grpc

Documentation

Index

• type ReverseUnaryMessage
• type ReverseUnaryRPCs
  • func NewReverseUnaryRPCs() ReverseUnaryRPCs

Types

type ReverseUnaryMessage

type ReverseUnaryMessage interface {
	proto.Message
	GetRequestId() string
}

type ReverseUnaryRPCs

type ReverseUnaryRPCs interface {
	Send(client string, req ReverseUnaryMessage) error
	WatchResponse(client string, reqID string, resp chan ReverseUnaryMessage) error
	DeleteWatch(client string, reqID string)

	ClientConnected(client string, stream grpc.ServerStream)
	ClientDisconnected(client string)
	ResponseReceived(client string, resp ReverseUnaryMessage) error
}

ReverseUnaryRPCs helps to implement reverse unary rpcs where server sends requests to a client and receives responses from the client.

func NewReverseUnaryRPCs

func NewReverseUnaryRPCs() ReverseUnaryRPCs