v1

package
v0.0.6 Latest Latest
Warning

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

 Go to latest Published: May 26, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Admin_PutRaftACL_FullMethodName    = "/v1.Admin/PutRaftACL"
	Admin_DeleteRaftACL_FullMethodName = "/v1.Admin/DeleteRaftACL"
	Admin_GetRaftACL_FullMethodName    = "/v1.Admin/GetRaftACL"
	Admin_ListRaftACLs_FullMethodName  = "/v1.Admin/ListRaftACLs"
)
View Source 
const (
	Mesh_GetNode_FullMethodName   = "/v1.Mesh/GetNode"
	Mesh_ListNodes_FullMethodName = "/v1.Mesh/ListNodes"
)
View Source 
const (
	Node_Join_FullMethodName                 = "/v1.Node/Join"
	Node_Leave_FullMethodName                = "/v1.Node/Leave"
	Node_GetStatus_FullMethodName            = "/v1.Node/GetStatus"
	Node_NegotiateDataChannel_FullMethodName = "/v1.Node/NegotiateDataChannel"
)
View Source 
const (
	PeerDiscovery_ListPeers_FullMethodName = "/v1.PeerDiscovery/ListPeers"
)
View Source 
const (
	WebRTC_StartDataChannel_FullMethodName = "/v1.WebRTC/StartDataChannel"
)

Variables

View Source 
var (
	ACLAction_name = map[int32]string{
		0: "DENY",
		1: "ALLOW",
	}
	ACLAction_value = map[string]int32{
		"DENY":  0,
		"ALLOW": 1,
	}
)

Enum value maps for ACLAction.

View Source 
var (
	ClusterStatus_name = map[int32]string{
		0: "CLUSTER_STATUS_UNKNOWN",
		1: "CLUSTER_LEADER",
		2: "CLUSTER_VOTER",
		3: "CLUSTER_NON_VOTER",
	}
	ClusterStatus_value = map[string]int32{
		"CLUSTER_STATUS_UNKNOWN": 0,
		"CLUSTER_LEADER":         1,
		"CLUSTER_VOTER":          2,
		"CLUSTER_NON_VOTER":      3,
	}
)

Enum value maps for ClusterStatus.

View Source 
var (
	Feature_name = map[int32]string{
		0: "FEATURE_NONE",
		1: "NODES",
		2: "LEADER_PROXY",
		3: "MESH_API",
		4: "PEER_DISCOVERY",
		5: "METRICS",
		6: "ICE_NEGOTIATION",
		7: "TURN_SERVER",
		8: "MESH_DNS",
	}
	Feature_value = map[string]int32{
		"FEATURE_NONE":    0,
		"NODES":           1,
		"LEADER_PROXY":    2,
		"MESH_API":        3,
		"PEER_DISCOVERY":  4,
		"METRICS":         5,
		"ICE_NEGOTIATION": 6,
		"TURN_SERVER":     7,
		"MESH_DNS":        8,
	}
)

Enum value maps for Feature.

View Source 
var (
	DataChannel_name = map[int32]string{
		0: "CHANNELS",
		1: "CONNECTIONS",
	}
	DataChannel_value = map[string]int32{
		"CHANNELS":    0,
		"CONNECTIONS": 1,
	}
)

Enum value maps for DataChannel.

View Source 
var (
	RaftCommandType_name = map[int32]string{
		0: "UNKNOWN",
		1: "QUERY",
		2: "EXECUTE",
	}
	RaftCommandType_value = map[string]int32{
		"UNKNOWN": 0,
		"QUERY":   1,
		"EXECUTE": 2,
	}
)

Enum value maps for RaftCommandType.

View Source 
var (
	SQLParameterType_name = map[int32]string{
		0: "SQL_PARAM_UNKNOWN",
		1: "SQL_PARAM_INT64",
		2: "SQL_PARAM_DOUBLE",
		3: "SQL_PARAM_BOOL",
		4: "SQL_PARAM_BYTES",
		5: "SQL_PARAM_STRING",
		6: "SQL_PARAM_TIME",
		7: "SQL_PARAM_NULL",
	}
	SQLParameterType_value = map[string]int32{
		"SQL_PARAM_UNKNOWN": 0,
		"SQL_PARAM_INT64":   1,
		"SQL_PARAM_DOUBLE":  2,
		"SQL_PARAM_BOOL":    3,
		"SQL_PARAM_BYTES":   4,
		"SQL_PARAM_STRING":  5,
		"SQL_PARAM_TIME":    6,
		"SQL_PARAM_NULL":    7,
	}
)

Enum value maps for SQLParameterType.

View Source 
var Admin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Admin",
	HandlerType: (*AdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PutRaftACL",
			Handler:    _Admin_PutRaftACL_Handler,
		},
		{
			MethodName: "DeleteRaftACL",
			Handler:    _Admin_DeleteRaftACL_Handler,
		},
		{
			MethodName: "GetRaftACL",
			Handler:    _Admin_GetRaftACL_Handler,
		},
		{
			MethodName: "ListRaftACLs",
			Handler:    _Admin_ListRaftACLs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1/admin.proto",
}

Admin_ServiceDesc is the grpc.ServiceDesc for Admin 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_v1_admin_messages_proto protoreflect.FileDescriptor
View Source 
var File_v1_admin_proto protoreflect.FileDescriptor
View Source 
var File_v1_mesh_messages_proto protoreflect.FileDescriptor
View Source 
var File_v1_mesh_proto protoreflect.FileDescriptor
View Source 
var File_v1_node_messages_proto protoreflect.FileDescriptor
View Source 
var File_v1_node_metrics_proto protoreflect.FileDescriptor
View Source 
var File_v1_node_proto protoreflect.FileDescriptor
View Source 
var File_v1_node_raft_proto protoreflect.FileDescriptor
View Source 
var File_v1_peer_discovery_proto protoreflect.FileDescriptor
View Source 
var File_v1_webrtc_messages_proto protoreflect.FileDescriptor
View Source 
var File_v1_webrtc_proto protoreflect.FileDescriptor
View Source 
var Mesh_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Mesh",
	HandlerType: (*MeshServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetNode",
			Handler:    _Mesh_GetNode_Handler,
		},
		{
			MethodName: "ListNodes",
			Handler:    _Mesh_ListNodes_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1/mesh.proto",
}

Mesh_ServiceDesc is the grpc.ServiceDesc for Mesh 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 Node_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Node",
	HandlerType: (*NodeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Join",
			Handler:    _Node_Join_Handler,
		},
		{
			MethodName: "Leave",
			Handler:    _Node_Leave_Handler,
		},
		{
			MethodName: "GetStatus",
			Handler:    _Node_GetStatus_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "NegotiateDataChannel",
			Handler:       _Node_NegotiateDataChannel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "v1/node.proto",
}

Node_ServiceDesc is the grpc.ServiceDesc for Node 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 PeerDiscovery_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.PeerDiscovery",
	HandlerType: (*PeerDiscoveryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListPeers",
			Handler:    _PeerDiscovery_ListPeers_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1/peer_discovery.proto",
}

PeerDiscovery_ServiceDesc is the grpc.ServiceDesc for PeerDiscovery 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 WebRTC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.WebRTC",
	HandlerType: (*WebRTCServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StartDataChannel",
			Handler:       _WebRTC_StartDataChannel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "v1/webrtc.proto",
}

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

Functions

func RegisterAdminServer added in v0.0.6 

func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer)

func RegisterMeshServer added in v0.0.5 

func RegisterMeshServer(s grpc.ServiceRegistrar, srv MeshServer)

func RegisterNodeServer 

func RegisterNodeServer(s grpc.ServiceRegistrar, srv NodeServer)

func RegisterPeerDiscoveryServer 

func RegisterPeerDiscoveryServer(s grpc.ServiceRegistrar, srv PeerDiscoveryServer)

func RegisterWebRTCServer added in v0.0.5 

func RegisterWebRTCServer(s grpc.ServiceRegistrar, srv WebRTCServer)

Types

type ACLAction added in v0.0.6 

type ACLAction int32

ACLAction is the action of an ACL. 

const (
	// DENY denies the action.
	ACLAction_DENY ACLAction = 0
	// ALLOW allows the action.
	ACLAction_ALLOW ACLAction = 1
)

func (ACLAction) Descriptor added in v0.0.6 

func (ACLAction) Descriptor() protoreflect.EnumDescriptor

func (ACLAction) Enum added in v0.0.6 

func (x ACLAction) Enum() *ACLAction

func (ACLAction) EnumDescriptor deprecated added in v0.0.6 

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

Deprecated: Use ACLAction.Descriptor instead.

func (ACLAction) Number added in v0.0.6 

func (x ACLAction) Number() protoreflect.EnumNumber

func (ACLAction) String added in v0.0.6 

func (x ACLAction) String() string

func (ACLAction) Type added in v0.0.6 

func (ACLAction) Type() protoreflect.EnumType

type AdminClient added in v0.0.6 

