gbgrpc

Documentation

Index

• Variables
• func FetchEvents(gb *gloomberg.Gloomberg)
• func NewClient(grpcAddress string) gen.GloombergClient
• func StartServer(gb *gloomberg.Gloomberg, sw *seawa.SeaWatcher)
• type GloombergGRPC
  • func NewGloombergGRPC(gb *gloomberg.Gloomberg, sw *seawa.SeaWatcher) *GloombergGRPC
  • func (gg *GloombergGRPC) GetEvents(req *gen.SubscriptionRequest, stream gen.Gloomberg_GetEventsServer) error
  • func (gg *GloombergGRPC) Subscribe(_ context.Context, req *gen.SubscriptionRequest) (*emptypb.Empty, error)

Variables

var GRPCClient gen.GloombergClient

Functions

func FetchEvents

func FetchEvents(gb *gloomberg.Gloomberg)

func NewClient

func NewClient(grpcAddress string) gen.GloombergClient

NewClient to grpc server.

func StartServer

func StartServer(gb *gloomberg.Gloomberg, sw *seawa.SeaWatcher)

Types

type GloombergGRPC

type GloombergGRPC struct {

	// server
	*remote.ClientGRPC

	gen.UnimplementedGloombergServer
	// contains filtered or unexported fields
}

func NewGloombergGRPC

func NewGloombergGRPC(gb *gloomberg.Gloomberg, sw *seawa.SeaWatcher) *GloombergGRPC

new GloombergGRPC.

func (*GloombergGRPC) GetEvents

func (gg *GloombergGRPC) GetEvents(req *gen.SubscriptionRequest, stream gen.Gloomberg_GetEventsServer) error

func (*GloombergGRPC) Subscribe

func (gg *GloombergGRPC) Subscribe(_ context.Context, req *gen.SubscriptionRequest) (*emptypb.Empty, error)