v1

package

Go to main page

Versions in this module

v0

v0.0.6

May 26, 2023

Changes in this version

+ const Admin_DeleteRaftACL_FullMethodName

+ const Admin_GetRaftACL_FullMethodName

+ const Admin_ListRaftACLs_FullMethodName

+ const Admin_PutRaftACL_FullMethodName

+ const Node_NegotiateDataChannel_FullMethodName

+ var ACLAction_name = map[int32]string

+ var ACLAction_value = map[string]int32

+ var Admin_ServiceDesc = grpc.ServiceDesc

+ var File_v1_admin_messages_proto protoreflect.FileDescriptor

+ var File_v1_admin_proto protoreflect.FileDescriptor

+ func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer)

+ type ACLAction int32

+ const ACLAction_ALLOW

+ const ACLAction_DENY

+ func (ACLAction) Descriptor() protoreflect.EnumDescriptor

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

+ func (ACLAction) Type() protoreflect.EnumType

+ func (x ACLAction) Enum() *ACLAction

+ func (x ACLAction) Number() protoreflect.EnumNumber

+ func (x ACLAction) String() string

+ type AdminClient interface

+ DeleteRaftACL func(ctx context.Context, in *DeleteRaftACLRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetRaftACL func(ctx context.Context, in *GetRaftACLRequest, opts ...grpc.CallOption) (*RaftACL, error)

+ ListRaftACLs func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RaftACLList, error)

+ PutRaftACL func(ctx context.Context, in *RaftACL, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewAdminClient(cc grpc.ClientConnInterface) AdminClient

+ type AdminServer interface

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

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

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

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

type DataChannelNegotiation

+ Src string

+ func (x *DataChannelNegotiation) GetSrc() string

+ type DeleteRaftACLRequest struct

+ Name string

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

+ func (*DeleteRaftACLRequest) ProtoMessage()

+ func (x *DeleteRaftACLRequest) GetName() string

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

+ func (x *DeleteRaftACLRequest) Reset()

+ func (x *DeleteRaftACLRequest) String() string

type Feature

+ const Feature_MESH_DNS

+ const Feature_METRICS

+ const Feature_TURN_SERVER

+ type GetRaftACLRequest struct

+ Name string

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

+ func (*GetRaftACLRequest) ProtoMessage()

+ func (x *GetRaftACLRequest) GetName() string

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

+ func (x *GetRaftACLRequest) Reset()

+ func (x *GetRaftACLRequest) String() string

+ type GetStatusRequest struct

+ Id string

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

+ func (*GetStatusRequest) ProtoMessage()

+ func (x *GetStatusRequest) GetId() string

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

+ func (x *GetStatusRequest) Reset()

+ func (x *GetStatusRequest) String() string

type JoinRequest

+ Endpoints []string

+ PrimaryEndpoint string

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

+ func (x *JoinRequest) GetPrimaryEndpoint() string

type MeshNode

+ Endpoints []string

+ PrimaryEndpoint string

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

+ func (x *MeshNode) GetPrimaryEndpoint() string

type NodeClient

+ NegotiateDataChannel func(ctx context.Context, opts ...grpc.CallOption) (Node_NegotiateDataChannelClient, error)

type NodeServer

+ NegotiateDataChannel func(Node_NegotiateDataChannelServer) error

+ type Node_NegotiateDataChannelClient interface

+ Recv func() (*DataChannelNegotiation, error)

+ Send func(*DataChannelNegotiation) error

+ type Node_NegotiateDataChannelServer interface

+ Recv func() (*DataChannelNegotiation, error)

+ Send func(*DataChannelNegotiation) error

+ type RaftACL struct

+ Action ACLAction

+ Name string

+ Patterns []string

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

+ func (*RaftACL) ProtoMessage()

+ func (x *RaftACL) GetAction() ACLAction

+ func (x *RaftACL) GetName() string

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

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

+ func (x *RaftACL) Reset()

+ func (x *RaftACL) String() string

+ type RaftACLList struct

+ Items []*RaftACL

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

+ func (*RaftACLList) ProtoMessage()

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

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

+ func (x *RaftACLList) Reset()

+ func (x *RaftACLList) String() string

+ type UnimplementedAdminServer struct

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

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

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

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

type UnimplementedNodeServer

+ func (UnimplementedNodeServer) NegotiateDataChannel(Node_NegotiateDataChannelServer) error

+ type UnsafeAdminServer interface

type WireguardPeer

+ Endpoints []string

+ PrimaryEndpoint string

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

+ func (x *WireguardPeer) GetPrimaryEndpoint() string

v0.0.5

May 24, 2023

Changes in this version

+ const Mesh_GetNode_FullMethodName

+ const Mesh_ListNodes_FullMethodName

+ const WebRTC_StartDataChannel_FullMethodName

+ var File_v1_mesh_messages_proto protoreflect.FileDescriptor

+ var File_v1_mesh_proto protoreflect.FileDescriptor

+ var File_v1_webrtc_messages_proto protoreflect.FileDescriptor

+ var File_v1_webrtc_proto protoreflect.FileDescriptor

+ var Mesh_ServiceDesc = grpc.ServiceDesc

+ var SQLParameterType_name = map[int32]string

+ var SQLParameterType_value = map[string]int32

+ var WebRTC_ServiceDesc = grpc.ServiceDesc

+ func RegisterMeshServer(s grpc.ServiceRegistrar, srv MeshServer)

+ func RegisterWebRTCServer(s grpc.ServiceRegistrar, srv WebRTCServer)

type Feature

+ const Feature_MESH_API

type JoinRequest

+ WireguardPort int32

+ func (x *JoinRequest) GetWireguardPort() int32

+ type MeshClient interface

+ GetNode func(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*MeshNode, error)

+ ListNodes func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NodeList, error)

