monitor

Documentation

Index

• Variables
• func RegisterMonitorServiceServer(s grpc.ServiceRegistrar, srv MonitorServiceServer)
• type MonitorRequest
  • func (*MonitorRequest) Descriptor() ([]byte, []int)
  • func (x *MonitorRequest) GetInterval() int64
  • func (x *MonitorRequest) GetMethod() string
  • func (x *MonitorRequest) GetSdid() string
  • func (*MonitorRequest) ProtoMessage()
  • func (x *MonitorRequest) ProtoReflect() protoreflect.Message
  • func (x *MonitorRequest) Reset()
  • func (x *MonitorRequest) String() string
• type MonitorResponse
  • func (*MonitorResponse) Descriptor() ([]byte, []int)
  • func (x *MonitorResponse) GetMonitorResponseItems() []*MonitorResponseItem
  • func (*MonitorResponse) ProtoMessage()
  • func (x *MonitorResponse) ProtoReflect() protoreflect.Message
  • func (x *MonitorResponse) Reset()
  • func (x *MonitorResponse) String() string
• type MonitorResponseItem
  • func (*MonitorResponseItem) Descriptor() ([]byte, []int)
  • func (x *MonitorResponseItem) GetAvgRT() float32
  • func (x *MonitorResponseItem) GetFail() int64
  • func (x *MonitorResponseItem) GetFailRate() float32
  • func (x *MonitorResponseItem) GetMethod() string
  • func (x *MonitorResponseItem) GetSdid() string
  • func (x *MonitorResponseItem) GetSuccess() int64
  • func (x *MonitorResponseItem) GetTimestamp() int64
  • func (x *MonitorResponseItem) GetTotal() int64
  • func (*MonitorResponseItem) ProtoMessage()
  • func (x *MonitorResponseItem) ProtoReflect() protoreflect.Message
  • func (x *MonitorResponseItem) Reset()
  • func (x *MonitorResponseItem) String() string
• type MonitorServiceClient
  • func NewMonitorServiceClient(cc grpc.ClientConnInterface) MonitorServiceClient
• type MonitorServiceServer
• type MonitorService_MonitorClient
• type MonitorService_MonitorServer
• type UnimplementedMonitorServiceServer
  • func (UnimplementedMonitorServiceServer) Monitor(*MonitorRequest, MonitorService_MonitorServer) error
• type UnsafeMonitorServiceServer

Variables

var File_extension_aop_monitor_api_ioc_golang_aop_monitor_monitor_proto protoreflect.FileDescriptor

var MonitorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ioc_golang.aop.monitor.MonitorService",
	HandlerType: (*MonitorServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Monitor",
			Handler:       _MonitorService_Monitor_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "extension/aop/monitor/api/ioc_golang/aop/monitor/monitor.proto",
}

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

Functions

func RegisterMonitorServiceServer

func RegisterMonitorServiceServer(s grpc.ServiceRegistrar, srv MonitorServiceServer)

Types

type MonitorRequest

