rpc

Documentation

Index

• func ConstructDialOptions(maxCallRecvMsgSize int, extraOpts ...grpc.DialOption) []grpc.DialOption
• type ClientConfig
• type ClientService
  • func NewClient(ctx context.Context, cfg *ClientConfig) *ClientService
  • func (cs *ClientService) Conn() error
  • func (cs *ClientService) SendUDPMessage(msg string) error
  • func (cs *ClientService) Start()
  • func (cs *ClientService) Stop() error
• type ServerConfig
• type ServerService
  • func NewServer(ctx context.Context, cfg *ServerConfig) *ServerService
  • func (rs *ServerService) Start()
  • func (rs *ServerService) Stop() error

Functions

func ConstructDialOptions

func ConstructDialOptions(maxCallRecvMsgSize int, extraOpts ...grpc.DialOption) []grpc.DialOption

Types

type ClientConfig

type ClientConfig struct {
	Endpoints  []string
	MaxMsgSize int
	DB         db.AccessRedisDB
}

type ClientService

type ClientService struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, cfg *ClientConfig) *ClientService

NewClient creates a new gRPC client - Connection Router gRPC Client

func (*ClientService) Conn

func (cs *ClientService) Conn() error

func (*ClientService) SendUDPMessage

func (cs *ClientService) SendUDPMessage(msg string) error

func (*ClientService) Start

func (cs *ClientService) Start()

func (*ClientService) Stop

func (cs *ClientService) Stop() error

type ServerConfig

type ServerConfig struct {
	Addr       string
	MaxMsgSize int
	Socket     socket.Socket
}

type ServerService

type ServerService struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context, cfg *ServerConfig) *ServerService

NewServer creates a new gRPC server - Propagation Manager gRPC Server

func (*ServerService) Start

func (rs *ServerService) Start()

func (*ServerService) Stop

func (rs *ServerService) Stop() error