Documentation
¶
Overview ¶
Package pulsar implements the Apache Pulsar connector.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PulsarSink ¶
type PulsarSink struct {
// contains filtered or unexported fields
}
PulsarSink connector
func NewPulsarSink ¶
func NewPulsarSink(ctx context.Context, clientOptions *pulsar.ClientOptions, producerOptions *pulsar.ProducerOptions) (*PulsarSink, error)
NewPulsarSink returns a new PulsarSink instance
func (*PulsarSink) In ¶
func (ps *PulsarSink) In() chan<- interface{}
In returns an input channel for receiving data
type PulsarSource ¶
type PulsarSource struct {
// contains filtered or unexported fields
}
PulsarSource connector
func NewPulsarSource ¶
func NewPulsarSource(ctx context.Context, clientOptions *pulsar.ClientOptions, consumerOptions *pulsar.ConsumerOptions) (*PulsarSource, error)
NewPulsarSource returns a new PulsarSource instance
func (*PulsarSource) Out ¶
func (ps *PulsarSource) Out() <-chan interface{}
Out returns an output channel for sending data
func (*PulsarSource) Via ¶
func (ps *PulsarSource) Via(_flow streams.Flow) streams.Flow
Via streams data through the given flow
Source Files
Click to show internal directories.
Click to hide internal directories.