rpc

package
v0.5.48 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Daemon_GetBuildInfo_FullMethodName  = "/cunicu.rpc.Daemon/GetBuildInfo"
	Daemon_StreamEvents_FullMethodName  = "/cunicu.rpc.Daemon/StreamEvents"
	Daemon_UnWait_FullMethodName        = "/cunicu.rpc.Daemon/UnWait"
	Daemon_Shutdown_FullMethodName      = "/cunicu.rpc.Daemon/Shutdown"
	Daemon_Sync_FullMethodName          = "/cunicu.rpc.Daemon/Sync"
	Daemon_GetStatus_FullMethodName     = "/cunicu.rpc.Daemon/GetStatus"
	Daemon_SetConfig_FullMethodName     = "/cunicu.rpc.Daemon/SetConfig"
	Daemon_GetConfig_FullMethodName     = "/cunicu.rpc.Daemon/GetConfig"
	Daemon_GetCompletion_FullMethodName = "/cunicu.rpc.Daemon/GetCompletion"
	Daemon_ReloadConfig_FullMethodName  = "/cunicu.rpc.Daemon/ReloadConfig"
	Daemon_AddPeer_FullMethodName       = "/cunicu.rpc.Daemon/AddPeer"
)
View Source 
const (
	Signaling_GetSignalingMessage_FullMethodName = "/cunicu.rpc.Signaling/GetSignalingMessage"
	Signaling_PutSignalingMessage_FullMethodName = "/cunicu.rpc.Signaling/PutSignalingMessage"
)
View Source 
const (
	EndpointDiscoverySocket_RestartPeer_FullMethodName = "/cunicu.rpc.EndpointDiscoverySocket/RestartPeer"
)

Variables

View Source 
var (
	EventType_name = map[int32]string{
		0:  "BACKEND_READY",
		1:  "SIGNALING_MESSAGE",
		10: "PEER_ADDED",
		11: "PEER_REMOVED",
		12: "PEER_MODIFIED",
		13: "PEER_STATE_CHANGED",
		20: "INTERFACE_ADDED",
		21: "INTERFACE_REMOVED",
		22: "INTERFACE_MODIFIED",
	}
	EventType_value = map[string]int32{
		"BACKEND_READY":      0,
		"SIGNALING_MESSAGE":  1,
		"PEER_ADDED":         10,
		"PEER_REMOVED":       11,
		"PEER_MODIFIED":      12,
		"PEER_STATE_CHANGED": 13,
		"INTERFACE_ADDED":    20,
		"INTERFACE_REMOVED":  21,
		"INTERFACE_MODIFIED": 22,
	}
)

Enum value maps for EventType.

View Source 
var Daemon_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cunicu.rpc.Daemon",
	HandlerType: (*DaemonServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetBuildInfo",
			Handler:    _Daemon_GetBuildInfo_Handler,
		},
		{
			MethodName: "UnWait",
			Handler:    _Daemon_UnWait_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _Daemon_Shutdown_Handler,
		},
		{
			MethodName: "Sync",
			Handler:    _Daemon_Sync_Handler,
		},
		{
			MethodName: "GetStatus",
			Handler:    _Daemon_GetStatus_Handler,
		},
		{
			MethodName: "SetConfig",
			Handler:    _Daemon_SetConfig_Handler,
		},
		{
			MethodName: "GetConfig",
			Handler:    _Daemon_GetConfig_Handler,
		},
		{
			MethodName: "GetCompletion",
			Handler:    _Daemon_GetCompletion_Handler,
		},
		{
			MethodName: "ReloadConfig",
			Handler:    _Daemon_ReloadConfig_Handler,
		},
		{
			MethodName: "AddPeer",
			Handler:    _Daemon_AddPeer_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamEvents",
			Handler:       _Daemon_StreamEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "rpc/daemon.proto",
}

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

View Source 
var EndpointDiscoverySocket_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cunicu.rpc.EndpointDiscoverySocket",
	HandlerType: (*EndpointDiscoverySocketServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RestartPeer",
			Handler:    _EndpointDiscoverySocket_RestartPeer_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpc/epdisc.proto",
}

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