type AdminClient interface {
	// PutRaftACL creates or updates an ACL.
	PutRaftACL(ctx context.Context, in *RaftACL, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeleteRaftACL deletes an ACL by name.
	DeleteRaftACL(ctx context.Context, in *DeleteRaftACLRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// GetRaftACL returns an ACL by name.
	GetRaftACL(ctx context.Context, in *GetRaftACLRequest, opts ...grpc.CallOption) (*RaftACL, error)
	// ListRaftACLs returns the ACLs for the Raft cluster.
	ListRaftACLs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RaftACLList, error)
}

AdminClient is the client API for Admin 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 NewAdminClient added in v0.0.6 

func NewAdminClient(cc grpc.ClientConnInterface) AdminClient

type AdminServer added in v0.0.6 

type AdminServer interface {
	// PutRaftACL creates or updates an ACL.
	PutRaftACL(context.Context, *RaftACL) (*emptypb.Empty, error)
	// DeleteRaftACL deletes an ACL by name.
	DeleteRaftACL(context.Context, *DeleteRaftACLRequest) (*emptypb.Empty, error)
	// GetRaftACL returns an ACL by name.
	GetRaftACL(context.Context, *GetRaftACLRequest) (*RaftACL, error)
	// ListRaftACLs returns the ACLs for the Raft cluster.
	ListRaftACLs(context.Context, *emptypb.Empty) (*RaftACLList, error)
	// contains filtered or unexported methods
}

AdminServer is the server API for Admin service. All implementations must embed UnimplementedAdminServer for forward compatibility

type CPUTimes 

type CPUTimes struct {
	LoadAverage *LoadAverage `protobuf:"bytes,1,opt,name=load_average,json=loadAverage,proto3" json:"load_average,omitempty"`
	// user is the user CPU time.
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// system is the system CPU time.
	System string `protobuf:"bytes,3,opt,name=system,proto3" json:"system,omitempty"`
	// idle is the idle CPU time.
	Idle string `protobuf:"bytes,4,opt,name=idle,proto3" json:"idle,omitempty"`
	// io_wait is the IO wait CPU time.
	IoWait string `protobuf:"bytes,5,opt,name=io_wait,json=ioWait,proto3" json:"io_wait,omitempty"`
	// irq is the IRQ CPU time.
	Irq string `protobuf:"bytes,6,opt,name=irq,proto3" json:"irq,omitempty"`
	// nice is the nice CPU time.
	Nice string `protobuf:"bytes,7,opt,name=nice,proto3" json:"nice,omitempty"`
	// soft_irq is the soft IRQ CPU time.
	SoftIrq string `protobuf:"bytes,8,opt,name=soft_irq,json=softIrq,proto3" json:"soft_irq,omitempty"`
	// steal is the steal CPU time.
	Steal string `protobuf:"bytes,9,opt,name=steal,proto3" json:"steal,omitempty"`
	// contains filtered or unexported fields
}

CPUTimes is the CPU times.

func (*CPUTimes) Descriptor deprecated 

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

Deprecated: Use CPUTimes.ProtoReflect.Descriptor instead.

func (*CPUTimes) GetIdle 

func (x *CPUTimes) GetIdle() string

func (*CPUTimes) GetIoWait 

func (x *CPUTimes) GetIoWait() string

func (*CPUTimes) GetIrq 

func (x *CPUTimes) GetIrq() string

func (*CPUTimes) GetLoadAverage 

func (x *CPUTimes) GetLoadAverage() *LoadAverage

func (*CPUTimes) GetNice 

func (x *CPUTimes) GetNice() string

func (*CPUTimes) GetSoftIrq 

func (x *CPUTimes) GetSoftIrq() string

func (*CPUTimes) GetSteal 

func (x *CPUTimes) GetSteal() string

func (*CPUTimes) GetSystem 

func (x *CPUTimes) GetSystem() string

func (*CPUTimes) GetUser 

func (x *CPUTimes) GetUser() string

func (*CPUTimes) ProtoMessage 

func (*CPUTimes) ProtoMessage()

func (*CPUTimes) ProtoReflect 

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

func (*CPUTimes) Reset 

func (x *CPUTimes) Reset()

func (*CPUTimes) String 

func (x *CPUTimes) String() string

type ClusterStatus added in v0.0.2 

type ClusterStatus int32

ClusterStatus is the status of the node in the cluster. 

const (
	// CLUSTER_STATUS_UNKNOWN is the default status.
	ClusterStatus_CLUSTER_STATUS_UNKNOWN ClusterStatus = 0
	// CLUSTER_LEADER is the status for the leader node.
	ClusterStatus_CLUSTER_LEADER ClusterStatus = 1
	// CLUSTER_VOTER is the status for a voter node.
	ClusterStatus_CLUSTER_VOTER ClusterStatus = 2
	// CLUSTER_NON_VOTER is the status for a non-voter node.
	ClusterStatus_CLUSTER_NON_VOTER ClusterStatus = 3
)

func (ClusterStatus) Descriptor added in v0.0.2 

func (ClusterStatus) Descriptor() protoreflect.EnumDescriptor

func (ClusterStatus) Enum added in v0.0.2 

func (x ClusterStatus) Enum() *ClusterStatus

func (ClusterStatus) EnumDescriptor deprecated added in v0.0.2 

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

Deprecated: Use ClusterStatus.Descriptor instead.

func (ClusterStatus) Number added in v0.0.2 

func (x ClusterStatus) Number() protoreflect.EnumNumber

func (ClusterStatus) String added in v0.0.2 

func (x ClusterStatus) String() string

func (ClusterStatus) Type added in v0.0.2 

func (ClusterStatus) Type() protoreflect.EnumType

type DataChannel 

type DataChannel int32

DataChannel are the data channels used when communicating over ICE with a node. 

const (
	// CHANNELS is the data channel used for negotiating new channels.
	// This is the first channel that is opened. The ID of the channel
	// should be 0.
	DataChannel_CHANNELS DataChannel = 0
	// CONNECTIONS is the data channel used for negotiating new connections.
	// This is a channel that is opened for each incoming connection from a
	// client. The ID should start at 0 and be incremented for each new connection.
	DataChannel_CONNECTIONS DataChannel = 1
)

func (DataChannel) Descriptor 

func (DataChannel) Descriptor() protoreflect.EnumDescriptor

func (DataChannel) Enum 

func (x DataChannel) Enum() *DataChannel

func (DataChannel) EnumDescriptor deprecated 

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

Deprecated: Use DataChannel.Descriptor instead.

func (DataChannel) Number 

func (x DataChannel) Number() protoreflect.EnumNumber

func (DataChannel) String 

func (x DataChannel) String() string

func (DataChannel) Type 

func (DataChannel) Type() protoreflect.EnumType

type DataChannelNegotiation 

type DataChannelNegotiation struct {

	// proto is the protocol of the traffic.
	Proto string `protobuf:"bytes,1,opt,name=proto,proto3" json:"proto,omitempty"`
	// src is the address of the client that initiated the request.
	Src string `protobuf:"bytes,2,opt,name=src,proto3" json:"src,omitempty"`
	// dst is the destination address of the traffic.
	Dst string `protobuf:"bytes,3,opt,name=dst,proto3" json:"dst,omitempty"`
	// port is the destination port of the traffic.
	Port uint32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// offer is the offer for the node to use as its local description.
	Offer string `protobuf:"bytes,5,opt,name=offer,proto3" json:"offer,omitempty"`
	// answer is the answer for the node to use as its remote description.
	Answer string `protobuf:"bytes,6,opt,name=answer,proto3" json:"answer,omitempty"`
	// candidate is an ICE candidate.
	Candidate string `protobuf:"bytes,7,opt,name=candidate,proto3" json:"candidate,omitempty"`
	// stun_servers is the list of STUN servers to use.
	StunServers []string `protobuf:"bytes,8,rep,name=stun_servers,json=stunServers,proto3" json:"stun_servers,omitempty"`
	// contains filtered or unexported fields
}

DataChannelNegotiation is the message for communicating data channels to nodes.

func (*DataChannelNegotiation) Descriptor deprecated 

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

Deprecated: Use DataChannelNegotiation.ProtoReflect.Descriptor instead.

func (*DataChannelNegotiation) GetAnswer 

func (x *DataChannelNegotiation) GetAnswer() string

func (*DataChannelNegotiation) GetCandidate 

func (x *DataChannelNegotiation) GetCandidate() string

func (*DataChannelNegotiation) GetDst 

func (x *DataChannelNegotiation) GetDst() string

func (*DataChannelNegotiation) GetOffer 

func (x *DataChannelNegotiation) GetOffer() string

func (*DataChannelNegotiation) GetPort 

func (x *DataChannelNegotiation) GetPort() uint32

func (*DataChannelNegotiation) GetProto 

func (x *DataChannelNegotiation) GetProto() string

func (*DataChannelNegotiation) GetSrc added in v0.0.6 

func (x *DataChannelNegotiation) GetSrc() string

func (*DataChannelNegotiation) GetStunServers 

func (x *DataChannelNegotiation) GetStunServers() []string

func (*DataChannelNegotiation) ProtoMessage 

func (*DataChannelNegotiation) ProtoMessage()

func (*DataChannelNegotiation) ProtoReflect 

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

func (*DataChannelNegotiation) Reset 

func (x *DataChannelNegotiation) Reset()

func (*DataChannelNegotiation) String 

func (x *DataChannelNegotiation) String() string

type DataChannelOffer 

type DataChannelOffer struct {

	// offer is the offer.
	Offer string `protobuf:"bytes,1,opt,name=offer,proto3" json:"offer,omitempty"`
	// stun_servers is the list of STUN servers to use.
	StunServers []string `protobuf:"bytes,2,rep,name=stun_servers,json=stunServers,proto3" json:"stun_servers,omitempty"`
	// candidate is an ICE candidate.
	Candidate string `protobuf:"bytes,3,opt,name=candidate,proto3" json:"candidate,omitempty"`
	// contains filtered or unexported fields
}

DataChannelOffer is an offer for a data channel. Candidates are sent after the offer is sent.

func (*DataChannelOffer) Descriptor deprecated 

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

Deprecated: Use DataChannelOffer.ProtoReflect.Descriptor instead.

func (*DataChannelOffer) GetCandidate 

func (x *DataChannelOffer) GetCandidate() string

func (*DataChannelOffer) GetOffer 

func (x *DataChannelOffer) GetOffer() string

func (*DataChannelOffer) GetStunServers 

func (x *DataChannelOffer) GetStunServers() []string

func (*DataChannelOffer) ProtoMessage 

func (*DataChannelOffer) ProtoMessage()

func (*DataChannelOffer) ProtoReflect 

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

func (*DataChannelOffer) Reset 

func (x *DataChannelOffer) Reset()

func (*DataChannelOffer) String 

func (x *DataChannelOffer) String() string

type DeleteRaftACLRequest added in v0.0.6 

type DeleteRaftACLRequest struct {

	// name is the name of the ACL.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DeleteRaftACLRequest is a request to delete a RaftACL.

func (*DeleteRaftACLRequest) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use DeleteRaftACLRequest.ProtoReflect.Descriptor instead.

func (*DeleteRaftACLRequest) GetName added in v0.0.6 

func (x *DeleteRaftACLRequest) GetName() string

func (*DeleteRaftACLRequest) ProtoMessage added in v0.0.6 

func (*DeleteRaftACLRequest) ProtoMessage()

func (*DeleteRaftACLRequest) ProtoReflect added in v0.0.6 

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

func (*DeleteRaftACLRequest) Reset added in v0.0.6 

func (x *DeleteRaftACLRequest) Reset()

func (*DeleteRaftACLRequest) String added in v0.0.6 

func (x *DeleteRaftACLRequest) String() string

type DiskInfo 

type DiskInfo struct {

	// filesystem_path is the path the disk is mounted to.
	FilesystemPath string `protobuf:"bytes,1,opt,name=filesystem_path,json=filesystemPath,proto3" json:"filesystem_path,omitempty"`
	// device is the device of the disk.
	Device string `protobuf:"bytes,2,opt,name=device,proto3" json:"device,omitempty"`
	// total is the total disk space.
	Total uint64 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	// free is the free disk space.
	Free uint64 `protobuf:"varint,4,opt,name=free,proto3" json:"free,omitempty"`
	// used is the used disk space.
	Used uint64 `protobuf:"varint,5,opt,name=used,proto3" json:"used,omitempty"`
	// used_percent is the used disk space percentage.
	UsedPercent float32 `protobuf:"fixed32,6,opt,name=used_percent,json=usedPercent,proto3" json:"used_percent,omitempty"`
	// inodes_total is the total inodes.
	InodesTotal uint64 `protobuf:"varint,7,opt,name=inodes_total,json=inodesTotal,proto3" json:"inodes_total,omitempty"`
	// inodes_free is the free inodes.
	InodesFree uint64 `protobuf:"varint,8,opt,name=inodes_free,json=inodesFree,proto3" json:"inodes_free,omitempty"`
	// inodes_used is the used inodes.
	InodesUsed uint64 `protobuf:"varint,9,opt,name=inodes_used,json=inodesUsed,proto3" json:"inodes_used,omitempty"`
	// inodes_used_percent is the used inodes percentage.
	InodesUsedPercent float32 `protobuf:"fixed32,10,opt,name=inodes_used_percent,json=inodesUsedPercent,proto3" json:"inodes_used_percent,omitempty"`
	// contains filtered or unexported fields
}

DiskInfo is the disk information.

func (*DiskInfo) Descriptor deprecated 

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

Deprecated: Use DiskInfo.ProtoReflect.Descriptor instead.

func (*DiskInfo) GetDevice 

func (x *DiskInfo) GetDevice() string

func (*DiskInfo) GetFilesystemPath 

func (x *DiskInfo) GetFilesystemPath() string

func (*DiskInfo) GetFree 

func (x *DiskInfo) GetFree() uint64

func (*DiskInfo) GetInodesFree 

func (x *DiskInfo) GetInodesFree() uint64

func (*DiskInfo) GetInodesTotal 

func (x *DiskInfo) GetInodesTotal() uint64

func (*DiskInfo) GetInodesUsed 

func (x *DiskInfo) GetInodesUsed() uint64

func (*DiskInfo) GetInodesUsedPercent 

func (x *DiskInfo) GetInodesUsedPercent() float32

func (*DiskInfo) GetTotal 

func (x *DiskInfo) GetTotal() uint64

func (*DiskInfo) GetUsed 

func (x *DiskInfo) GetUsed() uint64

func (*DiskInfo) GetUsedPercent 

func (x *DiskInfo) GetUsedPercent() float32

func (*DiskInfo) ProtoMessage 

func (*DiskInfo) ProtoMessage()

func (*DiskInfo) ProtoReflect 

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

func (*DiskInfo) Reset 

func (x *DiskInfo) Reset()

func (*DiskInfo) String 

func (x *DiskInfo) String() string

type Feature 

type Feature int32

Feature is a list of features supported by a node. 

const (
	// FEATURE_NONE is the default feature set.
	Feature_FEATURE_NONE Feature = 0
	// NODES is the feature for nodes. This is always supported.
	Feature_NODES Feature = 1
	// LEADER_PROXY is the feature for leader proxying.
	Feature_LEADER_PROXY Feature = 2
	// MESH_API is the feature for the mesh API.
	Feature_MESH_API Feature = 3
	// PEER_DISCOVERY is the feature for peer discovery.
	Feature_PEER_DISCOVERY Feature = 4
	// METRICS is the feature for exposing metrics.
	Feature_METRICS Feature = 5
	// ICE_NEGOTIATION is the feature for ICE negotiation.
	Feature_ICE_NEGOTIATION Feature = 6
	// TURN_SERVER is the feature for TURN server.
	Feature_TURN_SERVER Feature = 7
	// MESH_DNS is the feature for mesh DNS.
	Feature_MESH_DNS Feature = 8
)

func (Feature) Descriptor 

func (Feature) Descriptor() protoreflect.EnumDescriptor

func (Feature) Enum 

func (x Feature) Enum() *Feature

func (Feature) EnumDescriptor deprecated 

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

Deprecated: Use Feature.Descriptor instead.

func (Feature) Number 

func (x Feature) Number() protoreflect.EnumNumber

func (Feature) String 

func (x Feature) String() string

func (Feature) Type 

func (Feature) Type() protoreflect.EnumType

type GetNodeRequest 

type GetNodeRequest struct {

	// id is the ID of the node.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetNodeRequest is a request to get a node.

func (*GetNodeRequest) Descriptor deprecated 

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

Deprecated: Use GetNodeRequest.ProtoReflect.Descriptor instead.

func (*GetNodeRequest) GetId 

func (x *GetNodeRequest) GetId() string

func (*GetNodeRequest) ProtoMessage 

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) ProtoReflect 

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

func (*GetNodeRequest) Reset 

func (x *GetNodeRequest) Reset()

func (*GetNodeRequest) String 

func (x *GetNodeRequest) String() string

type GetRaftACLRequest added in v0.0.6 

type GetRaftACLRequest struct {

	// name is the name of the ACL.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

GetRaftACLRequest is a request to get a RaftACL.

func (*GetRaftACLRequest) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use GetRaftACLRequest.ProtoReflect.Descriptor instead.

func (*GetRaftACLRequest) GetName added in v0.0.6 

func (x *GetRaftACLRequest) GetName() string

func (*GetRaftACLRequest) ProtoMessage added in v0.0.6 

func (*GetRaftACLRequest) ProtoMessage()

func (*GetRaftACLRequest) ProtoReflect added in v0.0.6 

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

func (*GetRaftACLRequest) Reset added in v0.0.6 

func (x *GetRaftACLRequest) Reset()

func (*GetRaftACLRequest) String added in v0.0.6 

func (x *GetRaftACLRequest) String() string

type GetStatusRequest added in v0.0.6 

type GetStatusRequest struct {

	// id is the ID of the node. If unset, the status of the
	// local node is returned.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetStatusRequest is a request to get the status of a node.

func (*GetStatusRequest) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStatusRequest) GetId added in v0.0.6 

func (x *GetStatusRequest) GetId() string

func (*GetStatusRequest) ProtoMessage added in v0.0.6 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) ProtoReflect added in v0.0.6 

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

func (*GetStatusRequest) Reset added in v0.0.6 

func (x *GetStatusRequest) Reset()

func (*GetStatusRequest) String added in v0.0.6 

func (x *GetStatusRequest) String() string

type HostInfo 

type HostInfo struct {

	// architecture is the architecture of the host.
	Architecture string `protobuf:"bytes,1,opt,name=architecture,proto3" json:"architecture,omitempty"`
	// boot_time is the boot time of the host.
	BootTime string `protobuf:"bytes,2,opt,name=boot_time,json=bootTime,proto3" json:"boot_time,omitempty"`
	// containerized is whether the host is containerized.
	Containerized bool `protobuf:"varint,3,opt,name=containerized,proto3" json:"containerized,omitempty"`
	// hostname is the hostname of the host.
	Hostname string `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// ips is the list of IP addresses of the host.
	Ips []string `protobuf:"bytes,5,rep,name=ips,proto3" json:"ips,omitempty"`
	// kernel_version is the kernel version of the host.
	KernelVersion string `protobuf:"bytes,6,opt,name=kernel_version,json=kernelVersion,proto3" json:"kernel_version,omitempty"`
	// macs is the list of MAC addresses of the host.
	Macs []string `protobuf:"bytes,7,rep,name=macs,proto3" json:"macs,omitempty"`
	// os is the OS of the host.
	Os *OSInfo `protobuf:"bytes,8,opt,name=os,proto3" json:"os,omitempty"`
	// timezone is the timezone of the host.
	Timezone string `protobuf:"bytes,9,opt,name=timezone,proto3" json:"timezone,omitempty"`
	// uptime is the uptime of the host.
	Uptime string `protobuf:"bytes,10,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// contains filtered or unexported fields
}

HostInfo is the host information.

func (*HostInfo) Descriptor deprecated 

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

Deprecated: Use HostInfo.ProtoReflect.Descriptor instead.

func (*HostInfo) GetArchitecture 

func (x *HostInfo) GetArchitecture() string

func (*HostInfo) GetBootTime 

func (x *HostInfo) GetBootTime() string

func (*HostInfo) GetContainerized 

func (x *HostInfo) GetContainerized() bool

func (*HostInfo) GetHostname 

func (x *HostInfo) GetHostname() string

func (*HostInfo) GetIps 

func (x *HostInfo) GetIps() []string

func (*HostInfo) GetKernelVersion 

func (x *HostInfo) GetKernelVersion() string

func (*HostInfo) GetMacs 

func (x *HostInfo) GetMacs() []string

func (*HostInfo) GetOs 

func (x *HostInfo) GetOs() *OSInfo

func (*HostInfo) GetTimezone 

func (x *HostInfo) GetTimezone() string

func (*HostInfo) GetUptime 

func (x *HostInfo) GetUptime() string

func (*HostInfo) ProtoMessage 

func (*HostInfo) ProtoMessage()

func (*HostInfo) ProtoReflect 

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

func (*HostInfo) Reset 

func (x *HostInfo) Reset()

func (*HostInfo) String 

func (x *HostInfo) String() string

type HostMetrics 

type HostMetrics struct {

	// host is the host metrics.
	Host *HostInfo `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// cpu is the CPU metrics.
	Cpu *CPUTimes `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// memory is the memory metrics.
	Memory *MemoryInfo `protobuf:"bytes,3,opt,name=memory,proto3" json:"memory,omitempty"`
	// disks is the disk metrics.
	Disks []*DiskInfo `protobuf:"bytes,4,rep,name=disks,proto3" json:"disks,omitempty"`
	// contains filtered or unexported fields
}

HostMetrics is the metrics for the host.

func (*HostMetrics) Descriptor deprecated 

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

Deprecated: Use HostMetrics.ProtoReflect.Descriptor instead.

func (*HostMetrics) GetCpu 

func (x *HostMetrics) GetCpu() *CPUTimes

func (*HostMetrics) GetDisks 

func (x *HostMetrics) GetDisks() []*DiskInfo

func (*HostMetrics) GetHost 

func (x *HostMetrics) GetHost() *HostInfo

func (*HostMetrics) GetMemory 

func (x *HostMetrics) GetMemory() *MemoryInfo

func (*HostMetrics) ProtoMessage 

func (*HostMetrics) ProtoMessage()

func (*HostMetrics) ProtoReflect 

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

func (*HostMetrics) Reset 

func (x *HostMetrics) Reset()

func (*HostMetrics) String 

func (x *HostMetrics) String() string

type JoinRequest 

type JoinRequest struct {

	// id is the ID of the node.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// public_key is the public wireguard key of the node to broadcast to peers.
	PublicKey string `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// raft_port is the Raft listen port of the node.
	RaftPort int32 `protobuf:"varint,3,opt,name=raft_port,json=raftPort,proto3" json:"raft_port,omitempty"`
	// grpc_port is the gRPC listen port of the node.
	GrpcPort int32 `protobuf:"varint,4,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"`
	// wireguard_port is the Wireguard listen port of the node.
	WireguardPort int32 `protobuf:"varint,5,opt,name=wireguard_port,json=wireguardPort,proto3" json:"wireguard_port,omitempty"`
	// primary_endpoint is a routable address for the node. If left unset,
	// the node is assumed to be behind a NAT and not directly accessible.
	PrimaryEndpoint string `protobuf:"bytes,6,opt,name=primary_endpoint,json=primaryEndpoint,proto3" json:"primary_endpoint,omitempty"`
	// endpoints are additional endpoints routable to the node. See primary_endpoint.
	Endpoints []string `protobuf:"bytes,7,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// assign_ipv4 is whether an IPv4 address should be assigned to the node.
	AssignIpv4 bool `protobuf:"varint,8,opt,name=assign_ipv4,json=assignIpv4,proto3" json:"assign_ipv4,omitempty"`
	// prefer_raft_ipv6 is whether IPv6 should be preferred over IPv4 for raft communication.
	// This is only used if assign_ipv4 is true.
	PreferRaftIpv6 bool `protobuf:"varint,9,opt,name=prefer_raft_ipv6,json=preferRaftIpv6,proto3" json:"prefer_raft_ipv6,omitempty"`
	// as_voter is whether the node should receive a vote in elections.
	AsVoter bool `protobuf:"varint,10,opt,name=as_voter,json=asVoter,proto3" json:"as_voter,omitempty"`
	// contains filtered or unexported fields
}

JoinRequest is a request to join the cluster.

func (*JoinRequest) Descriptor deprecated 

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

Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.

func (*JoinRequest) GetAsVoter 

func (x *JoinRequest) GetAsVoter() bool

func (*JoinRequest) GetAssignIpv4 

func (x *JoinRequest) GetAssignIpv4() bool

func (*JoinRequest) GetEndpoints added in v0.0.6 

func (x *JoinRequest) GetEndpoints() []string

func (*JoinRequest) GetGrpcPort 

func (x *JoinRequest) GetGrpcPort() int32

func (*JoinRequest) GetId 

func (x *JoinRequest) GetId() string

func (*JoinRequest) GetPreferRaftIpv6 

func (x *JoinRequest) GetPreferRaftIpv6() bool

func (*JoinRequest) GetPrimaryEndpoint added in v0.0.6 

func (x *JoinRequest) GetPrimaryEndpoint() string

func (*JoinRequest) GetPublicKey 

func (x *JoinRequest) GetPublicKey() string

func (*JoinRequest) GetRaftPort 

func (x *JoinRequest) GetRaftPort() int32

func (*JoinRequest) GetWireguardPort added in v0.0.5 

func (x *JoinRequest) GetWireguardPort() int32

func (*JoinRequest) ProtoMessage 

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) ProtoReflect 

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

func (*JoinRequest) Reset 

func (x *JoinRequest) Reset()

func (*JoinRequest) String 

func (x *JoinRequest) String() string

type JoinResponse 

type JoinResponse struct {

	// address_ipv4 is the private IPv4 wireguard address of the node
	// in CIDR format representing the network. This is only set if
	// assign_ipv4 was set in the request or no network_ipv6 was provided.
	AddressIpv4 string `protobuf:"bytes,1,opt,name=address_ipv4,json=addressIpv4,proto3" json:"address_ipv4,omitempty"`
	// network_ipv6 is the IPv6 network assigned to the node.
	NetworkIpv6 string `protobuf:"bytes,2,opt,name=network_ipv6,json=networkIpv6,proto3" json:"network_ipv6,omitempty"`
	// peers is a list of wireguard peers to connect to.
	Peers []*WireguardPeer `protobuf:"bytes,3,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

JoinResponse is a response to a join request.

func (*JoinResponse) Descriptor deprecated 

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

Deprecated: Use JoinResponse.ProtoReflect.Descriptor instead.

func (*JoinResponse) GetAddressIpv4 

func (x *JoinResponse) GetAddressIpv4() string

func (*JoinResponse) GetNetworkIpv6 

func (x *JoinResponse) GetNetworkIpv6() string

func (*JoinResponse) GetPeers 

func (x *JoinResponse) GetPeers() []*WireguardPeer

func (*JoinResponse) ProtoMessage 

func (*JoinResponse) ProtoMessage()

func (*JoinResponse) ProtoReflect 

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

func (*JoinResponse) Reset 

func (x *JoinResponse) Reset()

func (*JoinResponse) String 

func (x *JoinResponse) String() string

type LeaveRequest 

type LeaveRequest struct {

	// id is the ID of the node.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

LeaveRequest is a request to leave the cluster.

func (*LeaveRequest) Descriptor deprecated 

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

Deprecated: Use LeaveRequest.ProtoReflect.Descriptor instead.

func (*LeaveRequest) GetId 

func (x *LeaveRequest) GetId() string

func (*LeaveRequest) ProtoMessage 

func (*LeaveRequest) ProtoMessage()

func (*LeaveRequest) ProtoReflect 

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

func (*LeaveRequest) Reset 

func (x *LeaveRequest) Reset()

func (*LeaveRequest) String 

func (x *LeaveRequest) String() string

type ListRaftPeersResponse 

type ListRaftPeersResponse struct {

	// Peers is the list of peers.
	Peers []*RaftPeer `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

ListRaftPeersResponse is the response to ListPeers.

func (*ListRaftPeersResponse) Descriptor deprecated 

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

Deprecated: Use ListRaftPeersResponse.ProtoReflect.Descriptor instead.

func (*ListRaftPeersResponse) GetPeers 

func (x *ListRaftPeersResponse) GetPeers() []*RaftPeer

func (*ListRaftPeersResponse) ProtoMessage 

func (*ListRaftPeersResponse) ProtoMessage()

func (*ListRaftPeersResponse) ProtoReflect 

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

func (*ListRaftPeersResponse) Reset 

func (x *ListRaftPeersResponse) Reset()

func (*ListRaftPeersResponse) String 

func (x *ListRaftPeersResponse) String() string

type LoadAverage 

type LoadAverage struct {

	// one is the 1 minute load average.
	One float32 `protobuf:"fixed32,1,opt,name=one,proto3" json:"one,omitempty"`
	// five is the 5 minute load average.
	Five float32 `protobuf:"fixed32,2,opt,name=five,proto3" json:"five,omitempty"`
	// fifteen is the 15 minute load average.
	Fifteen float32 `protobuf:"fixed32,3,opt,name=fifteen,proto3" json:"fifteen,omitempty"`
	// contains filtered or unexported fields
}

LoadAverage is the load average.

func (*LoadAverage) Descriptor deprecated 

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

Deprecated: Use LoadAverage.ProtoReflect.Descriptor instead.

func (*LoadAverage) GetFifteen 

func (x *LoadAverage) GetFifteen() float32

func (*LoadAverage) GetFive 

func (x *LoadAverage) GetFive() float32

func (*LoadAverage) GetOne 

func (x *LoadAverage) GetOne() float32

func (*LoadAverage) ProtoMessage 

func (*LoadAverage) ProtoMessage()

func (*LoadAverage) ProtoReflect 

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

func (*LoadAverage) Reset 

func (x *LoadAverage) Reset()

func (*LoadAverage) String 

func (x *LoadAverage) String() string

type MemoryInfo 

type MemoryInfo struct {

	// total is the total memory.
	Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	// used is the used memory.
	Used uint64 `protobuf:"varint,2,opt,name=used,proto3" json:"used,omitempty"`
	// available is the available memory.
	Available uint64 `protobuf:"varint,3,opt,name=available,proto3" json:"available,omitempty"`
	// free is the free memory.
	Free uint64 `protobuf:"varint,4,opt,name=free,proto3" json:"free,omitempty"`
	// virtual_total is the total virtual memory.
	VirtualTotal uint64 `protobuf:"varint,5,opt,name=virtual_total,json=virtualTotal,proto3" json:"virtual_total,omitempty"`
	// virtual_used is the used virtual memory.
	VirtualUsed uint64 `protobuf:"varint,6,opt,name=virtual_used,json=virtualUsed,proto3" json:"virtual_used,omitempty"`
	// virtual_free is the free virtual memory.
	VirtualFree uint64 `protobuf:"varint,7,opt,name=virtual_free,json=virtualFree,proto3" json:"virtual_free,omitempty"`
	// contains filtered or unexported fields
}

MemoryInfo is the memory information.

func (*MemoryInfo) Descriptor deprecated 

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

Deprecated: Use MemoryInfo.ProtoReflect.Descriptor instead.

func (*MemoryInfo) GetAvailable 

func (x *MemoryInfo) GetAvailable() uint64

func (*MemoryInfo) GetFree 

func (x *MemoryInfo) GetFree() uint64

func (*MemoryInfo) GetTotal 

func (x *MemoryInfo) GetTotal() uint64

func (*MemoryInfo) GetUsed 

func (x *MemoryInfo) GetUsed() uint64

func (*MemoryInfo) GetVirtualFree 

func (x *MemoryInfo) GetVirtualFree() uint64

func (*MemoryInfo) GetVirtualTotal 

func (x *MemoryInfo) GetVirtualTotal() uint64

func (*MemoryInfo) GetVirtualUsed 

func (x *MemoryInfo) GetVirtualUsed() uint64

func (*MemoryInfo) ProtoMessage 

func (*MemoryInfo) ProtoMessage()

func (*MemoryInfo) ProtoReflect 

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

func (*MemoryInfo) Reset 

func (x *MemoryInfo) Reset()

func (*MemoryInfo) String 

func (x *MemoryInfo) String() string

type MeshClient added in v0.0.5 

type MeshClient interface {
	// GetNode gets a node by ID.
	GetNode(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*MeshNode, error)
	// ListNodes lists all nodes.
	ListNodes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NodeList, error)
}

MeshClient is the client API for Mesh 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 NewMeshClient added in v0.0.5 

func NewMeshClient(cc grpc.ClientConnInterface) MeshClient

type MeshNode 

type MeshNode struct {

	// id is the ID of the node.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// primary_endpoint is the primary_endpoint of the node.
	PrimaryEndpoint string `protobuf:"bytes,2,opt,name=primary_endpoint,json=primaryEndpoint,proto3" json:"primary_endpoint,omitempty"`
	// endpoints are alternate endpoints for the node.
	Endpoints []string `protobuf:"bytes,3,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// raft_port is the Raft listen port of the node.
	RaftPort int32 `protobuf:"varint,4,opt,name=raft_port,json=raftPort,proto3" json:"raft_port,omitempty"`
	// grpc_port is the gRPC listen port of the node.
	GrpcPort int32 `protobuf:"varint,5,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"`
	// wireguard_port is the Wireguard listen port of the node.
	WireguardPort int32 `protobuf:"varint,6,opt,name=wireguard_port,json=wireguardPort,proto3" json:"wireguard_port,omitempty"`
	// public_key is the public key of the node.
	PublicKey string `protobuf:"bytes,7,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// private_ipv4 is the private IPv4 address of the node.
	PrivateIpv4 string `protobuf:"bytes,8,opt,name=private_ipv4,json=privateIpv4,proto3" json:"private_ipv4,omitempty"`
	// private_ipv6 is the private IPv6 address of the node.
	PrivateIpv6 string `protobuf:"bytes,9,opt,name=private_ipv6,json=privateIpv6,proto3" json:"private_ipv6,omitempty"`
	// updated_at is the last time the node joined the cluster.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// created_at is the creation time for the node.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// cluster_status is the status of the node in the cluster.
	ClusterStatus ClusterStatus `protobuf:"varint,12,opt,name=cluster_status,json=clusterStatus,proto3,enum=v1.ClusterStatus" json:"cluster_status,omitempty"`
	// contains filtered or unexported fields
}

MeshNode is a node that has been registered with the controller.

func (*MeshNode) Descriptor deprecated 

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

Deprecated: Use MeshNode.ProtoReflect.Descriptor instead.

func (*MeshNode) GetClusterStatus added in v0.0.4 

func (x *MeshNode) GetClusterStatus() ClusterStatus

func (*MeshNode) GetCreatedAt 

func (x *MeshNode) GetCreatedAt() *timestamppb.Timestamp

func (*MeshNode) GetEndpoints added in v0.0.6 

func (x *MeshNode) GetEndpoints() []string

func (*MeshNode) GetGrpcPort added in v0.0.5 

func (x *MeshNode) GetGrpcPort() int32

func (*MeshNode) GetId 

func (x *MeshNode) GetId() string

func (*MeshNode) GetPrimaryEndpoint added in v0.0.6 

func (x *MeshNode) GetPrimaryEndpoint() string

func (*MeshNode) GetPrivateIpv4 

func (x *MeshNode) GetPrivateIpv4() string

func (*MeshNode) GetPrivateIpv6 

func (x *MeshNode) GetPrivateIpv6() string

func (*MeshNode) GetPublicKey 

func (x *MeshNode) GetPublicKey() string

func (*MeshNode) GetRaftPort added in v0.0.5 

func (x *MeshNode) GetRaftPort() int32

func (*MeshNode) GetUpdatedAt 

func (x *MeshNode) GetUpdatedAt() *timestamppb.Timestamp

func (*MeshNode) GetWireguardPort added in v0.0.5 

func (x *MeshNode) GetWireguardPort() int32

func (*MeshNode) ProtoMessage 

func (*MeshNode) ProtoMessage()

func (*MeshNode) ProtoReflect 

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

func (*MeshNode) Reset 

func (x *MeshNode) Reset()

func (*MeshNode) String 

func (x *MeshNode) String() string

type MeshServer added in v0.0.5 

type MeshServer interface {
	// GetNode gets a node by ID.
	GetNode(context.Context, *GetNodeRequest) (*MeshNode, error)
	// ListNodes lists all nodes.
	ListNodes(context.Context, *emptypb.Empty) (*NodeList, error)
	// contains filtered or unexported methods
}

MeshServer is the server API for Mesh service. All implementations must embed UnimplementedMeshServer for forward compatibility

type NodeClient 

type NodeClient interface {
	// Join is used to join a node to the mesh. The joining node will be added to the mesh
	// as an observer, and will be able to query the mesh state, but will not be able to vote
	// in elections. To join as a voter pass the as_voter flag.
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)
	// Leave is used to remove a node from the mesh. The node will be removed from the mesh
	// and will no longer be able to query the mesh state or vote in elections.
	Leave(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// GetStatus gets the status of a node in the cluster.
	GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*Status, error)
	// NegotiateDataChannel is used to negotiate a WebRTC connection between a webmesh client
	// and a node in the cluster. The handling server will send the target node the source address,
	// the destination for traffic, and STUN/TURN servers to use for the negotiation. The node
	// responds with an offer to be forwarded to the client. When the handler receives an answer
	// from the client, it forwards it to the node. Once the node receives the answer, the stream
	// can optionally be used to exchange ICE candidates.
	NegotiateDataChannel(ctx context.Context, opts ...grpc.CallOption) (Node_NegotiateDataChannelClient, error)
}

