Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GrpcHeartbeatSVC ¶
type GrpcHeartbeatSVC struct { pb.UnimplementedHeartbeatServiceServer // contains filtered or unexported fields }
GrpcHeartbeatSVC ...
func NewGrpcHeartbeatSVC ¶
func NewGrpcHeartbeatSVC(writePool *nodemanager.WriterNodePool, readPool *nodemanager.ReaderNodePool) *GrpcHeartbeatSVC
NewGrpcHeartbeatSVC ...
func (*GrpcHeartbeatSVC) Report ¶
func (g *GrpcHeartbeatSVC) Report(client pb.HeartbeatService_ReportServer) error
func (*GrpcHeartbeatSVC) SetRole ¶
func (g *GrpcHeartbeatSVC) SetRole(ctx context.Context, req *pb.SetRoleRequest) (*pb.SetRoleResponse, error)
Click to show internal directories.
Click to hide internal directories.