rpc

package
v0.4.6 Latest Latest
Warning

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

Go to latest
Published: Dec 4, 2023 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.

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

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 (*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 (*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 (*SignalingBackendReadyEvent) ProtoMessage

func (*SignalingBackendReadyEvent) ProtoMessage()

func (*SignalingBackendReadyEvent) ProtoReflect

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) GetBuildInfo

func (UnimplementedDaemonServer) GetCompletion

func (UnimplementedDaemonServer) GetConfig

func (UnimplementedDaemonServer) GetStatus

func (UnimplementedDaemonServer) ReloadConfig

func (UnimplementedDaemonServer) SetConfig

func (UnimplementedDaemonServer) Shutdown

func (UnimplementedDaemonServer) StreamEvents

func (UnimplementedDaemonServer) Sync

func (UnimplementedDaemonServer) UnWait

type UnimplementedEndpointDiscoverySocketServer

type UnimplementedEndpointDiscoverySocketServer struct {
}

UnimplementedEndpointDiscoverySocketServer must be embedded to have forward compatible implementations.

func (UnimplementedEndpointDiscoverySocketServer) RestartPeer

type UnimplementedSignalingServer

type UnimplementedSignalingServer struct {
}

UnimplementedSignalingServer must be embedded to have forward compatible implementations.

func (UnimplementedSignalingServer) GetSignalingMessage

func (UnimplementedSignalingServer) PutSignalingMessage

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.

Jump to

Keyboard shortcuts

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