Method NewSinkTube

fs/contube/contube.go:105–105

NewSinkTube returns a new channel that can be used to sink events The event.Commit() would be invoked after the event is sunk successfully The caller should close the channel when it is done

(ctx context.Context, config ConfigMap)

	// The event.Commit() would be invoked after the event is sunk successfully
	// The caller should close the channel when it is done
	NewSinkTube(ctx context.Context, config ConfigMap) (chan<- Record, error)
}

type TubeFactory interface {