NodeClient is the client API for Node 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 NewNodeClient 

func NewNodeClient(cc grpc.ClientConnInterface) NodeClient

type NodeList 

type NodeList struct {

	// nodes is the list of nodes.
	Nodes []*MeshNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

NodeList is a list of nodes.

func (*NodeList) Descriptor deprecated 

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

Deprecated: Use NodeList.ProtoReflect.Descriptor instead.

func (*NodeList) GetNodes 

func (x *NodeList) GetNodes() []*MeshNode

func (*NodeList) ProtoMessage 

func (*NodeList) ProtoMessage()

func (*NodeList) ProtoReflect 

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

func (*NodeList) Reset 

func (x *NodeList) Reset()

func (*NodeList) String 

func (x *NodeList) String() string

type NodeMetrics 

type NodeMetrics struct {

	// device_name is the name of the device.
	DeviceName string `protobuf:"bytes,1,opt,name=device_name,json=deviceName,proto3" json:"device_name,omitempty"`
	// public_key is the public key of the node.
	PublicKey string `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// address_v4 is the IPv4 address of the node.
	AddressV4 string `protobuf:"bytes,3,opt,name=address_v4,json=addressV4,proto3" json:"address_v4,omitempty"`
	// address_v6 is the IPv6 address of the node.
	AddressV6 string `protobuf:"bytes,4,opt,name=address_v6,json=addressV6,proto3" json:"address_v6,omitempty"`
	// type is the type of interface being used for wireguard.
	Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	// listen_port is the port wireguard is listening on.
	ListenPort int32 `protobuf:"varint,6,opt,name=listen_port,json=listenPort,proto3" json:"listen_port,omitempty"`
	// total_receive_bytes is the total number of bytes received.
	TotalReceiveBytes uint64 `protobuf:"varint,7,opt,name=total_receive_bytes,json=totalReceiveBytes,proto3" json:"total_receive_bytes,omitempty"`
	// total_transmit_bytes is the total number of bytes transmitted.
	TotalTransmitBytes uint64 `protobuf:"varint,8,opt,name=total_transmit_bytes,json=totalTransmitBytes,proto3" json:"total_transmit_bytes,omitempty"`
	// peers are the per-peer statistics.
	Peers []*PeerMetrics `protobuf:"bytes,9,rep,name=peers,proto3" json:"peers,omitempty"`
	// system is the system metrics for the node.
	System *HostMetrics `protobuf:"bytes,10,opt,name=system,proto3" json:"system,omitempty"`
	// contains filtered or unexported fields
}

NodeMetrics is the metrics for the node.

func (*NodeMetrics) Descriptor deprecated 

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

Deprecated: Use NodeMetrics.ProtoReflect.Descriptor instead.

func (*NodeMetrics) GetAddressV4 

func (x *NodeMetrics) GetAddressV4() string

func (*NodeMetrics) GetAddressV6 

func (x *NodeMetrics) GetAddressV6() string

func (*NodeMetrics) GetDeviceName 

func (x *NodeMetrics) GetDeviceName() string

func (*NodeMetrics) GetListenPort 

func (x *NodeMetrics) GetListenPort() int32

func (*NodeMetrics) GetPeers 

func (x *NodeMetrics) GetPeers() []*PeerMetrics

func (*NodeMetrics) GetPublicKey 

func (x *NodeMetrics) GetPublicKey() string

func (*NodeMetrics) GetSystem 

func (x *NodeMetrics) GetSystem() *HostMetrics

func (*NodeMetrics) GetTotalReceiveBytes 

func (x *NodeMetrics) GetTotalReceiveBytes() uint64

func (*NodeMetrics) GetTotalTransmitBytes 

func (x *NodeMetrics) GetTotalTransmitBytes() uint64

func (*NodeMetrics) GetType 

func (x *NodeMetrics) GetType() string

func (*NodeMetrics) ProtoMessage 

func (*NodeMetrics) ProtoMessage()

func (*NodeMetrics) ProtoReflect 

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

func (*NodeMetrics) Reset 

func (x *NodeMetrics) Reset()

func (*NodeMetrics) String 

func (x *NodeMetrics) String() string

type NodeServer 

type NodeServer interface {
	// Join is used to join a node to the mesh. The joining node will be added to the mesh
	// as an observer, and will be able to query the mesh state, but will not be able to vote
	// in elections. To join as a voter pass the as_voter flag.
	Join(context.Context, *JoinRequest) (*JoinResponse, error)
	// Leave is used to remove a node from the mesh. The node will be removed from the mesh
	// and will no longer be able to query the mesh state or vote in elections.
	Leave(context.Context, *LeaveRequest) (*emptypb.Empty, error)
	// GetStatus gets the status of a node in the cluster.
	GetStatus(context.Context, *GetStatusRequest) (*Status, error)
	// NegotiateDataChannel is used to negotiate a WebRTC connection between a webmesh client
	// and a node in the cluster. The handling server will send the target node the source address,
	// the destination for traffic, and STUN/TURN servers to use for the negotiation. The node
	// responds with an offer to be forwarded to the client. When the handler receives an answer
	// from the client, it forwards it to the node. Once the node receives the answer, the stream
	// can optionally be used to exchange ICE candidates.
	NegotiateDataChannel(Node_NegotiateDataChannelServer) error
	// contains filtered or unexported methods
}

NodeServer is the server API for Node service. All implementations must embed UnimplementedNodeServer for forward compatibility

type Node_NegotiateDataChannelClient added in v0.0.6 

type Node_NegotiateDataChannelClient interface {
	Send(*DataChannelNegotiation) error
	Recv() (*DataChannelNegotiation, error)
	grpc.ClientStream
}

type Node_NegotiateDataChannelServer added in v0.0.6 

type Node_NegotiateDataChannelServer interface {
	Send(*DataChannelNegotiation) error
	Recv() (*DataChannelNegotiation, error)
	grpc.ServerStream
}

type OSInfo 

type OSInfo struct {

	// type is the type of OS.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// family is the family of OS.
	Family string `protobuf:"bytes,2,opt,name=family,proto3" json:"family,omitempty"`
	// platform is the platform of OS.
	Platform string `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	// name is the name of OS.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// version is the version of OS.
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// major is the major version of OS.
	Major int64 `protobuf:"varint,6,opt,name=major,proto3" json:"major,omitempty"`
	// minor is the minor version of OS.
	Minor int64 `protobuf:"varint,7,opt,name=minor,proto3" json:"minor,omitempty"`
	// patch is the patch version of OS.
	Patch int64 `protobuf:"varint,8,opt,name=patch,proto3" json:"patch,omitempty"`
	// build is the build version of OS.
	Build string `protobuf:"bytes,9,opt,name=build,proto3" json:"build,omitempty"`
	// codename is the codename of OS.
	Codename string `protobuf:"bytes,10,opt,name=codename,proto3" json:"codename,omitempty"`
	// contains filtered or unexported fields
}

OSInfo is the OS information.

func (*OSInfo) Descriptor deprecated 

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

Deprecated: Use OSInfo.ProtoReflect.Descriptor instead.

func (*OSInfo) GetBuild 

func (x *OSInfo) GetBuild() string

func (*OSInfo) GetCodename 

func (x *OSInfo) GetCodename() string

func (*OSInfo) GetFamily 

func (x *OSInfo) GetFamily() string

func (*OSInfo) GetMajor 

func (x *OSInfo) GetMajor() int64

func (*OSInfo) GetMinor 

func (x *OSInfo) GetMinor() int64

func (*OSInfo) GetName 

func (x *OSInfo) GetName() string

func (*OSInfo) GetPatch 

func (x *OSInfo) GetPatch() int64

func (*OSInfo) GetPlatform 

func (x *OSInfo) GetPlatform() string

func (*OSInfo) GetType 

func (x *OSInfo) GetType() string

func (*OSInfo) GetVersion 

func (x *OSInfo) GetVersion() string

func (*OSInfo) ProtoMessage 

func (*OSInfo) ProtoMessage()

func (*OSInfo) ProtoReflect 

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

func (*OSInfo) Reset 

func (x *OSInfo) Reset()

func (*OSInfo) String 

func (x *OSInfo) String() string

type PeerDiscoveryClient 

type PeerDiscoveryClient interface {
	// ListPeers returns a list of public peers currently known to the mesh.
	ListPeers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListRaftPeersResponse, error)
}

