Method Write

plugins/destination/test/client/client.go:257–257

(ctx context.Context, messages <-chan message.WriteMessage)

// is different so we need to adapt it to the interface.
type genericBatchWriter interface {
	Write(ctx context.Context, messages <-chan message.WriteMessage) error
	Flush(ctx context.Context) error
	Close(ctx context.Context) error
}