apachepulsar

Documentation

Index

• type PulsarSink
  • func NewPulsarSink(client pulsar.Client, producer pulsar.Producer) *PulsarSink
  • func (ps *PulsarSink) Sink(ctx context.Context, datumStreamCh <-chan sinksdk.Datum) sinksdk.Responses

Types

type PulsarSink

type PulsarSink struct {
	// contains filtered or unexported fields
}

func NewPulsarSink

func NewPulsarSink(client pulsar.Client, producer pulsar.Producer) *PulsarSink

func (*PulsarSink) Sink

func (ps *PulsarSink) Sink(ctx context.Context, datumStreamCh <-chan sinksdk.Datum) sinksdk.Responses