PeerDiscoveryClient is the client API for PeerDiscovery 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 NewPeerDiscoveryClient 

func NewPeerDiscoveryClient(cc grpc.ClientConnInterface) PeerDiscoveryClient

type PeerDiscoveryServer 

type PeerDiscoveryServer interface {
	// ListPeers returns a list of public peers currently known to the mesh.
	ListPeers(context.Context, *emptypb.Empty) (*ListRaftPeersResponse, error)
	// contains filtered or unexported methods
}

PeerDiscoveryServer is the server API for PeerDiscovery service. All implementations must embed UnimplementedPeerDiscoveryServer for forward compatibility

type PeerMetrics 

type PeerMetrics struct {

	// public_key is the public key of the peer.
	PublicKey string `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// endpoint is the connected endpoint of the peer.
	Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// persistent_keep_alive is the persistent keep alive interval for the peer.
	PersistentKeepAlive string `protobuf:"bytes,3,opt,name=persistent_keep_alive,json=persistentKeepAlive,proto3" json:"persistent_keep_alive,omitempty"`
	// last_handshake_time is the last handshake time for the peer.
	LastHandshakeTime string `protobuf:"bytes,4,opt,name=last_handshake_time,json=lastHandshakeTime,proto3" json:"last_handshake_time,omitempty"`
	// allowed_ips is the list of allowed IPs for the peer.
	AllowedIps []string `protobuf:"bytes,5,rep,name=allowed_ips,json=allowedIps,proto3" json:"allowed_ips,omitempty"`
	// protocol_version is the version of the wireguard protocol negotiated with the peer.
	ProtocolVersion int64 `protobuf:"varint,6,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// receive_bytes is the bytes received from the peer.
	ReceiveBytes uint64 `protobuf:"varint,7,opt,name=receive_bytes,json=receiveBytes,proto3" json:"receive_bytes,omitempty"`
	// transmit_bytes is the bytes transmitted to the peer.
	TransmitBytes uint64 `protobuf:"varint,8,opt,name=transmit_bytes,json=transmitBytes,proto3" json:"transmit_bytes,omitempty"`
	// contains filtered or unexported fields
}

