Documentation ¶
Index ¶
- Variables
- func RegisterTCPProbeServer(s *grpc.Server, srv TCPProbeServer)
- type Response
- type Stats
- type TCPProbeClient
- type TCPProbeServer
- type TCPProbe_GetClient
- type TCPProbe_GetServer
- type Target
- func (*Target) Descriptor() ([]byte, []int)deprecated
- func (x *Target) GetAddr() string
- func (x *Target) GetInterval() string
- func (x *Target) GetLabels() map[string]string
- func (*Target) ProtoMessage()
- func (x *Target) ProtoReflect() protoreflect.Message
- func (x *Target) Reset()
- func (x *Target) String() string
- type UnimplementedTCPProbeServer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_tcpprobe_proto protoreflect.FileDescriptor
Functions ¶
func RegisterTCPProbeServer ¶
func RegisterTCPProbeServer(s *grpc.Server, srv TCPProbeServer)
Types ¶
type Response ¶
type Response struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) GetMessage ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type Stats ¶
type Stats struct { Metrics *_struct.Struct `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` // contains filtered or unexported fields }
func (*Stats) Descriptor
deprecated
func (*Stats) GetMetrics ¶
func (*Stats) ProtoMessage ¶
func (*Stats) ProtoMessage()
func (*Stats) ProtoReflect ¶
func (x *Stats) ProtoReflect() protoreflect.Message
type TCPProbeClient ¶
type TCPProbeClient interface { Add(ctx context.Context, in *Target, opts ...grpc.CallOption) (*Response, error) Delete(ctx context.Context, in *Target, opts ...grpc.CallOption) (*Response, error) Get(ctx context.Context, in *Target, opts ...grpc.CallOption) (TCPProbe_GetClient, error) }
TCPProbeClient is the client API for TCPProbe service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTCPProbeClient ¶
func NewTCPProbeClient(cc grpc.ClientConnInterface) TCPProbeClient
type TCPProbeServer ¶
type TCPProbeServer interface { Add(context.Context, *Target) (*Response, error) Delete(context.Context, *Target) (*Response, error) Get(*Target, TCPProbe_GetServer) error }
TCPProbeServer is the server API for TCPProbe service.
type TCPProbe_GetClient ¶
type TCPProbe_GetClient interface { Recv() (*Stats, error) grpc.ClientStream }
type TCPProbe_GetServer ¶
type TCPProbe_GetServer interface { Send(*Stats) error grpc.ServerStream }
type Target ¶
type Target struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` Interval string `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Target) Descriptor
deprecated
func (*Target) GetInterval ¶
func (*Target) ProtoMessage ¶
func (*Target) ProtoMessage()
func (*Target) ProtoReflect ¶
func (x *Target) ProtoReflect() protoreflect.Message
type UnimplementedTCPProbeServer ¶
type UnimplementedTCPProbeServer struct { }
UnimplementedTCPProbeServer can be embedded to have forward compatible implementations.
func (*UnimplementedTCPProbeServer) Get ¶
func (*UnimplementedTCPProbeServer) Get(*Target, TCPProbe_GetServer) error
Click to show internal directories.
Click to hide internal directories.