View Source 
var File_rpc_daemon_proto protoreflect.FileDescriptor
View Source 
var File_rpc_epdisc_proto protoreflect.FileDescriptor
View Source 
var File_rpc_event_proto protoreflect.FileDescriptor
View Source 
var File_rpc_invitation_proto protoreflect.FileDescriptor
View Source 
var File_rpc_signaling_proto protoreflect.FileDescriptor
View Source 
var Signaling_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cunicu.rpc.Signaling",
	HandlerType: (*SignalingServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSignalingMessage",
			Handler:    _Signaling_GetSignalingMessage_Handler,
		},
		{
			MethodName: "PutSignalingMessage",
			Handler:    _Signaling_PutSignalingMessage_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpc/signaling.proto",
}

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

Functions

func RegisterDaemonServer 

func RegisterDaemonServer(s grpc.ServiceRegistrar, srv DaemonServer)

func RegisterEndpointDiscoverySocketServer 

func RegisterEndpointDiscoverySocketServer(s grpc.ServiceRegistrar, srv EndpointDiscoverySocketServer)

func RegisterSignalingServer 

func RegisterSignalingServer(s grpc.ServiceRegistrar, srv SignalingServer)

Types

type AddPeerParams 

type AddPeerParams struct {
	Interface string `protobuf:"bytes,1,opt,name=interface,proto3" json:"interface,omitempty"`
	PublicKey []byte `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*AddPeerParams) Descriptor deprecated 

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

Deprecated: Use AddPeerParams.ProtoReflect.Descriptor instead.

func (*AddPeerParams) GetInterface 

func (x *AddPeerParams) GetInterface() string

func (*AddPeerParams) GetName 

func (x *AddPeerParams) GetName() string

func (*AddPeerParams) GetPublicKey 

func (x *AddPeerParams) GetPublicKey() []byte

func (*AddPeerParams) ProtoMessage 

func (*AddPeerParams) ProtoMessage()

func (*AddPeerParams) ProtoReflect 

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

func (*AddPeerParams) Reset 

func (x *AddPeerParams) Reset()

func (*AddPeerParams) String 

func (x *AddPeerParams) String() string

type AddPeerResp 

type AddPeerResp struct {
	Invitation *Invitation     `protobuf:"bytes,1,opt,name=invitation,proto3" json:"invitation,omitempty"`
	Interface  *core.Interface `protobuf:"bytes,2,opt,name=interface,proto3" json:"interface,omitempty"`
	// contains filtered or unexported fields
}

func (*AddPeerResp) Descriptor deprecated 

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

Deprecated: Use AddPeerResp.ProtoReflect.Descriptor instead.

func (*AddPeerResp) GetInterface 

func (x *AddPeerResp) GetInterface() *core.Interface

func (*AddPeerResp) GetInvitation 

func (x *AddPeerResp) GetInvitation() *Invitation

func (*AddPeerResp) ProtoMessage 

func (*AddPeerResp) ProtoMessage()

func (*AddPeerResp) ProtoReflect 

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

func (*AddPeerResp) Reset 

func (x *AddPeerResp) Reset()

func (*AddPeerResp) String 

func (x *AddPeerResp) String() string

type ConfigValue 

type ConfigValue struct {
	Scalar string   `protobuf:"bytes,1,opt,name=scalar,proto3" json:"scalar,omitempty"`
	List   []string `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigValue) Descriptor deprecated 

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

Deprecated: Use ConfigValue.ProtoReflect.Descriptor instead.

func (*ConfigValue) GetList 

func (x *ConfigValue) GetList() []string

func (*ConfigValue) GetScalar 

func (x *ConfigValue) GetScalar() string

func (*ConfigValue) ProtoMessage 

func (*ConfigValue) ProtoMessage()

func (*ConfigValue) ProtoReflect 

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

func (*ConfigValue) Reset 

func (x *ConfigValue) Reset()

func (*ConfigValue) String 

func (x *ConfigValue) String() string

type DaemonClient 

