controller

Documentation

Index

• func RegisterHealthService(server *grpc.Server, healthService *HealthService)
• func RegisterWithConsul() error
• type Chatserver
  • func NewChatServer() *Chatserver
  • func (s *Chatserver) ReceiveMessageStream(req *pb.MessageStreamRequest, stream pb.ChatService_ReceiveMessageStreamServer) error
  • func (s *Chatserver) SendMessage(ctx context.Context, req *pb.SendMessageRequest) (*pb.SendMessageResponse, error)
  • func (s *Chatserver) StartTimer(ctx context.Context)
• type HealthService
  • func NewHealthService() *HealthService
  • func (h *HealthService) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (h *HealthService) SetStatus(service string, status grpc_health_v1.HealthCheckResponse_ServingStatus)
  • func (h *HealthService) Watch(req *grpc_health_v1.HealthCheckRequest, srv grpc_health_v1.Health_WatchServer) error

Functions

func RegisterHealthService

func RegisterHealthService(server *grpc.Server, healthService *HealthService)

RegisterHealthService 将健康检查服务注册到 gRPC 服务

func RegisterWithConsul

func RegisterWithConsul() error

Types

type Chatserver

type Chatserver struct {
	pb.UnimplementedChatServiceServer
	// contains filtered or unexported fields
}

func NewChatServer

func NewChatServer() *Chatserver

NewChatServer 创建并返回一个新的 Chatserver 实例

func (*Chatserver) ReceiveMessageStream

func (s *Chatserver) ReceiveMessageStream(req *pb.MessageStreamRequest, stream pb.ChatService_ReceiveMessageStreamServer) error

func (*Chatserver) SendMessage

func (s *Chatserver) SendMessage(ctx context.Context, req *pb.SendMessageRequest) (*pb.SendMessageResponse, error)

func (*Chatserver) StartTimer

func (s *Chatserver) StartTimer(ctx context.Context)

type HealthService

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

HealthService 实现 grpc_health_v1.HealthServer 接口

func NewHealthService

func NewHealthService() *HealthService

NewHealthService 创建新的 HealthService 实例

func (*HealthService) Check

func (h *HealthService) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

Check 方法实现

func (*HealthService) SetStatus

func (h *HealthService) SetStatus(service string, status grpc_health_v1.HealthCheckResponse_ServingStatus)

SetStatus 设置服务健康状态

func (*HealthService) Watch

func (h *HealthService) Watch(req *grpc_health_v1.HealthCheckRequest, srv grpc_health_v1.Health_WatchServer) error

Watch 方法实现（非必须，可返回未实现错误）