PeerMetrics are the metrics for a node's peer.

func (*PeerMetrics) Descriptor deprecated 

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

Deprecated: Use PeerMetrics.ProtoReflect.Descriptor instead.

func (*PeerMetrics) GetAllowedIps 

func (x *PeerMetrics) GetAllowedIps() []string

func (*PeerMetrics) GetEndpoint 

func (x *PeerMetrics) GetEndpoint() string

func (*PeerMetrics) GetLastHandshakeTime 

func (x *PeerMetrics) GetLastHandshakeTime() string

func (*PeerMetrics) GetPersistentKeepAlive 

func (x *PeerMetrics) GetPersistentKeepAlive() string

func (*PeerMetrics) GetProtocolVersion 

func (x *PeerMetrics) GetProtocolVersion() int64

func (*PeerMetrics) GetPublicKey 

func (x *PeerMetrics) GetPublicKey() string

func (*PeerMetrics) GetReceiveBytes 

func (x *PeerMetrics) GetReceiveBytes() uint64

func (*PeerMetrics) GetTransmitBytes 

func (x *PeerMetrics) GetTransmitBytes() uint64

func (*PeerMetrics) ProtoMessage 

func (*PeerMetrics) ProtoMessage()

func (*PeerMetrics) ProtoReflect 

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