type DaemonClient interface {
	GetBuildInfo(ctx context.Context, in *proto.Empty, opts ...grpc.CallOption) (*proto.BuildInfo, error)
	StreamEvents(ctx context.Context, in *proto.Empty, opts ...grpc.CallOption) (Daemon_StreamEventsClient, error)
	UnWait(ctx context.Context, in *proto.Empty, opts ...grpc.CallOption) (*proto.Empty, error)
	Shutdown(ctx context.Context, in *ShutdownParams, opts ...grpc.CallOption) (*proto.Empty, error)
	Sync(ctx context.Context, in *proto.Empty, opts ...grpc.CallOption) (*proto.Empty, error)
	GetStatus(ctx context.Context, in *GetStatusParams, opts ...grpc.CallOption) (*GetStatusResp, error)
	SetConfig(ctx context.Context, in *SetConfigParams, opts ...grpc.CallOption) (*proto.Empty, error)
	GetConfig(ctx context.Context, in *GetConfigParams, opts ...grpc.CallOption) (*GetConfigResp, error)
	GetCompletion(ctx context.Context, in *GetCompletionParams, opts ...grpc.CallOption) (*GetCompletionResp, error)
	ReloadConfig(ctx context.Context, in *proto.Empty, opts ...grpc.CallOption) (*proto.Empty, error)
	AddPeer(ctx context.Context, in *AddPeerParams, opts ...grpc.CallOption) (*AddPeerResp, error)
}

DaemonClient is the client API for Daemon 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 NewDaemonClient 

func NewDaemonClient(cc grpc.ClientConnInterface) DaemonClient

type DaemonServer 

type DaemonServer interface {
	GetBuildInfo(context.Context, *proto.Empty) (*proto.BuildInfo, error)
	StreamEvents(*proto.Empty, Daemon_StreamEventsServer) error
	UnWait(context.Context, *proto.Empty) (*proto.Empty, error)
	Shutdown(context.Context, *ShutdownParams) (*proto.Empty, error)
	Sync(context.Context, *proto.Empty) (*proto.Empty, error)
	GetStatus(context.Context, *GetStatusParams) (*GetStatusResp, error)
	SetConfig(context.Context, *SetConfigParams) (*proto.Empty, error)
	GetConfig(context.Context, *GetConfigParams) (*GetConfigResp, error)
	GetCompletion(context.Context, *GetCompletionParams) (*GetCompletionResp, error)
	ReloadConfig(context.Context, *proto.Empty) (*proto.Empty, error)
	AddPeer(context.Context, *AddPeerParams) (*AddPeerResp, error)
	// contains filtered or unexported methods
}

DaemonServer is the server API for Daemon service. All implementations must embed UnimplementedDaemonServer for forward compatibility

type Daemon_StreamEventsClient 

type Daemon_StreamEventsClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type Daemon_StreamEventsServer 

type Daemon_StreamEventsServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type EndpointDiscoverySocketClient 

type EndpointDiscoverySocketClient interface {
	RestartPeer(ctx context.Context, in *RestartPeerParams, opts ...grpc.CallOption) (*proto.Empty, error)
}

EndpointDiscoverySocketClient is the client API for EndpointDiscoverySocket 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 NewEndpointDiscoverySocketClient 

func NewEndpointDiscoverySocketClient(cc grpc.ClientConnInterface) EndpointDiscoverySocketClient

type EndpointDiscoverySocketServer 

type EndpointDiscoverySocketServer interface {
	RestartPeer(context.Context, *RestartPeerParams) (*proto.Empty, error)
	// contains filtered or unexported methods
}

EndpointDiscoverySocketServer is the server API for EndpointDiscoverySocket service. All implementations must embed UnimplementedEndpointDiscoverySocketServer for forward compatibility

type Event 

