Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CallGrpcServer ¶
func CallGrpcServer(hostport string)
func CallGrpcServerv2 ¶
func CallGrpcServerv2(hostport string)
Types ¶
type MessageQueue ¶
type MessageQueue struct {
// contains filtered or unexported fields
}
Queue to hold incoming messages
func (*MessageQueue) Dequeue ¶
func (q *MessageQueue) Dequeue() *pb.ServerMessage
Dequeue removes and returns the oldest message from the queue
func (*MessageQueue) Enqueue ¶
func (q *MessageQueue) Enqueue(msg *pb.ServerMessage)
Enqueue adds a message to the queue
Source Files
Click to show internal directories.
Click to hide internal directories.