in fluent-bit-cloudwatch.go [37:55]
func addPluginInstance(ctx unsafe.Pointer) error {
pluginID := len(pluginInstances)
config := getConfiguration(ctx, pluginID)
err := config.Validate()
if err != nil {
return err
}
instance, err := cloudwatch.NewOutputPlugin(config)
if err != nil {
return err
}
output.FLBPluginSetContext(ctx, pluginID)
pluginInstances = append(pluginInstances, instance)
return nil
}