proto

package
v0.2.5 Latest Latest
Warning

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

Go to latest
Published: Feb 20, 2021 License: MIT Imports: 10 Imported by: 0

Documentation

Index

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) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetCode

func (x *Response) GetCode() int32

func (*Response) GetMessage

func (x *Response) GetMessage() string

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) ProtoReflect

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

func (*Response) Reset

func (x *Response) Reset()

func (*Response) String

func (x *Response) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Stats.ProtoReflect.Descriptor instead.

func (*Stats) GetMetrics

func (x *Stats) GetMetrics() *_struct.Struct

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 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) Descriptor() ([]byte, []int)

Deprecated: Use Target.ProtoReflect.Descriptor instead.

func (*Target) GetAddr

func (x *Target) GetAddr() string

func (*Target) GetInterval

func (x *Target) GetInterval() string

func (*Target) GetLabels

func (x *Target) GetLabels() map[string]string

func (*Target) ProtoMessage

func (*Target) ProtoMessage()

func (*Target) ProtoReflect

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

func (*Target) Reset

func (x *Target) Reset()

func (*Target) String

func (x *Target) String() string

type UnimplementedTCPProbeServer

type UnimplementedTCPProbeServer struct {
}

UnimplementedTCPProbeServer can be embedded to have forward compatible implementations.

func (*UnimplementedTCPProbeServer) Add

func (*UnimplementedTCPProbeServer) Delete

func (*UnimplementedTCPProbeServer) Get

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL