proto

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 29, 2025 License: MIT Imports: 8 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_observer_proto protoreflect.FileDescriptor
View Source 
var Observer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Observer",
	HandlerType: (*ObserverServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Observe",
			Handler:    _Observer_Observe_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "observer.proto",
}

Observer_ServiceDesc is the grpc.ServiceDesc for Observer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterObserverServer 

func RegisterObserverServer(s grpc.ServiceRegistrar, srv ObserverServer)

Types

type Event 

type Event struct {
	Kind    string         `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Service string         `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Client  string         `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"`
	Type    string         `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Stats   *Stats         `protobuf:"bytes,5,opt,name=stats,proto3" json:"stats,omitempty"`
	Status  *ServiceStatus `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

func (*Event) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetClient 

func (x *Event) GetClient() string

func (*Event) GetKind 

func (x *Event) GetKind() string

func (*Event) GetService 

func (x *Event) GetService() string

func (*Event) GetStats 

func (x *Event) GetStats() *Stats

func (*Event) GetStatus 

func (x *Event) GetStatus() *ServiceStatus

func (*Event) GetType 

func (x *Event) GetType() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type ObserveReply 

type ObserveReply struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*ObserveReply) Descriptor deprecated 

func (*ObserveReply) Descriptor() ([]byte, []int)

Deprecated: Use ObserveReply.ProtoReflect.Descriptor instead.

func (*ObserveReply) GetOk 

func (x *ObserveReply) GetOk() bool

func (*ObserveReply) ProtoMessage 

func (*ObserveReply) ProtoMessage()

func (*ObserveReply) ProtoReflect 

func (x *ObserveReply) ProtoReflect() protoreflect.Message

func (*ObserveReply) Reset 

func (x *ObserveReply) Reset()

func (*ObserveReply) String 

func (x *ObserveReply) String() string

type ObserveRequest 

type ObserveRequest struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*ObserveRequest) Descriptor deprecated 

func (*ObserveRequest) Descriptor() ([]byte, []int)

Deprecated: Use ObserveRequest.ProtoReflect.Descriptor instead.

func (*ObserveRequest) GetEvents 

func (x *ObserveRequest) GetEvents() []*Event

func (*ObserveRequest) ProtoMessage 

func (*ObserveRequest) ProtoMessage()

func (*ObserveRequest) ProtoReflect 

func (x *ObserveRequest) ProtoReflect() protoreflect.Message

func (*ObserveRequest) Reset 

func (x *ObserveRequest) Reset()

func (*ObserveRequest) String 

func (x *ObserveRequest) String() string

type ObserverClient 

type ObserverClient interface {
	Observe(ctx context.Context, in *ObserveRequest, opts ...grpc.CallOption) (*ObserveReply, error)
}

ObserverClient is the client API for Observer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewObserverClient 

func NewObserverClient(cc grpc.ClientConnInterface) ObserverClient

type ObserverServer 

type ObserverServer interface {
	Observe(context.Context, *ObserveRequest) (*ObserveReply, error)
	// contains filtered or unexported methods
}

ObserverServer is the server API for Observer service. All implementations must embed UnimplementedObserverServer for forward compatibility

type ServiceStatus 

type ServiceStatus struct {
	State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Msg   string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceStatus) Descriptor deprecated 

func (*ServiceStatus) Descriptor() ([]byte, []int)

Deprecated: Use ServiceStatus.ProtoReflect.Descriptor instead.

func (*ServiceStatus) GetMsg 

func (x *ServiceStatus) GetMsg() string

func (*ServiceStatus) GetState 

func (x *ServiceStatus) GetState() string

func (*ServiceStatus) ProtoMessage 

func (*ServiceStatus) ProtoMessage()

func (*ServiceStatus) ProtoReflect 

func (x *ServiceStatus) ProtoReflect() protoreflect.Message

func (*ServiceStatus) Reset 

func (x *ServiceStatus) Reset()

func (*ServiceStatus) String 

func (x *ServiceStatus) String() string

type Stats 

type Stats struct {
	TotalConns   uint64 `protobuf:"varint,1,opt,name=totalConns,proto3" json:"totalConns,omitempty"`
	CurrentConns uint64 `protobuf:"varint,2,opt,name=currentConns,proto3" json:"currentConns,omitempty"`
	InputBytes   uint64 `protobuf:"varint,3,opt,name=inputBytes,proto3" json:"inputBytes,omitempty"`
	OutputBytes  uint64 `protobuf:"varint,4,opt,name=outputBytes,proto3" json:"outputBytes,omitempty"`
	TotalErrs    uint64 `protobuf:"varint,5,opt,name=totalErrs,proto3" json:"totalErrs,omitempty"`
	// contains filtered or unexported fields
}

func (*Stats) Descriptor deprecated 

func (*Stats) Descriptor() ([]byte, []int)

Deprecated: Use Stats.ProtoReflect.Descriptor instead.

func (*Stats) GetCurrentConns 

func (x *Stats) GetCurrentConns() uint64

func (*Stats) GetInputBytes 

func (x *Stats) GetInputBytes() uint64

func (*Stats) GetOutputBytes 

func (x *Stats) GetOutputBytes() uint64

func (*Stats) GetTotalConns 

func (x *Stats) GetTotalConns() uint64

func (*Stats) GetTotalErrs 

func (x *Stats) GetTotalErrs() uint64

func (*Stats) ProtoMessage 

func (*Stats) ProtoMessage()

func (*Stats) ProtoReflect 

func (x *Stats) ProtoReflect() protoreflect.Message

func (*Stats) Reset 

func (x *Stats) Reset()

func (*Stats) String 

func (x *Stats) String() string

type UnimplementedObserverServer 

type UnimplementedObserverServer struct {
}

UnimplementedObserverServer must be embedded to have forward compatible implementations.

func (UnimplementedObserverServer) Observe 

func (UnimplementedObserverServer) Observe(context.Context, *ObserveRequest) (*ObserveReply, error)

type UnsafeObserverServer 

type UnsafeObserverServer interface {
	// contains filtered or unexported methods
}

UnsafeObserverServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ObserverServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.