utils

Documentation

Index

• func CalculateMsgLength(message pulsar.Message) int
• func GetLatestMsgId(partitionedTopic, addr string) (msg []byte, err error)
• func HttpGet(url string, params map[string]string, header map[string]string) (resp []byte, err error)
• func PartitionedTopic(topic string, partition int) string
• func ReadEarliestMsg(partitionedTopic string, maxWaitMs int, pulsarClient pulsar.Client) (pulsar.Message, error)
• func ReadLastedMsg(partitionedTopic string, maxWaitMs int, msgIdBytes []byte, ...) (pulsar.Message, error)

Functions

func CalculateMsgLength

func CalculateMsgLength(message pulsar.Message) int

func GetLatestMsgId

func GetLatestMsgId(partitionedTopic, addr string) (msg []byte, err error)

func HttpGet

func HttpGet(url string, params map[string]string, header map[string]string) (resp []byte, err error)

func PartitionedTopic

func PartitionedTopic(topic string, partition int) string

func ReadEarliestMsg

func ReadEarliestMsg(partitionedTopic string, maxWaitMs int, pulsarClient pulsar.Client) (pulsar.Message, error)

func ReadLastedMsg

func ReadLastedMsg(partitionedTopic string, maxWaitMs int, msgIdBytes []byte, pulsarClient pulsar.Client) (pulsar.Message, error)