pulsar

Documentation

Index

• type PulsarSink
  • func NewPulsarSink(ctx context.Context, clientOptions *pulsar.ClientOptions, ...) (*PulsarSink, error)
  • func (ps *PulsarSink) In() chan<- interface{}
• type PulsarSource
  • func NewPulsarSource(ctx context.Context, clientOptions *pulsar.ClientOptions, ...) (*PulsarSource, error)
  • func (ps *PulsarSource) Out() <-chan interface{}
  • func (ps *PulsarSource) Via(_flow streams.Flow) streams.Flow

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