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.