+ func NewMeshClient(cc grpc.ClientConnInterface) MeshClient

type MeshNode

+ GrpcPort int32

+ RaftPort int32

+ WireguardPort int32

+ func (x *MeshNode) GetGrpcPort() int32

+ func (x *MeshNode) GetRaftPort() int32

+ func (x *MeshNode) GetWireguardPort() int32

+ type MeshServer interface

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

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

type RaftApplyResponse

+ Error string

+ ExecResult *SQLExecResult

+ QueryResult *SQLQueryResult

+ func (x *RaftApplyResponse) GetExecResult() *SQLExecResult

+ func (x *RaftApplyResponse) GetQueryResult() *SQLQueryResult

type RaftLogEntry

+ SqlExec *SQLExec

+ SqlQuery *SQLQuery

type SQLParameter

+ Bool bool

+ Bytes []byte

+ Double float64

+ Int64 int64

+ Str string

+ Time *timestamppb.Timestamp

+ Type SQLParameterType

+ func (x *SQLParameter) GetType() SQLParameterType

+ type SQLParameterType int32

+ const SQLParameterType_SQL_PARAM_BOOL

+ const SQLParameterType_SQL_PARAM_BYTES

+ const SQLParameterType_SQL_PARAM_DOUBLE

+ const SQLParameterType_SQL_PARAM_INT64

+ const SQLParameterType_SQL_PARAM_NULL

+ const SQLParameterType_SQL_PARAM_STRING

+ const SQLParameterType_SQL_PARAM_TIME

+ const SQLParameterType_SQL_PARAM_UNKNOWN

+ func (SQLParameterType) Descriptor() protoreflect.EnumDescriptor

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

+ func (SQLParameterType) Type() protoreflect.EnumType

+ func (x SQLParameterType) Enum() *SQLParameterType

+ func (x SQLParameterType) Number() protoreflect.EnumNumber

+ func (x SQLParameterType) String() string

+ type UnimplementedMeshServer struct

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

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

+ type UnimplementedWebRTCServer struct

+ func (UnimplementedWebRTCServer) StartDataChannel(WebRTC_StartDataChannelServer) error

+ type UnsafeMeshServer interface

+ type UnsafeWebRTCServer interface

+ type WebRTCClient interface

+ StartDataChannel func(ctx context.Context, opts ...grpc.CallOption) (WebRTC_StartDataChannelClient, error)

+ func NewWebRTCClient(cc grpc.ClientConnInterface) WebRTCClient

+ type WebRTCServer interface

+ StartDataChannel func(WebRTC_StartDataChannelServer) error

+ type WebRTC_StartDataChannelClient interface

+ Recv func() (*DataChannelOffer, error)

+ Send func(*StartDataChannelRequest) error

+ type WebRTC_StartDataChannelServer interface

+ Recv func() (*StartDataChannelRequest, error)

+ Send func(*DataChannelOffer) error

type WireguardPeer

+ Id string

+ func (x *WireguardPeer) GetId() string

v0.0.4

May 24, 2023

Changes in this version

type MeshNode

+ ClusterStatus ClusterStatus

+ func (x *MeshNode) GetClusterStatus() ClusterStatus

type Status

+ ClusterStatus ClusterStatus

+ Id string

+ WireguardPeers uint32

+ func (x *Status) GetClusterStatus() ClusterStatus

+ func (x *Status) GetId() string

+ func (x *Status) GetWireguardPeers() uint32

v0.0.3

May 23, 2023

Changes in this version

type ClusterStatus

+ const ClusterStatus_CLUSTER_LEADER

+ const ClusterStatus_CLUSTER_NON_VOTER

+ const ClusterStatus_CLUSTER_STATUS_UNKNOWN

+ const ClusterStatus_CLUSTER_VOTER

v0.0.2

May 23, 2023

Changes in this version

+ var ClusterStatus_name = map[int32]string

+ var ClusterStatus_value = map[string]int32

+ type ClusterStatus int32

+ const ClusterStatus_CLUSTER_STATUS_NONE

+ const ClusterStatus_LEADER

+ const ClusterStatus_NON_VOTER

+ const ClusterStatus_VOTER

+ func (ClusterStatus) Descriptor() protoreflect.EnumDescriptor

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

+ func (ClusterStatus) Type() protoreflect.EnumType

+ func (x ClusterStatus) Enum() *ClusterStatus

+ func (x ClusterStatus) Number() protoreflect.EnumNumber

+ func (x ClusterStatus) String() string

type Feature

+ const Feature_FEATURE_NONE

type MeshNode

+ Status ClusterStatus

+ func (x *MeshNode) GetStatus() ClusterStatus

type Status

+ Status ClusterStatus

+ func (x *Status) GetStatus() ClusterStatus

v0.0.1

May 23, 2023

Changes in this version

+ const Node_GetFeatures_FullMethodName

+ const Node_GetNode_FullMethodName

+ const Node_GetStatus_FullMethodName

+ const Node_Join_FullMethodName

+ const Node_Leave_FullMethodName

+ const Node_ListNodes_FullMethodName

+ const Node_StartDataChannel_FullMethodName

+ const PeerDiscovery_ListPeers_FullMethodName

+ const PeerDiscovery_WatchPeers_FullMethodName

+ var DataChannel_name = map[int32]string

+ var DataChannel_value = map[string]int32

+ var Feature_name = map[int32]string

+ var Feature_value = map[string]int32

+ var File_v1_node_messages_proto protoreflect.FileDescriptor

+ var File_v1_node_metrics_proto protoreflect.FileDescriptor

+ var File_v1_node_proto protoreflect.FileDescriptor

+ var File_v1_node_raft_proto protoreflect.FileDescriptor

+ var File_v1_peer_discovery_proto protoreflect.FileDescriptor

+ var Node_ServiceDesc = grpc.ServiceDesc

+ var PeerDiscovery_ServiceDesc = grpc.ServiceDesc

+ var RaftCommandType_name = map[int32]string

+ var RaftCommandType_value = map[string]int32

+ func RegisterNodeServer(s grpc.ServiceRegistrar, srv NodeServer)

+ func RegisterPeerDiscoveryServer(s grpc.ServiceRegistrar, srv PeerDiscoveryServer)

+ type CPUTimes struct

+ Idle string

+ IoWait string

+ Irq string

+ LoadAverage *LoadAverage

+ Nice string

+ SoftIrq string

+ Steal string

+ System string

+ User string

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

+ func (*CPUTimes) ProtoMessage()

+ func (x *CPUTimes) GetIdle() string

+ func (x *CPUTimes) GetIoWait() string

+ func (x *CPUTimes) GetIrq() string

+ func (x *CPUTimes) GetLoadAverage() *LoadAverage

+ func (x *CPUTimes) GetNice() string

+ func (x *CPUTimes) GetSoftIrq() string

+ func (x *CPUTimes) GetSteal() string

+ func (x *CPUTimes) GetSystem() string

+ func (x *CPUTimes) GetUser() string

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

+ func (x *CPUTimes) Reset()

+ func (x *CPUTimes) String() string

+ type DataChannel int32

+ const DataChannel_CHANNELS

+ const DataChannel_CONNECTIONS

+ func (DataChannel) Descriptor() protoreflect.EnumDescriptor

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

+ func (DataChannel) Type() protoreflect.EnumType

+ func (x DataChannel) Enum() *DataChannel

+ func (x DataChannel) Number() protoreflect.EnumNumber

+ func (x DataChannel) String() string

