wadohbe

Documentation

Index

• type Client
  • func NewClient(address string) (*Client, error)
  • func (c *Client) ReceiveMessage() <-chan EventMessage
• type EventMessage

Types

type Client

type Client struct {
	Service pb.ControllerServiceClient
	// contains filtered or unexported fields
}

Client is wrapper around wadoh-be grpc client.

func NewClient

func NewClient(address string) (*Client, error)

func (*Client) ReceiveMessage

func (c *Client) ReceiveMessage() <-chan EventMessage

ReceiveMessage wraps pb.ControllerServiceClient.ReceiveMessage call with additional retry without closing channel when got retryable error code such Unavailable. But after maxretries limit hit, channel will be closed.

type EventMessage

type EventMessage interface {
	GetFrom() string
	GetJid() string
	GetMessage() string
}