PulsarLib

Documentation

Index

• func InitClient(URL string) *pulsar.Client
• func SendMessage(client *pulsar.Client, topic string, message []byte)
• func SendRequestAsync(client *pulsar.Client, topic string, message *MessageResponse, ...)
• func SendRequestSync(client *pulsar.Client, topic string, message *MessageResponse) []byte
• func WaitEvent(client *pulsar.Client, topic string, foo func([]byte))
• type MessageResponse
  • func NewRequest(msg string) *MessageResponse

Functions

func InitClient

func InitClient(URL string) *pulsar.Client

func SendMessage

func SendMessage(client *pulsar.Client, topic string, message []byte)

func SendRequestAsync

func SendRequestAsync(client *pulsar.Client, topic string, message *MessageResponse, foo func([]byte))

func SendRequestSync

func SendRequestSync(client *pulsar.Client, topic string, message *MessageResponse) []byte

func WaitEvent

func WaitEvent(client *pulsar.Client, topic string, foo func([]byte))

Types

type MessageResponse

type MessageResponse struct {
	Id  string `json:"id"`
	Msg string `json:"msg"`
}

func NewRequest

func NewRequest(msg string) *MessageResponse