+ type DataChannelNegotiation struct

+ Answer string

+ Candidate string

+ Dst string

+ Offer string

+ Port uint32

+ Proto string

+ StunServers []string

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

+ func (*DataChannelNegotiation) ProtoMessage()

+ func (x *DataChannelNegotiation) GetAnswer() string

+ func (x *DataChannelNegotiation) GetCandidate() string

+ func (x *DataChannelNegotiation) GetDst() string

+ func (x *DataChannelNegotiation) GetOffer() string

+ func (x *DataChannelNegotiation) GetPort() uint32

+ func (x *DataChannelNegotiation) GetProto() string

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

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

+ func (x *DataChannelNegotiation) Reset()

+ func (x *DataChannelNegotiation) String() string

+ type DataChannelOffer struct

+ Candidate string

+ Offer string

+ StunServers []string

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

+ func (*DataChannelOffer) ProtoMessage()

+ func (x *DataChannelOffer) GetCandidate() string

+ func (x *DataChannelOffer) GetOffer() string

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

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

+ func (x *DataChannelOffer) Reset()

+ func (x *DataChannelOffer) String() string

+ type DiskInfo struct

+ Device string

+ FilesystemPath string

+ Free uint64

+ InodesFree uint64

+ InodesTotal uint64

+ InodesUsed uint64

+ InodesUsedPercent float32

+ Total uint64

+ Used uint64

+ UsedPercent float32

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

+ func (*DiskInfo) ProtoMessage()

+ func (x *DiskInfo) GetDevice() string

+ func (x *DiskInfo) GetFilesystemPath() string

+ func (x *DiskInfo) GetFree() uint64

+ func (x *DiskInfo) GetInodesFree() uint64

+ func (x *DiskInfo) GetInodesTotal() uint64

+ func (x *DiskInfo) GetInodesUsed() uint64

+ func (x *DiskInfo) GetInodesUsedPercent() float32

+ func (x *DiskInfo) GetTotal() uint64

+ func (x *DiskInfo) GetUsed() uint64

+ func (x *DiskInfo) GetUsedPercent() float32

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

+ func (x *DiskInfo) Reset()

+ func (x *DiskInfo) String() string

+ type Feature int32

+ const Feature_ICE_NEGOTIATION

+ const Feature_LEADER_PROXY

+ const Feature_METRICS_GRPC

+ const Feature_METRICS_NODE

+ const Feature_NODES

+ const Feature_NONE

+ const Feature_PEER_DISCOVERY

+ func (Feature) Descriptor() protoreflect.EnumDescriptor

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

+ func (Feature) Type() protoreflect.EnumType

+ func (x Feature) Enum() *Feature

+ func (x Feature) Number() protoreflect.EnumNumber

+ func (x Feature) String() string

+ type Features struct

+ Features []Feature

+ func (*Features) Descriptor() ([]byte, []int)

+ func (*Features) ProtoMessage()

+ func (x *Features) GetFeatures() []Feature

+ func (x *Features) ProtoReflect() protoreflect.Message

+ func (x *Features) Reset()

+ func (x *Features) String() string

+ type GetNodeRequest struct

+ Id string

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

+ func (*GetNodeRequest) ProtoMessage()

+ func (x *GetNodeRequest) GetId() string

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

+ func (x *GetNodeRequest) Reset()

+ func (x *GetNodeRequest) String() string

+ type HostInfo struct

+ Architecture string

+ BootTime string

+ Containerized bool

+ Hostname string

+ Ips []string

+ KernelVersion string

+ Macs []string

+ Os *OSInfo

+ Timezone string

+ Uptime string

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

+ func (*HostInfo) ProtoMessage()

+ func (x *HostInfo) GetArchitecture() string

+ func (x *HostInfo) GetBootTime() string

+ func (x *HostInfo) GetContainerized() bool

+ func (x *HostInfo) GetHostname() string

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

+ func (x *HostInfo) GetKernelVersion() string

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

+ func (x *HostInfo) GetOs() *OSInfo

+ func (x *HostInfo) GetTimezone() string

+ func (x *HostInfo) GetUptime() string

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

+ func (x *HostInfo) Reset()

+ func (x *HostInfo) String() string

+ type HostMetrics struct

+ Cpu *CPUTimes

+ Disks []*DiskInfo

+ Host *HostInfo

+ Memory *MemoryInfo

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

+ func (*HostMetrics) ProtoMessage()

