gnmi

Documentation

Index

• Variables
• func RegisterCollectorServer(s *grpc.Server, srv CollectorServer)
• type CollectorClient
  • func NewCollectorClient(cc grpc.ClientConnInterface) CollectorClient
• type CollectorServer
• type Nil
  • func (*Nil) Descriptor() ([]byte, []int)
  • func (*Nil) ProtoMessage()
  • func (x *Nil) ProtoReflect() protoreflect.Message
  • func (x *Nil) Reset()
  • func (x *Nil) String() string
• type ReconnectRequest
  • func (*ReconnectRequest) Descriptor() ([]byte, []int)
  • func (x *ReconnectRequest) GetTarget() []string
  • func (*ReconnectRequest) ProtoMessage()
  • func (x *ReconnectRequest) ProtoReflect() protoreflect.Message
  • func (x *ReconnectRequest) Reset()
  • func (x *ReconnectRequest) String() string
• type UnimplementedCollectorServer
  • func (*UnimplementedCollectorServer) Reconnect(context.Context, *ReconnectRequest) (*Nil, error)

Variables

var File_proto_collector_collector_proto protoreflect.FileDescriptor

Functions

func RegisterCollectorServer

func RegisterCollectorServer(s *grpc.Server, srv CollectorServer)

Types

type CollectorClient

type CollectorClient interface {
	// Reconnect requests that the existing connections for one or more specified
	// targets will be stopped and new connections established.
	Reconnect(ctx context.Context, in *ReconnectRequest, opts ...grpc.CallOption) (*Nil, error)
}

CollectorClient is the client API for Collector service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCollectorClient

func NewCollectorClient(cc grpc.ClientConnInterface) CollectorClient

type CollectorServer

type CollectorServer interface {
	// Reconnect requests that the existing connections for one or more specified
	// targets will be stopped and new connections established.
	Reconnect(context.Context, *ReconnectRequest) (*Nil, error)
}

CollectorServer is the server API for Collector service.

type Nil

type Nil struct {
	// contains filtered or unexported fields
}

func (*Nil) Descriptor

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

Deprecated: Use Nil.ProtoReflect.Descriptor instead.

func (*Nil) ProtoMessage

func (*Nil) ProtoMessage()

func (*Nil) ProtoReflect

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

func (*Nil) Reset

func (x *Nil) Reset()

func (*Nil) String

func (x *Nil) String() string

type ReconnectRequest

type ReconnectRequest struct {
	Target []string `protobuf:"bytes,1,rep,name=target,proto3" json:"target,omitempty"` // List of targets to reconnect.
	// contains filtered or unexported fields
}

func (*ReconnectRequest) Descriptor

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

Deprecated: Use ReconnectRequest.ProtoReflect.Descriptor instead.

func (*ReconnectRequest) GetTarget

func (x *ReconnectRequest) GetTarget() []string

func (*ReconnectRequest) ProtoMessage

func (*ReconnectRequest) ProtoMessage()

func (*ReconnectRequest) ProtoReflect

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

func (*ReconnectRequest) Reset

func (x *ReconnectRequest) Reset()

func (*ReconnectRequest) String

func (x *ReconnectRequest) String() string

type UnimplementedCollectorServer

type UnimplementedCollectorServer struct {
}

UnimplementedCollectorServer can be embedded to have forward compatible implementations.

func (*UnimplementedCollectorServer) Reconnect

func (*UnimplementedCollectorServer) Reconnect(context.Context, *ReconnectRequest) (*Nil, error)