func (*PeerMetrics) Reset 

func (x *PeerMetrics) Reset()

func (*PeerMetrics) String 

func (x *PeerMetrics) String() string

type RaftACL added in v0.0.6 

type RaftACL struct {

	// name is the name of the ACL.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// patterns is a list of node patterns this ACL applies to.
	Patterns []string `protobuf:"bytes,2,rep,name=patterns,proto3" json:"patterns,omitempty"`
	// action is the action of this ACL. For RaftACLs This is
	// if the matching nodes are allowed to vote in elections
	// or not.
	Action ACLAction `protobuf:"varint,3,opt,name=action,proto3,enum=ACLAction" json:"action,omitempty"`
	// contains filtered or unexported fields
}

RaftACL is an ACL that applies to Raft nodes.

func (*RaftACL) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use RaftACL.ProtoReflect.Descriptor instead.

func (*RaftACL) GetAction added in v0.0.6 

func (x *RaftACL) GetAction() ACLAction

func (*RaftACL) GetName added in v0.0.6 

func (x *RaftACL) GetName() string

func (*RaftACL) GetPatterns added in v0.0.6 

func (x *RaftACL) GetPatterns() []string

func (*RaftACL) ProtoMessage added in v0.0.6 

func (*RaftACL) ProtoMessage()

func (*RaftACL) ProtoReflect added in v0.0.6 

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

func (*RaftACL) Reset added in v0.0.6 

func (x *RaftACL) Reset()

func (*RaftACL) String added in v0.0.6 

func (x *RaftACL) String() string

type RaftACLList added in v0.0.6 