+ func (x *HostMetrics) GetCpu() *CPUTimes

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

+ func (x *HostMetrics) GetHost() *HostInfo

+ func (x *HostMetrics) GetMemory() *MemoryInfo

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

+ func (x *HostMetrics) Reset()

+ func (x *HostMetrics) String() string

+ type JoinRequest struct

+ AllowedIps []string

+ AsVoter bool

+ AssignAsn bool

+ AssignIpv4 bool

+ AvailableZones []string

+ Endpoint string

+ GrpcPort int32

+ Id string

+ PreferRaftIpv6 bool

+ PublicKey string

+ RaftPort int32

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

+ func (*JoinRequest) ProtoMessage()

+ func (x *JoinRequest) GetAllowedIps() []string

+ func (x *JoinRequest) GetAsVoter() bool

+ func (x *JoinRequest) GetAssignAsn() bool

+ func (x *JoinRequest) GetAssignIpv4() bool

+ func (x *JoinRequest) GetAvailableZones() []string

+ func (x *JoinRequest) GetEndpoint() string

+ func (x *JoinRequest) GetGrpcPort() int32

+ func (x *JoinRequest) GetId() string

+ func (x *JoinRequest) GetPreferRaftIpv6() bool

+ func (x *JoinRequest) GetPublicKey() string

+ func (x *JoinRequest) GetRaftPort() int32

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

+ func (x *JoinRequest) Reset()

+ func (x *JoinRequest) String() string

+ type JoinResponse struct

+ AddressIpv4 string

+ Asn uint32

+ NetworkIpv6 string

+ Peers []*WireguardPeer

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

+ func (*JoinResponse) ProtoMessage()

+ func (x *JoinResponse) GetAddressIpv4() string

+ func (x *JoinResponse) GetAsn() uint32

+ func (x *JoinResponse) GetNetworkIpv6() string

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

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

+ func (x *JoinResponse) Reset()

+ func (x *JoinResponse) String() string

+ type LeaveRequest struct

+ Id string

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

+ func (*LeaveRequest) ProtoMessage()

+ func (x *LeaveRequest) GetId() string

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

+ func (x *LeaveRequest) Reset()

+ func (x *LeaveRequest) String() string

+ type ListRaftPeersResponse struct

+ Peers []*RaftPeer

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

+ func (*ListRaftPeersResponse) ProtoMessage()

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

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

+ func (x *ListRaftPeersResponse) Reset()

+ func (x *ListRaftPeersResponse) String() string

+ type LoadAverage struct

+ Fifteen float32

+ Five float32

+ One float32

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

+ func (*LoadAverage) ProtoMessage()

+ func (x *LoadAverage) GetFifteen() float32

+ func (x *LoadAverage) GetFive() float32

+ func (x *LoadAverage) GetOne() float32

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

+ func (x *LoadAverage) Reset()

+ func (x *LoadAverage) String() string

+ type MemoryInfo struct

+ Available uint64

+ Free uint64

+ Total uint64

+ Used uint64

+ VirtualFree uint64

+ VirtualTotal uint64

+ VirtualUsed uint64

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

+ func (*MemoryInfo) ProtoMessage()

+ func (x *MemoryInfo) GetAvailable() uint64

+ func (x *MemoryInfo) GetFree() uint64

+ func (x *MemoryInfo) GetTotal() uint64

+ func (x *MemoryInfo) GetUsed() uint64

+ func (x *MemoryInfo) GetVirtualFree() uint64

+ func (x *MemoryInfo) GetVirtualTotal() uint64

+ func (x *MemoryInfo) GetVirtualUsed() uint64

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

+ func (x *MemoryInfo) Reset()

+ func (x *MemoryInfo) String() string

+ type MeshNode struct

+ AllowedIps []string

+ Asn uint32

+ AvailableZones []string

+ CreatedAt *timestamppb.Timestamp

+ Endpoint string

+ Id string

+ PrivateIpv4 string

+ PrivateIpv6 string

+ PublicKey string

+ UpdatedAt *timestamppb.Timestamp

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

+ func (*MeshNode) ProtoMessage()

+ func (x *MeshNode) GetAllowedIps() []string

+ func (x *MeshNode) GetAsn() uint32

+ func (x *MeshNode) GetAvailableZones() []string

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

+ func (x *MeshNode) GetEndpoint() string

+ func (x *MeshNode) GetId() string

+ func (x *MeshNode) GetPrivateIpv4() string

+ func (x *MeshNode) GetPrivateIpv6() string