type MonitorRequest struct {
	Sdid     string `protobuf:"bytes,1,opt,name=sdid,proto3" json:"sdid,omitempty"`
	Method   string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Interval int64  `protobuf:"varint,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*MonitorRequest) Descriptor

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

Deprecated: Use MonitorRequest.ProtoReflect.Descriptor instead.

func (*MonitorRequest) GetInterval

func (x *MonitorRequest) GetInterval() int64

func (*MonitorRequest) GetMethod

func (x *MonitorRequest) GetMethod() string

func (*MonitorRequest) GetSdid

func (x *MonitorRequest) GetSdid() string

func (*MonitorRequest) ProtoMessage

func (*MonitorRequest) ProtoMessage()

func (*MonitorRequest) ProtoReflect

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

func (*MonitorRequest) Reset

func (x *MonitorRequest) Reset()

func (*MonitorRequest) String

func (x *MonitorRequest) String() string

type MonitorResponse

type MonitorResponse struct {
	MonitorResponseItems []*MonitorResponseItem `protobuf:"bytes,1,rep,name=monitorResponseItems,proto3" json:"monitorResponseItems,omitempty"`
	// contains filtered or unexported fields
}

func (*MonitorResponse) Descriptor

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

Deprecated: Use MonitorResponse.ProtoReflect.Descriptor instead.

func (*MonitorResponse) GetMonitorResponseItems

func (x *MonitorResponse) GetMonitorResponseItems() []*MonitorResponseItem

func (*MonitorResponse) ProtoMessage

func (*MonitorResponse) ProtoMessage()

func (*MonitorResponse) ProtoReflect

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

func (*MonitorResponse) Reset

func (x *MonitorResponse) Reset()

func (*MonitorResponse) String

func (x *MonitorResponse) String() string

type MonitorResponseItem

type MonitorResponseItem struct {
	Timestamp int64   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Sdid      string  `protobuf:"bytes,2,opt,name=sdid,proto3" json:"sdid,omitempty"`
	Method    string  `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Total     int64   `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"`
	Success   int64   `protobuf:"varint,5,opt,name=success,proto3" json:"success,omitempty"`
	Fail      int64   `protobuf:"varint,6,opt,name=fail,proto3" json:"fail,omitempty"`
	AvgRT     float32 `protobuf:"fixed32,7,opt,name=avgRT,proto3" json:"avgRT,omitempty"`
	FailRate  float32 `protobuf:"fixed32,8,opt,name=failRate,proto3" json:"failRate,omitempty"`
	// contains filtered or unexported fields
}

func (*MonitorResponseItem) Descriptor

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

Deprecated: Use MonitorResponseItem.ProtoReflect.Descriptor instead.

func (*MonitorResponseItem) GetAvgRT

func (x *MonitorResponseItem) GetAvgRT() float32

func (*MonitorResponseItem) GetFail

func (x *MonitorResponseItem) GetFail() int64

func (*MonitorResponseItem) GetFailRate

func (x *MonitorResponseItem) GetFailRate() float32

func (*MonitorResponseItem) GetMethod

func (x *MonitorResponseItem) GetMethod() string

func (*MonitorResponseItem) GetSdid

func (x *MonitorResponseItem) GetSdid() string

func (*MonitorResponseItem) GetSuccess

func (x *MonitorResponseItem) GetSuccess() int64

func (*MonitorResponseItem) GetTimestamp

func (x *MonitorResponseItem) GetTimestamp() int64

func (*MonitorResponseItem) GetTotal

func (x *MonitorResponseItem) GetTotal() int64

func (*MonitorResponseItem) ProtoMessage

func (*MonitorResponseItem) ProtoMessage()

func (*MonitorResponseItem) ProtoReflect

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

func (*MonitorResponseItem) Reset

func (x *MonitorResponseItem) Reset()

func (*MonitorResponseItem) String

func (x *MonitorResponseItem) String() string

type MonitorServiceClient

type MonitorServiceClient interface {
	Monitor(ctx context.Context, in *MonitorRequest, opts ...grpc.CallOption) (MonitorService_MonitorClient, error)
}

MonitorServiceClient is the client API for MonitorService 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 NewMonitorServiceClient

func NewMonitorServiceClient(cc grpc.ClientConnInterface) MonitorServiceClient

type MonitorServiceServer

type MonitorServiceServer interface {
	Monitor(*MonitorRequest, MonitorService_MonitorServer) error
	// contains filtered or unexported methods
}

MonitorServiceServer is the server API for MonitorService service. All implementations must embed UnimplementedMonitorServiceServer for forward compatibility

type MonitorService_MonitorClient

type MonitorService_MonitorClient interface {
	Recv() (*MonitorResponse, error)
	grpc.ClientStream
}

type MonitorService_MonitorServer

type MonitorService_MonitorServer interface {
	Send(*MonitorResponse) error
	grpc.ServerStream
}

type UnimplementedMonitorServiceServer

type UnimplementedMonitorServiceServer struct {
}

UnimplementedMonitorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMonitorServiceServer) Monitor

func (UnimplementedMonitorServiceServer) Monitor(*MonitorRequest, MonitorService_MonitorServer) error

type UnsafeMonitorServiceServer

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

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