grpc

Documentation

Index

• type Server
  • func NewServer() *Server
  • func (v *Server) AllocDatabase(ctx context.Context, request *proto.AllocDatabaseRequest) (*proto.AllocDatabaseResponse, error)
  • func (v *Server) AllocKv(ctx context.Context, request *proto.AllocKvRequest) (*proto.AllocKvResponse, error)
  • func (v *Server) AllocMessageQueue(ctx context.Context, request *proto.AllocMqRequest) (*proto.AllocMqResponse, error)
  • func (v *Server) Check(ctx context.Context, request *health.HealthCheckRequest) (*health.HealthCheckResponse, error)
  • func (v *Server) CountStreamConnection(ctx context.Context, request *proto.CountConnectionRequest) (*proto.CountConnectionResponse, error)
  • func (v *Server) Listen() error
  • func (v *Server) PushStream(ctx context.Context, request *proto.PushStreamRequest) (*proto.PushStreamResponse, error)
  • func (v *Server) PushStreamBatch(ctx context.Context, request *proto.PushStreamBatchRequest) (*proto.PushStreamResponse, error)
  • func (v *Server) Watch(request *health.HealthCheckRequest, server health.Health_WatchServer) error

Types

type Server

type Server struct {
	proto.UnimplementedDatabaseServiceServer
	proto.UnimplementedStreamServiceServer
	proto.UnimplementedAllocatorServiceServer
	health.UnimplementedHealthServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer() *Server

func (*Server) AllocDatabase

func (v *Server) AllocDatabase(ctx context.Context, request *proto.AllocDatabaseRequest) (*proto.AllocDatabaseResponse, error)

func (*Server) AllocKv

func (v *Server) AllocKv(ctx context.Context, request *proto.AllocKvRequest) (*proto.AllocKvResponse, error)

func (*Server) AllocMessageQueue

func (v *Server) AllocMessageQueue(ctx context.Context, request *proto.AllocMqRequest) (*proto.AllocMqResponse, error)

func (*Server) Check

func (v *Server) Check(ctx context.Context, request *health.HealthCheckRequest) (*health.HealthCheckResponse, error)

func (*Server) CountStreamConnection

func (v *Server) CountStreamConnection(ctx context.Context, request *proto.CountConnectionRequest) (*proto.CountConnectionResponse, error)

func (*Server) Listen

func (v *Server) Listen() error

func (*Server) PushStream

func (v *Server) PushStream(ctx context.Context, request *proto.PushStreamRequest) (*proto.PushStreamResponse, error)

func (*Server) PushStreamBatch

func (v *Server) PushStreamBatch(ctx context.Context, request *proto.PushStreamBatchRequest) (*proto.PushStreamResponse, error)

func (*Server) Watch

func (v *Server) Watch(request *health.HealthCheckRequest, server health.Health_WatchServer) error