type Event struct {
	Type EventType        `protobuf:"varint,1,opt,name=type,proto3,enum=cunicu.rpc.EventType" json:"type,omitempty"`
	Time *proto.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Public key of peer which triggerd the event
	Peer []byte `protobuf:"bytes,3,opt,name=peer,proto3" json:"peer,omitempty"`
	// Interface name which triggered the event
	Interface string `protobuf:"bytes,4,opt,name=interface,proto3" json:"interface,omitempty"`
	// Types that are assignable to Event:
	//
	//	*Event_BackendReady
	//	*Event_PeerStateChange
	//	*Event_PeerModified
	//	*Event_InterfaceModified
	Event isEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetBackendReady 

func (x *Event) GetBackendReady() *SignalingBackendReadyEvent

func (*Event) GetEvent 

func (m *Event) GetEvent() isEvent_Event

func (*Event) GetInterface 

func (x *Event) GetInterface() string

func (*Event) GetInterfaceModified 

func (x *Event) GetInterfaceModified() *InterfaceModifiedEvent

func (*Event) GetPeer 

func (x *Event) GetPeer() []byte

func (*Event) GetPeerModified 

func (x *Event) GetPeerModified() *PeerModifiedEvent

func (*Event) GetPeerStateChange 

func (x *Event) GetPeerStateChange() *PeerStateChangeEvent

func (*Event) GetTime 

func (x *Event) GetTime() *proto.Timestamp

func (*Event) GetType 

func (x *Event) GetType() EventType

func (*Event) Log 

func (e *Event) Log(l *log.Logger, msg string, fields ...zap.Field)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventType 

type EventType int32
const (
	// Signaling Events
	EventType_BACKEND_READY     EventType = 0
	EventType_SIGNALING_MESSAGE EventType = 1
	// Core Events
	EventType_PEER_ADDED         EventType = 10
	EventType_PEER_REMOVED       EventType = 11
	EventType_PEER_MODIFIED      EventType = 12
	EventType_PEER_STATE_CHANGED EventType = 13
	EventType_INTERFACE_ADDED    EventType = 20
	EventType_INTERFACE_REMOVED  EventType = 21
	EventType_INTERFACE_MODIFIED EventType = 22
)

func (EventType) Descriptor 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated 

func (EventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String 

func (x EventType) String() string

func (EventType) Type 

func (EventType) Type() protoreflect.EnumType

type Event_BackendReady 

type Event_BackendReady struct {
	BackendReady *SignalingBackendReadyEvent `protobuf:"bytes,100,opt,name=backend_ready,json=backendReady,proto3,oneof"`
}

type Event_InterfaceModified 

type Event_InterfaceModified struct {
	InterfaceModified *InterfaceModifiedEvent `protobuf:"bytes,123,opt,name=interface_modified,json=interfaceModified,proto3,oneof"`
}

type Event_PeerModified 

type Event_PeerModified struct {
	PeerModified *PeerModifiedEvent `protobuf:"bytes,122,opt,name=peer_modified,json=peerModified,proto3,oneof"`
}

type Event_PeerStateChange 

type Event_PeerStateChange struct {
	PeerStateChange *PeerStateChangeEvent `protobuf:"bytes,121,opt,name=peer_state_change,json=peerStateChange,proto3,oneof"`
}

type GetCompletionParams 

type GetCompletionParams struct {
	Cmd        []string `protobuf:"bytes,1,rep,name=cmd,proto3" json:"cmd,omitempty"`
	Args       []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	ToComplete string   `protobuf:"bytes,3,opt,name=to_complete,json=toComplete,proto3" json:"to_complete,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCompletionParams) Descriptor deprecated 

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

Deprecated: Use GetCompletionParams.ProtoReflect.Descriptor instead.

func (*GetCompletionParams) GetArgs 

func (x *GetCompletionParams) GetArgs() []string

func (*GetCompletionParams) GetCmd 

func (x *GetCompletionParams) GetCmd() []string

func (*GetCompletionParams) GetToComplete 

func (x *GetCompletionParams) GetToComplete() string

func (*GetCompletionParams) ProtoMessage 

func (*GetCompletionParams) ProtoMessage()

func (*GetCompletionParams) ProtoReflect 

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

func (*GetCompletionParams) Reset 

func (x *GetCompletionParams) Reset()

func (*GetCompletionParams) String 

func (x *GetCompletionParams) String() string

type GetCompletionResp 

type GetCompletionResp struct {
	Options []string `protobuf:"bytes,1,rep,name=options,proto3" json:"options,omitempty"`
	Flags   int32    `protobuf:"varint,2,opt,name=flags,proto3" json:"flags,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCompletionResp) Descriptor deprecated 

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

Deprecated: Use GetCompletionResp.ProtoReflect.Descriptor instead.

func (*GetCompletionResp) GetFlags 

func (x *GetCompletionResp) GetFlags() int32

func (*GetCompletionResp) GetOptions 

func (x *GetCompletionResp) GetOptions() []string

func (*GetCompletionResp) ProtoMessage 

func (*GetCompletionResp) ProtoMessage()

func (*GetCompletionResp) ProtoReflect 

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

func (*GetCompletionResp) Reset 

func (x *GetCompletionResp) Reset()

func (*GetCompletionResp) String 

func (x *GetCompletionResp) String() string

type GetConfigParams 

type GetConfigParams struct {
	KeyFilter string `protobuf:"bytes,1,opt,name=key_filter,json=keyFilter,proto3" json:"key_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigParams) Descriptor deprecated 

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

Deprecated: Use GetConfigParams.ProtoReflect.Descriptor instead.

func (*GetConfigParams) GetKeyFilter 

func (x *GetConfigParams) GetKeyFilter() string

func (*GetConfigParams) ProtoMessage 

func (*GetConfigParams) ProtoMessage()

func (*GetConfigParams) ProtoReflect 

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

func (*GetConfigParams) Reset 

func (x *GetConfigParams) Reset()

func (*GetConfigParams) String 

func (x *GetConfigParams) String() string

type GetConfigResp 

type GetConfigResp struct {
	Settings map[string]*ConfigValue `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetConfigResp) Descriptor deprecated 

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

Deprecated: Use GetConfigResp.ProtoReflect.Descriptor instead.

func (*GetConfigResp) GetSettings 

func (x *GetConfigResp) GetSettings() map[string]*ConfigValue

func (*GetConfigResp) ProtoMessage 

func (*GetConfigResp) ProtoMessage()

func (*GetConfigResp) ProtoReflect 

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

func (*GetConfigResp) Reset 

func (x *GetConfigResp) Reset()

func (*GetConfigResp) String 

func (x *GetConfigResp) String() string

type GetSignalingMessageParams 

type GetSignalingMessageParams struct {

	// Interface name
	Intf string `protobuf:"bytes,1,opt,name=intf,proto3" json:"intf,omitempty"`
	// Public key of peer
	Peer []byte `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSignalingMessageParams) Descriptor deprecated 

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

Deprecated: Use GetSignalingMessageParams.ProtoReflect.Descriptor instead.

func (*GetSignalingMessageParams) GetIntf 

func (x *GetSignalingMessageParams) GetIntf() string

func (*GetSignalingMessageParams) GetPeer 

func (x *GetSignalingMessageParams) GetPeer() []byte

func (*GetSignalingMessageParams) ProtoMessage 

func (*GetSignalingMessageParams) ProtoMessage()

func (*GetSignalingMessageParams) ProtoReflect 

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

func (*GetSignalingMessageParams) Reset 

func (x *GetSignalingMessageParams) Reset()

func (*GetSignalingMessageParams) String 

func (x *GetSignalingMessageParams) String() string

type GetSignalingMessageResp 

type GetSignalingMessageResp struct {
	Envelope *signaling.Envelope `protobuf:"bytes,1,opt,name=envelope,proto3" json:"envelope,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSignalingMessageResp) Descriptor deprecated 

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

Deprecated: Use GetSignalingMessageResp.ProtoReflect.Descriptor instead.

func (*GetSignalingMessageResp) GetEnvelope 

func (x *GetSignalingMessageResp) GetEnvelope() *signaling.Envelope

func (*GetSignalingMessageResp) ProtoMessage 

func (*GetSignalingMessageResp) ProtoMessage()

func (*GetSignalingMessageResp) ProtoReflect 

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

func (*GetSignalingMessageResp) Reset 

func (x *GetSignalingMessageResp) Reset()

func (*GetSignalingMessageResp) String 

func (x *GetSignalingMessageResp) String() string

type GetStatusParams 

type GetStatusParams struct {
	Interface string `protobuf:"bytes,1,opt,name=interface,proto3" json:"interface,omitempty"`
	Peer      []byte `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusParams) Descriptor deprecated 

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

Deprecated: Use GetStatusParams.ProtoReflect.Descriptor instead.

func (*GetStatusParams) GetInterface 

func (x *GetStatusParams) GetInterface() string

func (*GetStatusParams) GetPeer 

func (x *GetStatusParams) GetPeer() []byte

func (*GetStatusParams) ProtoMessage 

func (*GetStatusParams) ProtoMessage()

func (*GetStatusParams) ProtoReflect 

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

func (*GetStatusParams) Reset 

func (x *GetStatusParams) Reset()

func (*GetStatusParams) String 

func (x *GetStatusParams) String() string

type GetStatusResp 

type GetStatusResp struct {
	Interfaces []*core.Interface `protobuf:"bytes,1,rep,name=interfaces,proto3" json:"interfaces,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusResp) Descriptor deprecated 

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

Deprecated: Use GetStatusResp.ProtoReflect.Descriptor instead.

func (*GetStatusResp) Dump 

func (s *GetStatusResp) Dump(wr io.Writer, level log.Level) error

func (*GetStatusResp) GetInterfaces 

func (x *GetStatusResp) GetInterfaces() []*core.Interface

func (*GetStatusResp) ProtoMessage 

func (*GetStatusResp) ProtoMessage()

func (*GetStatusResp) ProtoReflect 

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

func (*GetStatusResp) Reset 

func (x *GetStatusResp) Reset()

func (*GetStatusResp) String 

func (x *GetStatusResp) String() string

type InterfaceModifiedEvent 

type InterfaceModifiedEvent struct {
	Modified uint32 `protobuf:"varint,1,opt,name=modified,proto3" json:"modified,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceModifiedEvent) Descriptor deprecated 

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

Deprecated: Use InterfaceModifiedEvent.ProtoReflect.Descriptor instead.

func (*InterfaceModifiedEvent) GetModified 

func (x *InterfaceModifiedEvent) GetModified() uint32

func (*InterfaceModifiedEvent) ProtoMessage 

func (*InterfaceModifiedEvent) ProtoMessage()

func (*InterfaceModifiedEvent) ProtoReflect 

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

func (*InterfaceModifiedEvent) Reset 

func (x *InterfaceModifiedEvent) Reset()

func (*InterfaceModifiedEvent) String 

func (x *InterfaceModifiedEvent) String() string

type Invitation 

type Invitation struct {
	Community []byte `protobuf:"bytes,1,opt,name=community,proto3" json:"community,omitempty"`
	Endpoint  string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*Invitation) Descriptor deprecated 

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

Deprecated: Use Invitation.ProtoReflect.Descriptor instead.

func (*Invitation) GetCommunity 

func (x *Invitation) GetCommunity() []byte

func (*Invitation) GetEndpoint 

func (x *Invitation) GetEndpoint() string

func (*Invitation) ProtoMessage 

func (*Invitation) ProtoMessage()

func (*Invitation) ProtoReflect 

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

func (*Invitation) Reset 

func (x *Invitation) Reset()

func (*Invitation) String 

func (x *Invitation) String() string

type PeerModifiedEvent 

type PeerModifiedEvent struct {
	Modified uint32 `protobuf:"varint,1,opt,name=modified,proto3" json:"modified,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerModifiedEvent) Descriptor deprecated 

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

Deprecated: Use PeerModifiedEvent.ProtoReflect.Descriptor instead.

func (*PeerModifiedEvent) GetModified 

func (x *PeerModifiedEvent) GetModified() uint32

func (*PeerModifiedEvent) ProtoMessage 

func (*PeerModifiedEvent) ProtoMessage()

func (*PeerModifiedEvent) ProtoReflect 

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

func (*PeerModifiedEvent) Reset 

func (x *PeerModifiedEvent) Reset()

func (*PeerModifiedEvent) String 

func (x *PeerModifiedEvent) String() string

type PeerStateChangeEvent 

type PeerStateChangeEvent struct {
	NewState  core.PeerState `protobuf:"varint,1,opt,name=new_state,json=newState,proto3,enum=cunicu.core.PeerState" json:"new_state,omitempty"`
	PrevState core.PeerState `protobuf:"varint,2,opt,name=prev_state,json=prevState,proto3,enum=cunicu.core.PeerState" json:"prev_state,omitempty"`
	// contains filtered or unexported fields
}

func (*PeerStateChangeEvent) Descriptor deprecated 

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

Deprecated: Use PeerStateChangeEvent.ProtoReflect.Descriptor instead.

func (*PeerStateChangeEvent) GetNewState 

func (x *PeerStateChangeEvent) GetNewState() core.PeerState

func (*PeerStateChangeEvent) GetPrevState 

func (x *PeerStateChangeEvent) GetPrevState() core.PeerState

func (*PeerStateChangeEvent) ProtoMessage 

func (*PeerStateChangeEvent) ProtoMessage()

func (*PeerStateChangeEvent) ProtoReflect 

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

func (*PeerStateChangeEvent) Reset 

func (x *PeerStateChangeEvent) Reset()

func (*PeerStateChangeEvent) String 

func (x *PeerStateChangeEvent) String() string

type PutSignalingMessageParams 

type PutSignalingMessageParams struct {
	Envelope *signaling.Envelope `protobuf:"bytes,1,opt,name=envelope,proto3" json:"envelope,omitempty"`
	// contains filtered or unexported fields
}

func (*PutSignalingMessageParams) Descriptor deprecated 

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

Deprecated: Use PutSignalingMessageParams.ProtoReflect.Descriptor instead.

func (*PutSignalingMessageParams) GetEnvelope 

func (x *PutSignalingMessageParams) GetEnvelope() *signaling.Envelope

func (*PutSignalingMessageParams) ProtoMessage 

func (*PutSignalingMessageParams) ProtoMessage()

func (*PutSignalingMessageParams) ProtoReflect 

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

func (*PutSignalingMessageParams) Reset 

func (x *PutSignalingMessageParams) Reset()

func (*PutSignalingMessageParams) String 

func (x *PutSignalingMessageParams) String() string

type RestartPeerParams 

type RestartPeerParams struct {
	Intf string `protobuf:"bytes,1,opt,name=intf,proto3" json:"intf,omitempty"`
	Peer []byte `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	// contains filtered or unexported fields
}

func (*RestartPeerParams) Descriptor deprecated 

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

Deprecated: Use RestartPeerParams.ProtoReflect.Descriptor instead.

func (*RestartPeerParams) GetIntf 

func (x *RestartPeerParams) GetIntf() string

func (*RestartPeerParams) GetPeer 

func (x *RestartPeerParams) GetPeer() []byte

func (*RestartPeerParams) ProtoMessage 

func (*RestartPeerParams) ProtoMessage()

func (*RestartPeerParams) ProtoReflect 

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

func (*RestartPeerParams) Reset 

func (x *RestartPeerParams) Reset()

func (*RestartPeerParams) String 

func (x *RestartPeerParams) String() string

type SetConfigParams 

type SetConfigParams struct {
	Settings map[string]*ConfigValue `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetConfigParams) Descriptor deprecated 

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

Deprecated: Use SetConfigParams.ProtoReflect.Descriptor instead.

func (*SetConfigParams) GetSettings 

func (x *SetConfigParams) GetSettings() map[string]*ConfigValue

func (*SetConfigParams) ProtoMessage 

func (*SetConfigParams) ProtoMessage()

func (*SetConfigParams) ProtoReflect 

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

func (*SetConfigParams) Reset 

func (x *SetConfigParams) Reset()

func (*SetConfigParams) String 

func (x *SetConfigParams) String() string

type ShutdownParams 

type ShutdownParams struct {
	Restart bool `protobuf:"varint,1,opt,name=restart,proto3" json:"restart,omitempty"`
	// contains filtered or unexported fields
}

func (*ShutdownParams) Descriptor deprecated 

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

Deprecated: Use ShutdownParams.ProtoReflect.Descriptor instead.

func (*ShutdownParams) GetRestart 

func (x *ShutdownParams) GetRestart() bool

func (*ShutdownParams) ProtoMessage 

func (*ShutdownParams) ProtoMessage()

func (*ShutdownParams) ProtoReflect 

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

func (*ShutdownParams) Reset 

func (x *ShutdownParams) Reset()

func (*ShutdownParams) String 

func (x *ShutdownParams) String() string

type SignalingBackendReadyEvent 

type SignalingBackendReadyEvent struct {
	Type signaling.BackendType `protobuf:"varint,1,opt,name=type,proto3,enum=cunicu.signaling.BackendType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalingBackendReadyEvent) Descriptor deprecated 

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

Deprecated: Use SignalingBackendReadyEvent.ProtoReflect.Descriptor instead.

func (*SignalingBackendReadyEvent) GetType 

func (x *SignalingBackendReadyEvent) GetType() signaling.BackendType

func (*SignalingBackendReadyEvent) ProtoMessage 

func (*SignalingBackendReadyEvent) ProtoMessage()

func (*SignalingBackendReadyEvent) ProtoReflect 

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

func (*SignalingBackendReadyEvent) Reset 

func (x *SignalingBackendReadyEvent) Reset()

func (*SignalingBackendReadyEvent) String 

func (x *SignalingBackendReadyEvent) String() string

type SignalingClient 

type SignalingClient interface {
	GetSignalingMessage(ctx context.Context, in *GetSignalingMessageParams, opts ...grpc.CallOption) (*GetSignalingMessageResp, error)
	PutSignalingMessage(ctx context.Context, in *PutSignalingMessageParams, opts ...grpc.CallOption) (*proto.Empty, error)
}

SignalingClient is the client API for Signaling 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 NewSignalingClient 

func NewSignalingClient(cc grpc.ClientConnInterface) SignalingClient

type SignalingServer 

type SignalingServer interface {
	GetSignalingMessage(context.Context, *GetSignalingMessageParams) (*GetSignalingMessageResp, error)
	PutSignalingMessage(context.Context, *PutSignalingMessageParams) (*proto.Empty, error)
	// contains filtered or unexported methods
}

SignalingServer is the server API for Signaling service. All implementations must embed UnimplementedSignalingServer for forward compatibility

type UnimplementedDaemonServer 

type UnimplementedDaemonServer struct {
}

UnimplementedDaemonServer must be embedded to have forward compatible implementations.

func (UnimplementedDaemonServer) AddPeer 

func (UnimplementedDaemonServer) AddPeer(context.Context, *AddPeerParams) (*AddPeerResp, error)

func (UnimplementedDaemonServer) GetBuildInfo 

func (UnimplementedDaemonServer) GetBuildInfo(context.Context, *proto.Empty) (*proto.BuildInfo, error)

func (UnimplementedDaemonServer) GetCompletion 

func (UnimplementedDaemonServer) GetCompletion(context.Context, *GetCompletionParams) (*GetCompletionResp, error)

func (UnimplementedDaemonServer) GetConfig 

func (UnimplementedDaemonServer) GetConfig(context.Context, *GetConfigParams) (*GetConfigResp, error)

func (UnimplementedDaemonServer) GetStatus 

func (UnimplementedDaemonServer) GetStatus(context.Context, *GetStatusParams) (*GetStatusResp, error)

func (UnimplementedDaemonServer) ReloadConfig 

func (UnimplementedDaemonServer) ReloadConfig(context.Context, *proto.Empty) (*proto.Empty, error)

func (UnimplementedDaemonServer) SetConfig 

func (UnimplementedDaemonServer) SetConfig(context.Context, *SetConfigParams) (*proto.Empty, error)

func (UnimplementedDaemonServer) Shutdown 

func (UnimplementedDaemonServer) Shutdown(context.Context, *ShutdownParams) (*proto.Empty, error)

func (UnimplementedDaemonServer) StreamEvents 

func (UnimplementedDaemonServer) StreamEvents(*proto.Empty, Daemon_StreamEventsServer) error

func (UnimplementedDaemonServer) Sync 

func (UnimplementedDaemonServer) Sync(context.Context, *proto.Empty) (*proto.Empty, error)

func (UnimplementedDaemonServer) UnWait 

func (UnimplementedDaemonServer) UnWait(context.Context, *proto.Empty) (*proto.Empty, error)

type UnimplementedEndpointDiscoverySocketServer 

type UnimplementedEndpointDiscoverySocketServer struct {
}

UnimplementedEndpointDiscoverySocketServer must be embedded to have forward compatible implementations.

func (UnimplementedEndpointDiscoverySocketServer) RestartPeer 

func (UnimplementedEndpointDiscoverySocketServer) RestartPeer(context.Context, *RestartPeerParams) (*proto.Empty, error)

type UnimplementedSignalingServer 

type UnimplementedSignalingServer struct {
}

UnimplementedSignalingServer must be embedded to have forward compatible implementations.

func (UnimplementedSignalingServer) GetSignalingMessage 

func (UnimplementedSignalingServer) GetSignalingMessage(context.Context, *GetSignalingMessageParams) (*GetSignalingMessageResp, error)

func (UnimplementedSignalingServer) PutSignalingMessage 

func (UnimplementedSignalingServer) PutSignalingMessage(context.Context, *PutSignalingMessageParams) (*proto.Empty, error)

type UnsafeDaemonServer 

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

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

type UnsafeEndpointDiscoverySocketServer 

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

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

type UnsafeSignalingServer 

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

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

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.