position

package

v0.5.4 Latest Latest Go to latest Published: Nov 21, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type TopicPosition struct {
	ReplayID []byte    `json:"replayID"`
	ReadTime time.Time `json:"readTime"`
}

type TopicPositions map[string]TopicPosition

type Topics struct {
	Topics TopicPositions `json:"topics"`
}

func NewTopicPosition() Topics

func ParseSDKPosition(sdkPos opencdc.Position, topic string) (Topics, error)

func (p Topics) SetTopicReplayID(topic string, replayID []byte) error

func (p Topics) SetTopics(topics []string)

func (p Topics) ToSDKPosition() opencdc.Position

func (p Topics) TopicReplayID(topic string) []byte