gnmi

Documentation

Index

• Variables
• func RegisterCollectorServer(s grpc.ServiceRegistrar, 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)
• type UnsafeCollectorServer

Variables

var Collector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gnmi.Collector",
	HandlerType: (*CollectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Reconnect",
			Handler:    _Collector_Reconnect_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/openconfig/gnmi/proto/collector/collector.proto",
}

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

var File_github_com_openconfig_gnmi_proto_collector_collector_proto protoreflect.FileDescriptor

Functions

func RegisterCollectorServer

func RegisterCollectorServer(s grpc.ServiceRegistrar, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#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. All implementations should embed UnimplementedCollectorServer for forward compatibility

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 should be embedded to have forward compatible implementations.

func (UnimplementedCollectorServer) Reconnect

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

type UnsafeCollectorServer

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

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