Versions in this module Expand all Collapse all v0 v0.1.1 Aug 21, 2021 v0.1.0 Aug 21, 2021 Changes in this version + var File_proto_msa_observer_proto protoreflect.FileDescriptor + var Observer_ServiceDesc = grpc.ServiceDesc + func RegisterObserverServer(s grpc.ServiceRegistrar, srv ObserverServer) + type Info struct + GroupType string + Host string + Key string + Port int32 + func (*Info) Descriptor() ([]byte, []int) + func (*Info) ProtoMessage() + func (x *Info) GetGroupType() string + func (x *Info) GetHost() string + func (x *Info) GetKey() string + func (x *Info) GetPort() int32 + func (x *Info) ProtoReflect() protoreflect.Message + func (x *Info) Reset() + func (x *Info) String() string + type ObserverClient interface + PushFirst func(ctx context.Context, in *RequestPushFirst, opts ...grpc.CallOption) (*ResponsePushFirst, error) + PushStats func(ctx context.Context, in *RequestPushStats, opts ...grpc.CallOption) (*Response, error) + PushStatus func(ctx context.Context, in *RequestPushStatus, opts ...grpc.CallOption) (*Response, error) + RestartService func(ctx context.Context, in *RequestRestartService, opts ...grpc.CallOption) (*Response, error) + Who func(ctx context.Context, in *RequestWho, opts ...grpc.CallOption) (*ResponseWho, error) + func NewObserverClient(cc grpc.ClientConnInterface) ObserverClient + type ObserverServer interface + PushFirst func(context.Context, *RequestPushFirst) (*ResponsePushFirst, error) + PushStats func(context.Context, *RequestPushStats) (*Response, error) + PushStatus func(context.Context, *RequestPushStatus) (*Response, error) + RestartService func(context.Context, *RequestRestartService) (*Response, error) + Who func(context.Context, *RequestWho) (*ResponseWho, error) + type RequestPushFirst struct + Host string + Key string + Port int32 + func (*RequestPushFirst) Descriptor() ([]byte, []int) + func (*RequestPushFirst) ProtoMessage() + func (x *RequestPushFirst) GetHost() string + func (x *RequestPushFirst) GetKey() string + func (x *RequestPushFirst) GetPort() int32 + func (x *RequestPushFirst) ProtoReflect() protoreflect.Message + func (x *RequestPushFirst) Reset() + func (x *RequestPushFirst) String() string + type RequestPushStats struct + CurCpu float32 + CurHdd float32 + CurRam float32 + Key string + MaxCpu float32 + MaxHdd float32 + MaxRam float32 + func (*RequestPushStats) Descriptor() ([]byte, []int) + func (*RequestPushStats) ProtoMessage() + func (x *RequestPushStats) GetCurCpu() float32 + func (x *RequestPushStats) GetCurHdd() float32 + func (x *RequestPushStats) GetCurRam() float32 + func (x *RequestPushStats) GetKey() string + func (x *RequestPushStats) GetMaxCpu() float32 + func (x *RequestPushStats) GetMaxHdd() float32 + func (x *RequestPushStats) GetMaxRam() float32 + func (x *RequestPushStats) ProtoReflect() protoreflect.Message + func (x *RequestPushStats) Reset() + func (x *RequestPushStats) String() string + type RequestPushStatus struct + IsNew bool + Key string + Status msaUtils.StatusService + func (*RequestPushStatus) Descriptor() ([]byte, []int) + func (*RequestPushStatus) ProtoMessage() + func (x *RequestPushStatus) GetIsNew() bool + func (x *RequestPushStatus) GetKey() string + func (x *RequestPushStatus) GetStatus() msaUtils.StatusService + func (x *RequestPushStatus) ProtoReflect() protoreflect.Message + func (x *RequestPushStatus) Reset() + func (x *RequestPushStatus) String() string + type RequestRestartService struct + Key string + func (*RequestRestartService) Descriptor() ([]byte, []int) + func (*RequestRestartService) ProtoMessage() + func (x *RequestRestartService) GetKey() string + func (x *RequestRestartService) ProtoReflect() protoreflect.Message + func (x *RequestRestartService) Reset() + func (x *RequestRestartService) String() string + type RequestWho struct + GroupType string + func (*RequestWho) Descriptor() ([]byte, []int) + func (*RequestWho) ProtoMessage() + func (x *RequestWho) GetGroupType() string + func (x *RequestWho) ProtoReflect() protoreflect.Message + func (x *RequestWho) Reset() + func (x *RequestWho) String() string + type Response struct + Success bool + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (x *Response) GetSuccess() bool + func (x *Response) ProtoReflect() protoreflect.Message + func (x *Response) Reset() + func (x *Response) String() string + type ResponsePushFirst struct + Dependents []*Info + func (*ResponsePushFirst) Descriptor() ([]byte, []int) + func (*ResponsePushFirst) ProtoMessage() + func (x *ResponsePushFirst) GetDependents() []*Info + func (x *ResponsePushFirst) ProtoReflect() protoreflect.Message + func (x *ResponsePushFirst) Reset() + func (x *ResponsePushFirst) String() string + type ResponseWho struct + Key string + func (*ResponseWho) Descriptor() ([]byte, []int) + func (*ResponseWho) ProtoMessage() + func (x *ResponseWho) GetKey() string + func (x *ResponseWho) ProtoReflect() protoreflect.Message + func (x *ResponseWho) Reset() + func (x *ResponseWho) String() string + type UnimplementedObserverServer struct + func (UnimplementedObserverServer) PushFirst(context.Context, *RequestPushFirst) (*ResponsePushFirst, error) + func (UnimplementedObserverServer) PushStats(context.Context, *RequestPushStats) (*Response, error) + func (UnimplementedObserverServer) PushStatus(context.Context, *RequestPushStatus) (*Response, error) + func (UnimplementedObserverServer) RestartService(context.Context, *RequestRestartService) (*Response, error) + func (UnimplementedObserverServer) Who(context.Context, *RequestWho) (*ResponseWho, error) + type UnsafeObserverServer interface