+ func (x *MeshNode) GetPublicKey() string

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

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

+ func (x *MeshNode) Reset()

+ func (x *MeshNode) String() string

+ type NodeClient interface

+ GetFeatures func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Features, error)

+ GetNode func(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*MeshNode, error)

+ GetStatus func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Status, error)

+ Join func(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)

+ Leave func(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ ListNodes func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NodeList, error)

+ StartDataChannel func(ctx context.Context, opts ...grpc.CallOption) (Node_StartDataChannelClient, error)

+ func NewNodeClient(cc grpc.ClientConnInterface) NodeClient

+ type NodeList struct

+ Nodes []*MeshNode

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

+ func (*NodeList) ProtoMessage()

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

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

+ func (x *NodeList) Reset()

+ func (x *NodeList) String() string

+ type NodeMetrics struct

+ AddressV4 string

+ AddressV6 string

+ DeviceName string

+ ListenPort int32

+ Peers []*PeerMetrics

+ PublicKey string

+ System *HostMetrics

+ TotalReceiveBytes uint64

+ TotalTransmitBytes uint64

+ Type string

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

+ func (*NodeMetrics) ProtoMessage()

+ func (x *NodeMetrics) GetAddressV4() string

+ func (x *NodeMetrics) GetAddressV6() string

+ func (x *NodeMetrics) GetDeviceName() string

+ func (x *NodeMetrics) GetListenPort() int32

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

+ func (x *NodeMetrics) GetPublicKey() string

+ func (x *NodeMetrics) GetSystem() *HostMetrics

+ func (x *NodeMetrics) GetTotalReceiveBytes() uint64

+ func (x *NodeMetrics) GetTotalTransmitBytes() uint64

+ func (x *NodeMetrics) GetType() string

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

+ func (x *NodeMetrics) Reset()

+ func (x *NodeMetrics) String() string

+ type NodeServer interface

+ GetFeatures func(context.Context, *emptypb.Empty) (*Features, error)

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

+ GetStatus func(context.Context, *emptypb.Empty) (*Status, error)

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

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

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

+ StartDataChannel func(Node_StartDataChannelServer) error

+ type Node_StartDataChannelClient interface

+ Recv func() (*DataChannelOffer, error)

+ Send func(*StartDataChannelRequest) error

+ type Node_StartDataChannelServer interface

+ Recv func() (*StartDataChannelRequest, error)

+ Send func(*DataChannelOffer) error

+ type OSInfo struct

+ Build string

+ Codename string

+ Family string

+ Major int64

+ Minor int64

+ Name string

+ Patch int64

+ Platform string

+ Type string

+ Version string

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

+ func (*OSInfo) ProtoMessage()

+ func (x *OSInfo) GetBuild() string

+ func (x *OSInfo) GetCodename() string

+ func (x *OSInfo) GetFamily() string

+ func (x *OSInfo) GetMajor() int64

+ func (x *OSInfo) GetMinor() int64

+ func (x *OSInfo) GetName() string

+ func (x *OSInfo) GetPatch() int64

+ func (x *OSInfo) GetPlatform() string

+ func (x *OSInfo) GetType() string

+ func (x *OSInfo) GetVersion() string

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

+ func (x *OSInfo) Reset()

+ func (x *OSInfo) String() string

+ type PeerDiscoveryClient interface

+ ListPeers func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListRaftPeersResponse, error)

+ WatchPeers func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (PeerDiscovery_WatchPeersClient, error)

+ func NewPeerDiscoveryClient(cc grpc.ClientConnInterface) PeerDiscoveryClient

+ type PeerDiscoveryServer interface

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

+ WatchPeers func(*emptypb.Empty, PeerDiscovery_WatchPeersServer) error

+ type PeerDiscovery_WatchPeersClient interface

+ Recv func() (*RaftPeer, error)

+ type PeerDiscovery_WatchPeersServer interface

+ Send func(*RaftPeer) error

+ type PeerMetrics struct

+ AllowedIps []string

+ Endpoint string

+ LastHandshakeTime string

+ PersistentKeepAlive string

+ ProtocolVersion int64

+ PublicKey string

+ ReceiveBytes uint64

+ TransmitBytes uint64

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

+ func (*PeerMetrics) ProtoMessage()

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

+ func (x *PeerMetrics) GetEndpoint() string

+ func (x *PeerMetrics) GetLastHandshakeTime() string

+ func (x *PeerMetrics) GetPersistentKeepAlive() string

