payloads

Documentation

Index

• type Payload
  • func (p Payload) EventTime() time.Time
  • func (p Payload) ID() string
  • func (p Payload) Keys() []string
  • func (p Payload) Value() []byte
  • func (p Payload) Watermark() time.Time
• type SendResult

Types

type Payload

type Payload struct {
	Data string
}

func (Payload) EventTime

func (p Payload) EventTime() time.Time

func (Payload) ID

func (p Payload) ID() string

func (Payload) Keys

func (p Payload) Keys() []string

func (Payload) Value

func (p Payload) Value() []byte

func (Payload) Watermark

func (p Payload) Watermark() time.Time

type SendResult

type SendResult struct {
	MessageID pulsar.MessageID
	Err       error
}