type RaftACLList struct {

	// items is a list of RaftACLs.
	Items []*RaftACL `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

RaftACLList is a list of RaftACLs.

func (*RaftACLList) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use RaftACLList.ProtoReflect.Descriptor instead.

func (*RaftACLList) GetItems added in v0.0.6 

func (x *RaftACLList) GetItems() []*RaftACL

func (*RaftACLList) ProtoMessage added in v0.0.6 

func (*RaftACLList) ProtoMessage()

func (*RaftACLList) ProtoReflect added in v0.0.6 

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

func (*RaftACLList) Reset added in v0.0.6 

func (x *RaftACLList) Reset()

func (*RaftACLList) String added in v0.0.6 

func (x *RaftACLList) String() string

type RaftApplyResponse 

type RaftApplyResponse struct {

	// time is the total time it took to apply the log entry.
	Time string `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// query is the query result of the log entry.
	QueryResult *SQLQueryResult `protobuf:"bytes,2,opt,name=query_result,json=queryResult,proto3" json:"query_result,omitempty"`
	// exec is the exec result of the log entry.
	ExecResult *SQLExecResult `protobuf:"bytes,3,opt,name=exec_result,json=execResult,proto3" json:"exec_result,omitempty"`
	// error is an error that occurred during the apply.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

RaftApplyResponse is the response to an apply request. It contains the result of applying the log entry.

func (*RaftApplyResponse) Descriptor deprecated 

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

Deprecated: Use RaftApplyResponse.ProtoReflect.Descriptor instead.

func (*RaftApplyResponse) GetError 

func (x *RaftApplyResponse) GetError() string

func (*RaftApplyResponse) GetExecResult added in v0.0.5 

func (x *RaftApplyResponse) GetExecResult() *SQLExecResult

func (*RaftApplyResponse) GetQueryResult added in v0.0.5 

func (x *RaftApplyResponse) GetQueryResult() *SQLQueryResult

func (*RaftApplyResponse) GetTime 

func (x *RaftApplyResponse) GetTime() string

func (*RaftApplyResponse) ProtoMessage 

func (*RaftApplyResponse) ProtoMessage()

func (*RaftApplyResponse) ProtoReflect 

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

func (*RaftApplyResponse) Reset 

func (x *RaftApplyResponse) Reset()

func (*RaftApplyResponse) String 

func (x *RaftApplyResponse) String() string

type RaftCommandType 

type RaftCommandType int32

RaftCommandType is the type of command being sent to the Raft log. 

const (
	// UNKNOWN is the unknown command type.
	RaftCommandType_UNKNOWN RaftCommandType = 0
	// QUERY is the query command type.
	RaftCommandType_QUERY RaftCommandType = 1
	// EXECUTE is the execute command type.
	RaftCommandType_EXECUTE RaftCommandType = 2
)

func (RaftCommandType) Descriptor 

func (RaftCommandType) Descriptor() protoreflect.EnumDescriptor

func (RaftCommandType) Enum 

func (x RaftCommandType) Enum() *RaftCommandType

func (RaftCommandType) EnumDescriptor deprecated 

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

Deprecated: Use RaftCommandType.Descriptor instead.

func (RaftCommandType) Number 

func (x RaftCommandType) Number() protoreflect.EnumNumber

func (RaftCommandType) String 

func (x RaftCommandType) String() string

func (RaftCommandType) Type 

func (RaftCommandType) Type() protoreflect.EnumType

type RaftLogEntry 

type RaftLogEntry struct {

	// type is the type of the log entry.
	Type RaftCommandType `protobuf:"varint,1,opt,name=type,proto3,enum=v1.RaftCommandType" json:"type,omitempty"`
	// data is the data of the log entry.
	// sql_query is the SQL query of the log entry.
	SqlQuery *SQLQuery `protobuf:"bytes,2,opt,name=sql_query,json=sqlQuery,proto3" json:"sql_query,omitempty"`
	// sql_exec is the SQL exec of the log entry.
	SqlExec *SQLExec `protobuf:"bytes,3,opt,name=sql_exec,json=sqlExec,proto3" json:"sql_exec,omitempty"`
	// contains filtered or unexported fields
}

RaftLogEntry is the data of an entry in the Raft log.

func (*RaftLogEntry) Descriptor deprecated 

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

Deprecated: Use RaftLogEntry.ProtoReflect.Descriptor instead.

func (*RaftLogEntry) GetSqlExec 

func (x *RaftLogEntry) GetSqlExec() *SQLExec

func (*RaftLogEntry) GetSqlQuery 

func (x *RaftLogEntry) GetSqlQuery() *SQLQuery

func (*RaftLogEntry) GetType 

func (x *RaftLogEntry) GetType() RaftCommandType

func (*RaftLogEntry) ProtoMessage 

func (*RaftLogEntry) ProtoMessage()

func (*RaftLogEntry) ProtoReflect 

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

func (*RaftLogEntry) Reset 

func (x *RaftLogEntry) Reset()

func (*RaftLogEntry) String 

func (x *RaftLogEntry) String() string

type RaftPeer 

type RaftPeer struct {

	// ID is the ID of the peer.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Address is the public gRPC address of the peer.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// Voter is whether the peer is a voter.
	Voter bool `protobuf:"varint,3,opt,name=voter,proto3" json:"voter,omitempty"`
	// Leader is whether the peer is the leader.
	Leader bool `protobuf:"varint,4,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

RaftPeer is a peer in the Raft cluster.

func (*RaftPeer) Descriptor deprecated 

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

Deprecated: Use RaftPeer.ProtoReflect.Descriptor instead.

func (*RaftPeer) GetAddress 

func (x *RaftPeer) GetAddress() string

func (*RaftPeer) GetId 

func (x *RaftPeer) GetId() string

func (*RaftPeer) GetLeader 

func (x *RaftPeer) GetLeader() bool

func (*RaftPeer) GetVoter 

func (x *RaftPeer) GetVoter() bool

func (*RaftPeer) ProtoMessage 

func (*RaftPeer) ProtoMessage()

func (*RaftPeer) ProtoReflect 

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

func (*RaftPeer) Reset 

func (x *RaftPeer) Reset()

func (*RaftPeer) String 

func (x *RaftPeer) String() string

type SQLExec 

type SQLExec struct {

	// transaction flags whether the exec is a transaction.
	Transaction bool `protobuf:"varint,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
	// statement is the statement of the SQL exec.
	Statement *SQLStatement `protobuf:"bytes,2,opt,name=statement,proto3" json:"statement,omitempty"`
	// contains filtered or unexported fields
}

SQLExec is a SQL exec.

func (*SQLExec) Descriptor deprecated 

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

Deprecated: Use SQLExec.ProtoReflect.Descriptor instead.

func (*SQLExec) GetStatement 

func (x *SQLExec) GetStatement() *SQLStatement

func (*SQLExec) GetTransaction 

func (x *SQLExec) GetTransaction() bool

func (*SQLExec) ProtoMessage 

func (*SQLExec) ProtoMessage()

func (*SQLExec) ProtoReflect 

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

func (*SQLExec) Reset 

func (x *SQLExec) Reset()

func (*SQLExec) String 

func (x *SQLExec) String() string

type SQLExecResult 

type SQLExecResult struct {

	// last_insert_id is the last insert ID.
	LastInsertId int64 `protobuf:"varint,1,opt,name=last_insert_id,json=lastInsertId,proto3" json:"last_insert_id,omitempty"`
	// rows_affected is the number of rows affected.
	RowsAffected int64 `protobuf:"varint,2,opt,name=rows_affected,json=rowsAffected,proto3" json:"rows_affected,omitempty"`
	// error is an error that occurred during the exec.
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// time is the time it took to execute the exec.
	Time string `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

SQLExecResult is the result of a SQL exec.

func (*SQLExecResult) Descriptor deprecated 

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

Deprecated: Use SQLExecResult.ProtoReflect.Descriptor instead.

func (*SQLExecResult) GetError 

func (x *SQLExecResult) GetError() string

func (*SQLExecResult) GetLastInsertId 

func (x *SQLExecResult) GetLastInsertId() int64

func (*SQLExecResult) GetRowsAffected 

func (x *SQLExecResult) GetRowsAffected() int64

func (*SQLExecResult) GetTime 

func (x *SQLExecResult) GetTime() string

func (*SQLExecResult) ProtoMessage 

func (*SQLExecResult) ProtoMessage()

func (*SQLExecResult) ProtoReflect 

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

func (*SQLExecResult) Reset 

func (x *SQLExecResult) Reset()

func (*SQLExecResult) String 

func (x *SQLExecResult) String() string

type SQLParameter 

type SQLParameter struct {

	// name is the name of the parameter.
	Name   string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type   SQLParameterType       `protobuf:"varint,2,opt,name=type,proto3,enum=v1.SQLParameterType" json:"type,omitempty"`
	Int64  int64                  `protobuf:"zigzag64,3,opt,name=int64,proto3" json:"int64,omitempty"`
	Double float64                `protobuf:"fixed64,4,opt,name=double,proto3" json:"double,omitempty"`
	Bool   bool                   `protobuf:"varint,5,opt,name=bool,proto3" json:"bool,omitempty"`
	Bytes  []byte                 `protobuf:"bytes,6,opt,name=bytes,proto3" json:"bytes,omitempty"`
	Str    string                 `protobuf:"bytes,7,opt,name=str,proto3" json:"str,omitempty"`
	Time   *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

SQLParameter is a parameter of a SQL query.

func (*SQLParameter) Descriptor deprecated 

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

Deprecated: Use SQLParameter.ProtoReflect.Descriptor instead.

func (*SQLParameter) GetBool 

func (x *SQLParameter) GetBool() bool

func (*SQLParameter) GetBytes 

func (x *SQLParameter) GetBytes() []byte

func (*SQLParameter) GetDouble 

func (x *SQLParameter) GetDouble() float64

func (*SQLParameter) GetInt64 

func (x *SQLParameter) GetInt64() int64

func (*SQLParameter) GetName 

func (x *SQLParameter) GetName() string

func (*SQLParameter) GetStr 

func (x *SQLParameter) GetStr() string

func (*SQLParameter) GetTime 

func (x *SQLParameter) GetTime() *timestamppb.Timestamp

func (*SQLParameter) GetType added in v0.0.5 

func (x *SQLParameter) GetType() SQLParameterType

func (*SQLParameter) ProtoMessage 

func (*SQLParameter) ProtoMessage()

func (*SQLParameter) ProtoReflect 

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

func (*SQLParameter) Reset 

func (x *SQLParameter) Reset()

func (*SQLParameter) String 

func (x *SQLParameter) String() string

type SQLParameterType added in v0.0.5 

type SQLParameterType int32
const (
	// UNKNOWN is the unknown parameter type.
	SQLParameterType_SQL_PARAM_UNKNOWN SQLParameterType = 0
	// INT64 is the int64 parameter type.
	SQLParameterType_SQL_PARAM_INT64 SQLParameterType = 1
	// DOUBLE is the double parameter type.
	SQLParameterType_SQL_PARAM_DOUBLE SQLParameterType = 2
	// BOOL is the bool parameter type.
	SQLParameterType_SQL_PARAM_BOOL SQLParameterType = 3
	// BYTES is the bytes parameter type.
	SQLParameterType_SQL_PARAM_BYTES SQLParameterType = 4
	// STRING is the string parameter type.
	SQLParameterType_SQL_PARAM_STRING SQLParameterType = 5
	// TIME is the time parameter type.
	SQLParameterType_SQL_PARAM_TIME SQLParameterType = 6
	// NULL is the null parameter type.
	SQLParameterType_SQL_PARAM_NULL SQLParameterType = 7
)

func (SQLParameterType) Descriptor added in v0.0.5 

func (SQLParameterType) Descriptor() protoreflect.EnumDescriptor

func (SQLParameterType) Enum added in v0.0.5 

func (x SQLParameterType) Enum() *SQLParameterType

func (SQLParameterType) EnumDescriptor deprecated added in v0.0.5 

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

Deprecated: Use SQLParameterType.Descriptor instead.

func (SQLParameterType) Number added in v0.0.5 

func (x SQLParameterType) Number() protoreflect.EnumNumber

func (SQLParameterType) String added in v0.0.5 

func (x SQLParameterType) String() string

func (SQLParameterType) Type added in v0.0.5 

func (SQLParameterType) Type() protoreflect.EnumType

type SQLQuery 

type SQLQuery struct {

	// transaction flags whether the query is a transaction.
	Transaction bool `protobuf:"varint,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
	// statement is the statement of the SQL query.
	Statement *SQLStatement `protobuf:"bytes,2,opt,name=statement,proto3" json:"statement,omitempty"`
	// contains filtered or unexported fields
}

SQLQuery is a SQL query.

func (*SQLQuery) Descriptor deprecated 

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

Deprecated: Use SQLQuery.ProtoReflect.Descriptor instead.

func (*SQLQuery) GetStatement 

func (x *SQLQuery) GetStatement() *SQLStatement

func (*SQLQuery) GetTransaction 

func (x *SQLQuery) GetTransaction() bool

func (*SQLQuery) ProtoMessage 

func (*SQLQuery) ProtoMessage()

func (*SQLQuery) ProtoReflect 

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

func (*SQLQuery) Reset 

func (x *SQLQuery) Reset()

func (*SQLQuery) String 

func (x *SQLQuery) String() string

type SQLQueryResult 

type SQLQueryResult struct {

	// columns is the list of columns.
	Columns []string `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// types is the list of types.
	Types []string `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"`
	// values is the list of values.
	Values []*SQLValues `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// error is an error that occurred during the query.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// time is the time it took to execute the query.
	Time string `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

SQLQueryResult contains the rows of a SQL query.

func (*SQLQueryResult) Descriptor deprecated 

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

Deprecated: Use SQLQueryResult.ProtoReflect.Descriptor instead.

func (*SQLQueryResult) GetColumns 

func (x *SQLQueryResult) GetColumns() []string

func (*SQLQueryResult) GetError 

func (x *SQLQueryResult) GetError() string

func (*SQLQueryResult) GetTime 

func (x *SQLQueryResult) GetTime() string

func (*SQLQueryResult) GetTypes 

func (x *SQLQueryResult) GetTypes() []string

func (*SQLQueryResult) GetValues 

func (x *SQLQueryResult) GetValues() []*SQLValues

func (*SQLQueryResult) ProtoMessage 

func (*SQLQueryResult) ProtoMessage()

func (*SQLQueryResult) ProtoReflect 

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

func (*SQLQueryResult) Reset 

func (x *SQLQueryResult) Reset()

func (*SQLQueryResult) String 

func (x *SQLQueryResult) String() string

type SQLStatement 

type SQLStatement struct {

	// sql is the SQL statement.
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	// parameters is the parameters of the SQL statement.
	Parameters []*SQLParameter `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

SQLStatement is a SQL statement.

func (*SQLStatement) Descriptor deprecated 

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

Deprecated: Use SQLStatement.ProtoReflect.Descriptor instead.

func (*SQLStatement) GetParameters 

func (x *SQLStatement) GetParameters() []*SQLParameter

func (*SQLStatement) GetSql 

func (x *SQLStatement) GetSql() string

func (*SQLStatement) ProtoMessage 

func (*SQLStatement) ProtoMessage()

func (*SQLStatement) ProtoReflect 

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

func (*SQLStatement) Reset 

func (x *SQLStatement) Reset()

func (*SQLStatement) String 

func (x *SQLStatement) String() string

type SQLValues 

type SQLValues struct {

	// values is the list of values.
	Values []*SQLParameter `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

SQLValues is a list of values.

func (*SQLValues) Descriptor deprecated 

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

Deprecated: Use SQLValues.ProtoReflect.Descriptor instead.

func (*SQLValues) GetValues 

func (x *SQLValues) GetValues() []*SQLParameter

func (*SQLValues) ProtoMessage 

func (*SQLValues) ProtoMessage()

func (*SQLValues) ProtoReflect 

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

func (*SQLValues) Reset 

func (x *SQLValues) Reset()

func (*SQLValues) String 

func (x *SQLValues) String() string

type StartDataChannelRequest 

type StartDataChannelRequest struct {

	// node_id is the ID of the node to send the data to.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// proto is the protocol of the traffic.
	Proto string `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"`
	// dst is the destination address of the traffic.
	Dst string `protobuf:"bytes,3,opt,name=dst,proto3" json:"dst,omitempty"`
	// port is the destination port of the traffic.
	Port uint32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// answer is the answer to the offer.
	Answer string `protobuf:"bytes,5,opt,name=answer,proto3" json:"answer,omitempty"`
	// candidate is an ICE candidate.
	Candidate string `protobuf:"bytes,6,opt,name=candidate,proto3" json:"candidate,omitempty"`
	// contains filtered or unexported fields
}

StartDataChannelRequest is a request to start a data channel. The answer and candidate fields are populated after the offer is received.

func (*StartDataChannelRequest) Descriptor deprecated 

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

Deprecated: Use StartDataChannelRequest.ProtoReflect.Descriptor instead.

func (*StartDataChannelRequest) GetAnswer 

func (x *StartDataChannelRequest) GetAnswer() string

func (*StartDataChannelRequest) GetCandidate 

func (x *StartDataChannelRequest) GetCandidate() string

func (*StartDataChannelRequest) GetDst 

func (x *StartDataChannelRequest) GetDst() string

func (*StartDataChannelRequest) GetNodeId 

func (x *StartDataChannelRequest) GetNodeId() string

func (*StartDataChannelRequest) GetPort 

func (x *StartDataChannelRequest) GetPort() uint32

func (*StartDataChannelRequest) GetProto 

func (x *StartDataChannelRequest) GetProto() string

func (*StartDataChannelRequest) ProtoMessage 

func (*StartDataChannelRequest) ProtoMessage()

func (*StartDataChannelRequest) ProtoReflect 

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

func (*StartDataChannelRequest) Reset 

func (x *StartDataChannelRequest) Reset()

func (*StartDataChannelRequest) String 

func (x *StartDataChannelRequest) String() string

type Status 

type Status struct {

	// id is the ID of the node.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// version is the version of the node.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// commit is the commit of the node.
	Commit string `protobuf:"bytes,3,opt,name=commit,proto3" json:"commit,omitempty"`
	// build_date is the build date of the node.
	BuildDate string `protobuf:"bytes,4,opt,name=build_date,json=buildDate,proto3" json:"build_date,omitempty"`
	// uptime is the uptime of the node.
	Uptime string `protobuf:"bytes,5,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// started_at is the time the node started.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// features is the list of features currently enabled.
	Features []Feature `protobuf:"varint,7,rep,packed,name=features,proto3,enum=v1.Feature" json:"features,omitempty"`
	// wireguard_peers is the number of wireguard peers connected.
	WireguardPeers uint32 `protobuf:"varint,8,opt,name=wireguard_peers,json=wireguardPeers,proto3" json:"wireguard_peers,omitempty"`
	// cluster_status is the status of the node in the cluster.
	ClusterStatus ClusterStatus `protobuf:"varint,9,opt,name=cluster_status,json=clusterStatus,proto3,enum=v1.ClusterStatus" json:"cluster_status,omitempty"`
	// current_leader is the current leader of the cluster.
	CurrentLeader string `protobuf:"bytes,10,opt,name=current_leader,json=currentLeader,proto3" json:"current_leader,omitempty"`
	// contains filtered or unexported fields
}

Status represents the status of a node.

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetBuildDate 

func (x *Status) GetBuildDate() string

func (*Status) GetClusterStatus added in v0.0.4 

func (x *Status) GetClusterStatus() ClusterStatus

func (*Status) GetCommit 

func (x *Status) GetCommit() string

func (*Status) GetCurrentLeader 

func (x *Status) GetCurrentLeader() string

func (*Status) GetFeatures 

func (x *Status) GetFeatures() []Feature

func (*Status) GetId added in v0.0.4 

func (x *Status) GetId() string

func (*Status) GetStartedAt 

func (x *Status) GetStartedAt() *timestamppb.Timestamp

func (*Status) GetUptime 

func (x *Status) GetUptime() string

func (*Status) GetVersion 

func (x *Status) GetVersion() string

func (*Status) GetWireguardPeers added in v0.0.4 

func (x *Status) GetWireguardPeers() uint32

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type UnimplementedAdminServer added in v0.0.6 

type UnimplementedAdminServer struct {
}

UnimplementedAdminServer must be embedded to have forward compatible implementations.

func (UnimplementedAdminServer) DeleteRaftACL added in v0.0.6 

func (UnimplementedAdminServer) DeleteRaftACL(context.Context, *DeleteRaftACLRequest) (*emptypb.Empty, error)

func (UnimplementedAdminServer) GetRaftACL added in v0.0.6 

func (UnimplementedAdminServer) GetRaftACL(context.Context, *GetRaftACLRequest) (*RaftACL, error)

func (UnimplementedAdminServer) ListRaftACLs added in v0.0.6 

func (UnimplementedAdminServer) ListRaftACLs(context.Context, *emptypb.Empty) (*RaftACLList, error)

func (UnimplementedAdminServer) PutRaftACL added in v0.0.6 

func (UnimplementedAdminServer) PutRaftACL(context.Context, *RaftACL) (*emptypb.Empty, error)

type UnimplementedMeshServer added in v0.0.5 

type UnimplementedMeshServer struct {
}

UnimplementedMeshServer must be embedded to have forward compatible implementations.

func (UnimplementedMeshServer) GetNode added in v0.0.5 

func (UnimplementedMeshServer) GetNode(context.Context, *GetNodeRequest) (*MeshNode, error)

func (UnimplementedMeshServer) ListNodes added in v0.0.5 

func (UnimplementedMeshServer) ListNodes(context.Context, *emptypb.Empty) (*NodeList, error)

type UnimplementedNodeServer 

type UnimplementedNodeServer struct {
}

UnimplementedNodeServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeServer) GetStatus 

func (UnimplementedNodeServer) GetStatus(context.Context, *GetStatusRequest) (*Status, error)

func (UnimplementedNodeServer) Join 

func (UnimplementedNodeServer) Join(context.Context, *JoinRequest) (*JoinResponse, error)

func (UnimplementedNodeServer) Leave 

func (UnimplementedNodeServer) Leave(context.Context, *LeaveRequest) (*emptypb.Empty, error)

func (UnimplementedNodeServer) NegotiateDataChannel added in v0.0.6 

func (UnimplementedNodeServer) NegotiateDataChannel(Node_NegotiateDataChannelServer) error

type UnimplementedPeerDiscoveryServer 

type UnimplementedPeerDiscoveryServer struct {
}

UnimplementedPeerDiscoveryServer must be embedded to have forward compatible implementations.

func (UnimplementedPeerDiscoveryServer) ListPeers 

func (UnimplementedPeerDiscoveryServer) ListPeers(context.Context, *emptypb.Empty) (*ListRaftPeersResponse, error)

type UnimplementedWebRTCServer added in v0.0.5 

type UnimplementedWebRTCServer struct {
}

UnimplementedWebRTCServer must be embedded to have forward compatible implementations.

func (UnimplementedWebRTCServer) StartDataChannel added in v0.0.5 

func (UnimplementedWebRTCServer) StartDataChannel(WebRTC_StartDataChannelServer) error

type UnsafeAdminServer added in v0.0.6 

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

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

type UnsafeMeshServer added in v0.0.5 

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

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

type UnsafeNodeServer 

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

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

type UnsafePeerDiscoveryServer 

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

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

type UnsafeWebRTCServer added in v0.0.5 

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

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

type WebRTCClient added in v0.0.5 

type WebRTCClient interface {
	// StartDataChannel requests a new WebRTC connection to a node.
	// The client speaks first with the request containing the node ID
	// and where forwarded packets should be sent. The server responds
	// with an offer and STUN servers to be used to establish a WebRTC connection.
	// The client should then respond with an answer to the offer that matches the
	// spec of the DataChannel.CHANNELS enum value.
	//
	// After the offer is accepted, the stream can be used to exchange ICE candidates
	// to speed up the connection process.
	StartDataChannel(ctx context.Context, opts ...grpc.CallOption) (WebRTC_StartDataChannelClient, error)
}

WebRTCClient is the client API for WebRTC 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 NewWebRTCClient added in v0.0.5 

func NewWebRTCClient(cc grpc.ClientConnInterface) WebRTCClient

type WebRTCServer added in v0.0.5 

type WebRTCServer interface {
	// StartDataChannel requests a new WebRTC connection to a node.
	// The client speaks first with the request containing the node ID
	// and where forwarded packets should be sent. The server responds
	// with an offer and STUN servers to be used to establish a WebRTC connection.
	// The client should then respond with an answer to the offer that matches the
	// spec of the DataChannel.CHANNELS enum value.
	//
	// After the offer is accepted, the stream can be used to exchange ICE candidates
	// to speed up the connection process.
	StartDataChannel(WebRTC_StartDataChannelServer) error
	// contains filtered or unexported methods
}

WebRTCServer is the server API for WebRTC service. All implementations must embed UnimplementedWebRTCServer for forward compatibility

type WebRTC_StartDataChannelClient added in v0.0.5 

type WebRTC_StartDataChannelClient interface {
	Send(*StartDataChannelRequest) error
	Recv() (*DataChannelOffer, error)
	grpc.ClientStream
}

type WebRTC_StartDataChannelServer added in v0.0.5 

type WebRTC_StartDataChannelServer interface {
	Send(*DataChannelOffer) error
	Recv() (*StartDataChannelRequest, error)
	grpc.ServerStream
}

type WireguardPeer 

type WireguardPeer struct {

	// id is the ID of the peer.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// public_key is the public key of the peer.
	PublicKey string `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// primary_endpoint is the primary endpoint of the peer, if applicable.
	PrimaryEndpoint string `protobuf:"bytes,3,opt,name=primary_endpoint,json=primaryEndpoint,proto3" json:"primary_endpoint,omitempty"`
	// endpoints are alternative endpoints of the peer, if applicable.
	Endpoints []string `protobuf:"bytes,4,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// address_ipv4 is the private IPv4 wireguard address of the peer.
	AddressIpv4 string `protobuf:"bytes,5,opt,name=address_ipv4,json=addressIpv4,proto3" json:"address_ipv4,omitempty"`
	// address_ipv6 is the private IPv6 wireguard address of the peer.
	AddressIpv6 string `protobuf:"bytes,6,opt,name=address_ipv6,json=addressIpv6,proto3" json:"address_ipv6,omitempty"`
	// contains filtered or unexported fields
}

WireguardPeer is a peer in the Wireguard network.

func (*WireguardPeer) Descriptor deprecated 

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

Deprecated: Use WireguardPeer.ProtoReflect.Descriptor instead.

func (*WireguardPeer) GetAddressIpv4 

func (x *WireguardPeer) GetAddressIpv4() string

func (*WireguardPeer) GetAddressIpv6 

func (x *WireguardPeer) GetAddressIpv6() string

func (*WireguardPeer) GetEndpoints added in v0.0.6 

func (x *WireguardPeer) GetEndpoints() []string

func (*WireguardPeer) GetId added in v0.0.5 

func (x *WireguardPeer) GetId() string

func (*WireguardPeer) GetPrimaryEndpoint added in v0.0.6 

func (x *WireguardPeer) GetPrimaryEndpoint() string

func (*WireguardPeer) GetPublicKey 

func (x *WireguardPeer) GetPublicKey() string

func (*WireguardPeer) ProtoMessage 

func (*WireguardPeer) ProtoMessage()

func (*WireguardPeer) ProtoReflect 

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

func (*WireguardPeer) Reset 

func (x *WireguardPeer) Reset()

func (*WireguardPeer) String 

func (x *WireguardPeer) String() string

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.