+ func (x *PeerMetrics) GetProtocolVersion() int64

+ func (x *PeerMetrics) GetPublicKey() string

+ func (x *PeerMetrics) GetReceiveBytes() uint64

+ func (x *PeerMetrics) GetTransmitBytes() uint64

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

+ func (x *PeerMetrics) Reset()

+ func (x *PeerMetrics) String() string

+ type RaftApplyResponse struct

+ Result isRaftApplyResponse_Result

+ Time string

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

+ func (*RaftApplyResponse) ProtoMessage()

+ func (m *RaftApplyResponse) GetResult() isRaftApplyResponse_Result

+ func (x *RaftApplyResponse) GetError() string

+ func (x *RaftApplyResponse) GetExec() *SQLExecResult

+ func (x *RaftApplyResponse) GetRows() *SQLQueryResult

+ func (x *RaftApplyResponse) GetTime() string

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

+ func (x *RaftApplyResponse) Reset()

+ func (x *RaftApplyResponse) String() string

+ type RaftApplyResponse_Error struct

+ Error string

+ type RaftApplyResponse_Exec struct

+ Exec *SQLExecResult

+ type RaftApplyResponse_Rows struct

+ Rows *SQLQueryResult

+ type RaftCommandType int32

+ const RaftCommandType_EXECUTE

+ const RaftCommandType_QUERY

+ const RaftCommandType_UNKNOWN

+ func (RaftCommandType) Descriptor() protoreflect.EnumDescriptor

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

+ func (RaftCommandType) Type() protoreflect.EnumType

+ func (x RaftCommandType) Enum() *RaftCommandType

+ func (x RaftCommandType) Number() protoreflect.EnumNumber

+ func (x RaftCommandType) String() string

+ type RaftLogEntry struct

+ Data isRaftLogEntry_Data

+ Type RaftCommandType

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

+ func (*RaftLogEntry) ProtoMessage()

+ func (m *RaftLogEntry) GetData() isRaftLogEntry_Data

+ func (x *RaftLogEntry) GetSqlExec() *SQLExec

+ func (x *RaftLogEntry) GetSqlQuery() *SQLQuery

+ func (x *RaftLogEntry) GetType() RaftCommandType

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

+ func (x *RaftLogEntry) Reset()

+ func (x *RaftLogEntry) String() string

+ type RaftLogEntry_SqlExec struct

+ SqlExec *SQLExec

+ type RaftLogEntry_SqlQuery struct

+ SqlQuery *SQLQuery

+ type RaftPeer struct

+ Address string

+ Id string

+ Leader bool

+ Voter bool

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

+ func (*RaftPeer) ProtoMessage()

+ func (x *RaftPeer) GetAddress() string

+ func (x *RaftPeer) GetId() string

+ func (x *RaftPeer) GetLeader() bool

+ func (x *RaftPeer) GetVoter() bool

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

+ func (x *RaftPeer) Reset()

+ func (x *RaftPeer) String() string

+ type SQLExec struct

+ Statement *SQLStatement

+ Transaction bool

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

+ func (*SQLExec) ProtoMessage()

+ func (x *SQLExec) GetStatement() *SQLStatement

+ func (x *SQLExec) GetTransaction() bool

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

+ func (x *SQLExec) Reset()

+ func (x *SQLExec) String() string

+ type SQLExecResult struct

+ Error string

+ LastInsertId int64

+ RowsAffected int64

+ Time string

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

+ func (*SQLExecResult) ProtoMessage()

+ func (x *SQLExecResult) GetError() string

+ func (x *SQLExecResult) GetLastInsertId() int64

+ func (x *SQLExecResult) GetRowsAffected() int64

+ func (x *SQLExecResult) GetTime() string

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

+ func (x *SQLExecResult) Reset()

+ func (x *SQLExecResult) String() string

+ type SQLParameter struct

+ Name string

+ Value isSQLParameter_Value

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

+ func (*SQLParameter) ProtoMessage()

+ func (m *SQLParameter) GetValue() isSQLParameter_Value

+ func (x *SQLParameter) GetBool() bool

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

+ func (x *SQLParameter) GetDouble() float64

+ func (x *SQLParameter) GetInt64() int64

+ func (x *SQLParameter) GetName() string

+ func (x *SQLParameter) GetStr() string

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

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

+ func (x *SQLParameter) Reset()

+ func (x *SQLParameter) String() string

+ type SQLParameter_Bool struct

