Method NewSourceTube

fs/contube/contube.go:98–98

NewSourceTube returns a new channel that can be used to receive events The channel would be closed when the context is done

(ctx context.Context, config ConfigMap)

	// NewSourceTube returns a new channel that can be used to receive events
	// The channel would be closed when the context is done
	NewSourceTube(ctx context.Context, config ConfigMap) (<-chan Record, error)
}

type SinkTubeFactory interface {