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.

func NewForwarderRegistrationClient 

func NewForwarderRegistrationClient(cc grpc.ClientConnInterface) ForwarderRegistrationClient

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 (m *ForwarderRegistrationRequest) String() 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.

func NewForwarderUnRegistrationClient 

func NewForwarderUnRegistrationClient(cc grpc.ClientConnInterface) ForwarderUnRegistrationClient

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 (m *ForwarderUnRegistrationReply) String() 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 (m *ForwarderUnRegistrationRequest) String() 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) RequestForwarderRegistration(ctx context.Context, req *ForwarderRegistrationRequest) (*ForwarderRegistrationReply, error)

func (*UnimplementedForwarderRegistrationServer) RequestLiveness 

func (*UnimplementedForwarderRegistrationServer) RequestLiveness(srv ForwarderRegistration_RequestLivenessServer) error

type UnimplementedForwarderUnRegistrationServer 

type UnimplementedForwarderUnRegistrationServer struct {
}

UnimplementedForwarderUnRegistrationServer can be embedded to have forward compatible implementations.

func (*UnimplementedForwarderUnRegistrationServer) RequestForwarderUnRegistration 

func (*UnimplementedForwarderUnRegistrationServer) RequestForwarderUnRegistration(ctx context.Context, req *ForwarderUnRegistrationRequest) (*ForwarderUnRegistrationReply, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.