+ Bool bool

+ type SQLParameter_Bytes struct

+ Bytes []byte

+ type SQLParameter_Double struct

+ Double float64

+ type SQLParameter_Int64 struct

+ Int64 int64

+ type SQLParameter_Str struct

+ Str string

+ type SQLParameter_Time struct

+ Time *timestamppb.Timestamp

+ type SQLQuery struct

+ Statement *SQLStatement

+ Transaction bool

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

+ func (*SQLQuery) ProtoMessage()

+ func (x *SQLQuery) GetStatement() *SQLStatement

+ func (x *SQLQuery) GetTransaction() bool

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

+ func (x *SQLQuery) Reset()

+ func (x *SQLQuery) String() string

+ type SQLQueryResult struct

+ Columns []string

+ Error string

+ Time string

+ Types []string

+ Values []*SQLValues

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

+ func (*SQLQueryResult) ProtoMessage()

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

+ func (x *SQLQueryResult) GetError() string

+ func (x *SQLQueryResult) GetTime() string

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

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

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

+ func (x *SQLQueryResult) Reset()

+ func (x *SQLQueryResult) String() string

+ type SQLStatement struct

+ Parameters []*SQLParameter

+ Sql string

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

+ func (*SQLStatement) ProtoMessage()

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

+ func (x *SQLStatement) GetSql() string

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

+ func (x *SQLStatement) Reset()

+ func (x *SQLStatement) String() string

+ type SQLValues struct

+ Values []*SQLParameter

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

+ func (*SQLValues) ProtoMessage()

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

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

+ func (x *SQLValues) Reset()

+ func (x *SQLValues) String() string

+ type StartDataChannelRequest struct

+ Answer string

+ Candidate string

+ Dst string

+ NodeId string

+ Port uint32

+ Proto string

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

+ func (*StartDataChannelRequest) ProtoMessage()

+ func (x *StartDataChannelRequest) GetAnswer() string

+ func (x *StartDataChannelRequest) GetCandidate() string

+ func (x *StartDataChannelRequest) GetDst() string

+ func (x *StartDataChannelRequest) GetNodeId() string

+ func (x *StartDataChannelRequest) GetPort() uint32

+ func (x *StartDataChannelRequest) GetProto() string

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

+ func (x *StartDataChannelRequest) Reset()

+ func (x *StartDataChannelRequest) String() string

+ type Status struct

+ BuildDate string

+ Commit string

+ CurrentLeader string

+ Features []Feature

+ Leader bool

+ Peers uint32

+ StartedAt *timestamppb.Timestamp

+ Uptime string

+ Version string

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

+ func (*Status) ProtoMessage()

+ func (x *Status) GetBuildDate() string

+ func (x *Status) GetCommit() string

+ func (x *Status) GetCurrentLeader() string

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

+ func (x *Status) GetLeader() bool

+ func (x *Status) GetPeers() uint32

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

+ func (x *Status) GetUptime() string

+ func (x *Status) GetVersion() string

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

+ func (x *Status) Reset()

+ func (x *Status) String() string

+ type UnimplementedNodeServer struct

+ func (UnimplementedNodeServer) GetFeatures(context.Context, *emptypb.Empty) (*Features, error)

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

+ func (UnimplementedNodeServer) GetStatus(context.Context, *emptypb.Empty) (*Status, error)

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

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

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

+ func (UnimplementedNodeServer) StartDataChannel(Node_StartDataChannelServer) error

+ type UnimplementedPeerDiscoveryServer struct

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

+ func (UnimplementedPeerDiscoveryServer) WatchPeers(*emptypb.Empty, PeerDiscovery_WatchPeersServer) error

+ type UnsafeNodeServer interface

+ type UnsafePeerDiscoveryServer interface

+ type WireguardPeer struct

+ AddressIpv4 string

+ AddressIpv6 string

+ AllowedIps []string

+ Asn uint32

+ Endpoint string

+ PublicKey string

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

+ func (*WireguardPeer) ProtoMessage()

+ func (x *WireguardPeer) GetAddressIpv4() string

+ func (x *WireguardPeer) GetAddressIpv6() string

+ func (x *WireguardPeer) GetAllowedIps() []string

+ func (x *WireguardPeer) GetAsn() uint32

+ func (x *WireguardPeer) GetEndpoint() string

+ func (x *WireguardPeer) GetPublicKey() string

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

+ func (x *WireguardPeer) Reset()

+ func (x *WireguardPeer) String() string

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