broker

Documentation

Index

• func RegisterBrokerServiceServer(s *grpc.Server, srv BrokerServiceServer)
• type BrokerServiceClient
  • func NewBrokerServiceClient(cc *grpc.ClientConn) BrokerServiceClient
• type BrokerServiceServer

Functions

func RegisterBrokerServiceServer

func RegisterBrokerServiceServer(s *grpc.Server, srv BrokerServiceServer)

Types

type BrokerServiceClient

type BrokerServiceClient interface {
	WritePoints(ctx context.Context, in *common.Request, opts ...grpc.CallOption) (*common.Response, error)
}

BrokerServiceClient is the client API for BrokerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBrokerServiceClient

func NewBrokerServiceClient(cc *grpc.ClientConn) BrokerServiceClient

type BrokerServiceServer

type BrokerServiceServer interface {
	WritePoints(context.Context, *common.Request) (*common.Response, error)
}

BrokerServiceServer is the server API for BrokerService service.