apachepulsar

Documentation

Index

• type PulsarSource
  • func NewPulsarSource(client pulsar.Client, adminClient pulsaradmin.Client, consumer pulsar.Consumer) *PulsarSource
  • func (ps *PulsarSource) Ack(ctx context.Context, request sourcesdk.AckRequest)
  • func (ps *PulsarSource) Partitions(ctx context.Context) []int32
  • func (ps *PulsarSource) Pending(_ context.Context) int64
  • func (ps *PulsarSource) Read(_ context.Context, readRequest sourcesdk.ReadRequest, ...)

Types

type PulsarSource

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

func NewPulsarSource

func NewPulsarSource(client pulsar.Client, adminClient pulsaradmin.Client, consumer pulsar.Consumer) *PulsarSource

func (*PulsarSource) Ack

func (ps *PulsarSource) Ack(ctx context.Context, request sourcesdk.AckRequest)

func (*PulsarSource) Partitions

func (ps *PulsarSource) Partitions(ctx context.Context) []int32

func (*PulsarSource) Pending

func (ps *PulsarSource) Pending(_ context.Context) int64

func (*PulsarSource) Read

func (ps *PulsarSource) Read(_ context.Context, readRequest sourcesdk.ReadRequest, messageCh chan<- sourcesdk.Message)