forwarderregistrar

package
v1.0.2 Latest Latest
Warning

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

Go to latest
Published: Dec 10, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterForwarderRegistrationServer

func RegisterForwarderRegistrationServer(s *grpc.Server, srv ForwarderRegistrationServer)

func RegisterForwarderUnRegistrationServer

func RegisterForwarderUnRegistrationServer(s *grpc.Server, srv ForwarderUnRegistrationServer)

Types

type ForwarderRegistrationClient

type ForwarderRegistrationClient interface {
	RequestForwarderRegistration(ctx context.Context, in *ForwarderRegistrationRequest, opts ...grpc.CallOption) (*ForwarderRegistrationReply, error)
	// RequestLiveness is a stream initiated by NSM to inform the forwarder that NSM is still alive and
	// no re-registration is required. Detection a failure on this "channel" will mean
	// that NSM is gone and the forwarder needs to start re-registration logic.
	RequestLiveness(ctx context.Context, opts ...grpc.CallOption) (ForwarderRegistration_RequestLivenessClient, error)
}

ForwarderRegistrationClient is the client API for ForwarderRegistration service.

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

type ForwarderRegistrationReply

type ForwarderRegistrationReply struct {
	Registered           bool     `protobuf:"varint,1,opt,name=registered,proto3" json:"registered,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ForwarderRegistrationReply) Descriptor

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

func (*ForwarderRegistrationReply) GetRegistered

func (m *ForwarderRegistrationReply) GetRegistered() bool

func (*ForwarderRegistrationReply) ProtoMessage

func (*ForwarderRegistrationReply) ProtoMessage()

func (*ForwarderRegistrationReply) Reset

func (m *ForwarderRegistrationReply) Reset()

func (*ForwarderRegistrationReply) String

func (m *ForwarderRegistrationReply) String() string

func (*ForwarderRegistrationReply) XXX_DiscardUnknown

func (m *ForwarderRegistrationReply) XXX_DiscardUnknown()

func (*ForwarderRegistrationReply) XXX_Marshal

func (m *ForwarderRegistrationReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForwarderRegistrationReply) XXX_Merge

func (m *ForwarderRegistrationReply) XXX_Merge(src proto.Message)

func (*ForwarderRegistrationReply) XXX_Size

func (m *ForwarderRegistrationReply) XXX_Size() int

func (*ForwarderRegistrationReply) XXX_Unmarshal

func (m *ForwarderRegistrationReply) XXX_Unmarshal(b []byte) error

type ForwarderRegistrationRequest

type ForwarderRegistrationRequest struct {
	ForwarderName        string   `protobuf:"bytes,1,opt,name=forwarder_name,json=forwarderName,proto3" json:"forwarder_name,omitempty"`
	ForwarderSocket      string   `protobuf:"bytes,2,opt,name=forwarder_socket,json=forwarderSocket,proto3" json:"forwarder_socket,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ForwarderRegistrationRequest is sent by the forwarder to NSM to advertise itself and inform NSM about the location of the forwarder socket and its initially supported parameters.

func (*ForwarderRegistrationRequest) Descriptor

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

func (*ForwarderRegistrationRequest) GetForwarderName

func (m *ForwarderRegistrationRequest) GetForwarderName() string

func (*ForwarderRegistrationRequest) GetForwarderSocket

func (m *ForwarderRegistrationRequest) GetForwarderSocket() string

func (*ForwarderRegistrationRequest) ProtoMessage

func (*ForwarderRegistrationRequest) ProtoMessage()

func (*ForwarderRegistrationRequest) Reset

func (m *ForwarderRegistrationRequest) Reset()

func (*ForwarderRegistrationRequest) String

func (*ForwarderRegistrationRequest) XXX_DiscardUnknown

func (m *ForwarderRegistrationRequest) XXX_DiscardUnknown()

func (*ForwarderRegistrationRequest) XXX_Marshal

func (m *ForwarderRegistrationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForwarderRegistrationRequest) XXX_Merge

func (m *ForwarderRegistrationRequest) XXX_Merge(src proto.Message)

func (*ForwarderRegistrationRequest) XXX_Size

func (m *ForwarderRegistrationRequest) XXX_Size() int

func (*ForwarderRegistrationRequest) XXX_Unmarshal

func (m *ForwarderRegistrationRequest) XXX_Unmarshal(b []byte) error

type ForwarderRegistrationServer

type ForwarderRegistrationServer interface {
	RequestForwarderRegistration(context.Context, *ForwarderRegistrationRequest) (*ForwarderRegistrationReply, error)
	// RequestLiveness is a stream initiated by NSM to inform the forwarder that NSM is still alive and
	// no re-registration is required. Detection a failure on this "channel" will mean
	// that NSM is gone and the forwarder needs to start re-registration logic.
	RequestLiveness(ForwarderRegistration_RequestLivenessServer) error
}

ForwarderRegistrationServer is the server API for ForwarderRegistration service.

type ForwarderRegistration_RequestLivenessClient

type ForwarderRegistration_RequestLivenessClient interface {
	Send(*empty.Empty) error
	Recv() (*empty.Empty, error)
	grpc.ClientStream
}

type ForwarderRegistration_RequestLivenessServer

type ForwarderRegistration_RequestLivenessServer interface {
	Send(*empty.Empty) error
	Recv() (*empty.Empty, error)
	grpc.ServerStream
}

type ForwarderUnRegistrationClient

type ForwarderUnRegistrationClient interface {
	RequestForwarderUnRegistration(ctx context.Context, in *ForwarderUnRegistrationRequest, opts ...grpc.CallOption) (*ForwarderUnRegistrationReply, error)
}

ForwarderUnRegistrationClient is the client API for ForwarderUnRegistration service.

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

type ForwarderUnRegistrationReply

type ForwarderUnRegistrationReply struct {
	UnRegistered         bool     `protobuf:"varint,1,opt,name=un_registered,json=unRegistered,proto3" json:"un_registered,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ForwarderUnRegistrationReply) Descriptor

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

func (*ForwarderUnRegistrationReply) GetUnRegistered

func (m *ForwarderUnRegistrationReply) GetUnRegistered() bool

func (*ForwarderUnRegistrationReply) ProtoMessage

func (*ForwarderUnRegistrationReply) ProtoMessage()

func (*ForwarderUnRegistrationReply) Reset

func (m *ForwarderUnRegistrationReply) Reset()

func (*ForwarderUnRegistrationReply) String

func (*ForwarderUnRegistrationReply) XXX_DiscardUnknown

func (m *ForwarderUnRegistrationReply) XXX_DiscardUnknown()

func (*ForwarderUnRegistrationReply) XXX_Marshal

func (m *ForwarderUnRegistrationReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForwarderUnRegistrationReply) XXX_Merge

func (m *ForwarderUnRegistrationReply) XXX_Merge(src proto.Message)

func (*ForwarderUnRegistrationReply) XXX_Size

func (m *ForwarderUnRegistrationReply) XXX_Size() int

func (*ForwarderUnRegistrationReply) XXX_Unmarshal

func (m *ForwarderUnRegistrationReply) XXX_Unmarshal(b []byte) error

type ForwarderUnRegistrationRequest

type ForwarderUnRegistrationRequest struct {
	ForwarderName        string   `protobuf:"bytes,1,opt,name=forwarder_name,json=forwarderName,proto3" json:"forwarder_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ForwarderUnRegistrationRequest is sent by the forwarder to NSM to remove itself from the list of available forwarders.

func (*ForwarderUnRegistrationRequest) Descriptor

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

func (*ForwarderUnRegistrationRequest) GetForwarderName

func (m *ForwarderUnRegistrationRequest) GetForwarderName() string

func (*ForwarderUnRegistrationRequest) ProtoMessage

func (*ForwarderUnRegistrationRequest) ProtoMessage()

func (*ForwarderUnRegistrationRequest) Reset

func (m *ForwarderUnRegistrationRequest) Reset()

func (*ForwarderUnRegistrationRequest) String

func (*ForwarderUnRegistrationRequest) XXX_DiscardUnknown

func (m *ForwarderUnRegistrationRequest) XXX_DiscardUnknown()

func (*ForwarderUnRegistrationRequest) XXX_Marshal

func (m *ForwarderUnRegistrationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForwarderUnRegistrationRequest) XXX_Merge

func (m *ForwarderUnRegistrationRequest) XXX_Merge(src proto.Message)

func (*ForwarderUnRegistrationRequest) XXX_Size

func (m *ForwarderUnRegistrationRequest) XXX_Size() int

func (*ForwarderUnRegistrationRequest) XXX_Unmarshal

func (m *ForwarderUnRegistrationRequest) XXX_Unmarshal(b []byte) error

type ForwarderUnRegistrationServer

type ForwarderUnRegistrationServer interface {
	RequestForwarderUnRegistration(context.Context, *ForwarderUnRegistrationRequest) (*ForwarderUnRegistrationReply, error)
}

ForwarderUnRegistrationServer is the server API for ForwarderUnRegistration service.

type UnimplementedForwarderRegistrationServer

type UnimplementedForwarderRegistrationServer struct {
}

UnimplementedForwarderRegistrationServer can be embedded to have forward compatible implementations.

func (*UnimplementedForwarderRegistrationServer) RequestForwarderRegistration

func (*UnimplementedForwarderRegistrationServer) RequestLiveness

type UnimplementedForwarderUnRegistrationServer

type UnimplementedForwarderUnRegistrationServer struct {
}

UnimplementedForwarderUnRegistrationServer can be embedded to have forward compatible implementations.

func (*UnimplementedForwarderUnRegistrationServer) RequestForwarderUnRegistration

Jump to

Keyboard shortcuts

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