console

package

v0.12.0 Latest Latest Go to latest Published: Oct 19, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Sinks metadata to standard output.

sinks:
    name:console

This section is empty.

This section is empty.

func New(logger log.Logger) plugins.Syncer

type Sink struct {
	plugins.BasePlugin
	// contains filtered or unexported fields
}

func (*Sink) Close() error

func (s *Sink) Init(ctx context.Context, config plugins.Config) error

func (s *Sink) Sink(_ context.Context, batch []models.Record) error