pubsubsession

Documentation

Index

• func InitPubSubSession(client pulsar.Client, topicURL *url.URL, ...) (*pubSubSession, error)
• type PubSubSession
• type TimeStampedPayload

Functions

func InitPubSubSession

func InitPubSubSession(client pulsar.Client, topicURL *url.URL, localClusterName, remoteClusterName string) (*pubSubSession, error)

Types

type PubSubSession

type PubSubSession interface {
	GetChan() (chan []TimeStampedPayload, chan error)
	StartListening(ctx context.Context, expectedMsgCount int)
	StartSending(ctx context.Context, payloads [][]byte) []TimeStampedPayload
	ClosePubSubSession()
}

type TimeStampedPayload

type TimeStampedPayload struct {
	Payload   []byte
	TimeStamp time.Time
}