Versions in this module Expand all Collapse all v0 v0.2.1 Aug 14, 2025 Changes in this version + var File_observer_proto protoreflect.FileDescriptor + var Observer_ServiceDesc = grpc.ServiceDesc + func RegisterObserverServer(s grpc.ServiceRegistrar, srv ObserverServer) + type Event struct + Client string + Kind string + Service string + Stats *Stats + Status *ServiceStatus + Type string + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (x *Event) GetClient() string + func (x *Event) GetKind() string + func (x *Event) GetService() string + func (x *Event) GetStats() *Stats + func (x *Event) GetStatus() *ServiceStatus + func (x *Event) GetType() string + func (x *Event) ProtoReflect() protoreflect.Message + func (x *Event) Reset() + func (x *Event) String() string + type ObserveReply struct + Ok bool + func (*ObserveReply) Descriptor() ([]byte, []int) + func (*ObserveReply) ProtoMessage() + func (x *ObserveReply) GetOk() bool + func (x *ObserveReply) ProtoReflect() protoreflect.Message + func (x *ObserveReply) Reset() + func (x *ObserveReply) String() string + type ObserveRequest struct + Events []*Event + func (*ObserveRequest) Descriptor() ([]byte, []int) + func (*ObserveRequest) ProtoMessage() + func (x *ObserveRequest) GetEvents() []*Event + func (x *ObserveRequest) ProtoReflect() protoreflect.Message + func (x *ObserveRequest) Reset() + func (x *ObserveRequest) String() string + type ObserverClient interface + Observe func(ctx context.Context, in *ObserveRequest, opts ...grpc.CallOption) (*ObserveReply, error) + func NewObserverClient(cc grpc.ClientConnInterface) ObserverClient + type ObserverServer interface + Observe func(context.Context, *ObserveRequest) (*ObserveReply, error) + type ServiceStatus struct + Msg string + State string + func (*ServiceStatus) Descriptor() ([]byte, []int) + func (*ServiceStatus) ProtoMessage() + func (x *ServiceStatus) GetMsg() string + func (x *ServiceStatus) GetState() string + func (x *ServiceStatus) ProtoReflect() protoreflect.Message + func (x *ServiceStatus) Reset() + func (x *ServiceStatus) String() string + type Stats struct + CurrentConns uint64 + InputBytes uint64 + OutputBytes uint64 + TotalConns uint64 + TotalErrs uint64 + func (*Stats) Descriptor() ([]byte, []int) + func (*Stats) ProtoMessage() + func (x *Stats) GetCurrentConns() uint64 + func (x *Stats) GetInputBytes() uint64 + func (x *Stats) GetOutputBytes() uint64 + func (x *Stats) GetTotalConns() uint64 + func (x *Stats) GetTotalErrs() uint64 + func (x *Stats) ProtoReflect() protoreflect.Message + func (x *Stats) Reset() + func (x *Stats) String() string + type UnimplementedObserverServer struct + func (UnimplementedObserverServer) Observe(context.Context, *ObserveRequest) (*ObserveReply, error) + type UnsafeObserverServer interface
Go to main page