v1

package

Go to main page

Versions in this module

v0

v0.9.1

Oct 24, 2023

Changes in this version

+ type NodeConfiguration struct

+ AddressIPv4 string

+ AddressIPv6 string

+ Domain string

+ Id string

+ NetworkIPv4 string

+ NetworkIPv6 string

+ PrivateKey []byte

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

+ func (*NodeConfiguration) ProtoMessage()

+ func (in *NodeConfiguration) DeepCopy() *NodeConfiguration

+ func (in *NodeConfiguration) DeepCopyInterface() interface{}

+ func (in *NodeConfiguration) DeepCopyInto(out *NodeConfiguration)

+ func (m *NodeConfiguration) Validate() error

+ func (m *NodeConfiguration) ValidateAll() error

+ func (x *NodeConfiguration) GetAddressIPv4() string

+ func (x *NodeConfiguration) GetAddressIPv6() string

+ func (x *NodeConfiguration) GetDomain() string

+ func (x *NodeConfiguration) GetId() string

+ func (x *NodeConfiguration) GetNetworkIPv4() string

+ func (x *NodeConfiguration) GetNetworkIPv6() string

+ func (x *NodeConfiguration) GetPrivateKey() []byte

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

+ func (x *NodeConfiguration) Reset()

+ func (x *NodeConfiguration) String() string

+ type NodeConfigurationMultiError []error

+ func (m NodeConfigurationMultiError) AllErrors() []error

+ func (m NodeConfigurationMultiError) Error() string

+ type NodeConfigurationValidationError struct

+ func (e NodeConfigurationValidationError) Cause() error

+ func (e NodeConfigurationValidationError) Error() string

+ func (e NodeConfigurationValidationError) ErrorName() string

+ func (e NodeConfigurationValidationError) Field() string

+ func (e NodeConfigurationValidationError) Key() bool

+ func (e NodeConfigurationValidationError) Reason() string

type PluginConfiguration

+ NodeConfig *NodeConfiguration

+ func (x *PluginConfiguration) GetNodeConfig() *NodeConfiguration

v0.9.0

Oct 11, 2023

Changes in this version

+ const Registrar_Lookup_FullMethodName

+ const Registrar_Register_FullMethodName

+ var File_v1_registrar_proto protoreflect.FileDescriptor

+ var Registrar_ServiceDesc = grpc.ServiceDesc

+ func RegisterRegistrarServer(s grpc.ServiceRegistrar, srv RegistrarServer)

type Feature

+ const Feature_REGISTRAR

+ type LookupRequest struct

+ Alias string

+ Id string

+ PublicKey string

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

+ func (*LookupRequest) ProtoMessage()

+ func (in *LookupRequest) DeepCopy() *LookupRequest

+ func (in *LookupRequest) DeepCopyInterface() interface{}

+ func (in *LookupRequest) DeepCopyInto(out *LookupRequest)

+ func (m *LookupRequest) Validate() error

+ func (m *LookupRequest) ValidateAll() error

+ func (x *LookupRequest) GetAlias() string

+ func (x *LookupRequest) GetId() string

+ func (x *LookupRequest) GetPublicKey() string

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

+ func (x *LookupRequest) Reset()

+ func (x *LookupRequest) String() string

+ type LookupRequestMultiError []error

+ func (m LookupRequestMultiError) AllErrors() []error

+ func (m LookupRequestMultiError) Error() string

+ type LookupRequestValidationError struct

+ func (e LookupRequestValidationError) Cause() error

+ func (e LookupRequestValidationError) Error() string

+ func (e LookupRequestValidationError) ErrorName() string

+ func (e LookupRequestValidationError) Field() string

+ func (e LookupRequestValidationError) Key() bool

+ func (e LookupRequestValidationError) Reason() string

+ type LookupResponse struct

+ Alias string

+ Id string

+ PublicKey string

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

+ func (*LookupResponse) ProtoMessage()

+ func (in *LookupResponse) DeepCopy() *LookupResponse

+ func (in *LookupResponse) DeepCopyInterface() interface{}

+ func (in *LookupResponse) DeepCopyInto(out *LookupResponse)

+ func (m *LookupResponse) Validate() error

+ func (m *LookupResponse) ValidateAll() error

+ func (x *LookupResponse) GetAlias() string

+ func (x *LookupResponse) GetId() string

+ func (x *LookupResponse) GetPublicKey() string

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

+ func (x *LookupResponse) Reset()

+ func (x *LookupResponse) String() string

+ type LookupResponseMultiError []error

+ func (m LookupResponseMultiError) AllErrors() []error

+ func (m LookupResponseMultiError) Error() string

+ type LookupResponseValidationError struct

+ func (e LookupResponseValidationError) Cause() error

+ func (e LookupResponseValidationError) Error() string

+ func (e LookupResponseValidationError) ErrorName() string

+ func (e LookupResponseValidationError) Field() string

+ func (e LookupResponseValidationError) Key() bool

+ func (e LookupResponseValidationError) Reason() string

+ type RegisterRequest struct

+ Alias string

+ Expiry *timestamppb.Timestamp

+ PublicKey string

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

+ func (*RegisterRequest) ProtoMessage()

+ func (in *RegisterRequest) DeepCopy() *RegisterRequest

+ func (in *RegisterRequest) DeepCopyInterface() interface{}

+ func (in *RegisterRequest) DeepCopyInto(out *RegisterRequest)

+ func (m *RegisterRequest) Validate() error

+ func (m *RegisterRequest) ValidateAll() error

+ func (x *RegisterRequest) GetAlias() string

+ func (x *RegisterRequest) GetExpiry() *timestamppb.Timestamp

+ func (x *RegisterRequest) GetPublicKey() string

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

+ func (x *RegisterRequest) Reset()

+ func (x *RegisterRequest) String() string

+ type RegisterRequestMultiError []error

+ func (m RegisterRequestMultiError) AllErrors() []error

+ func (m RegisterRequestMultiError) Error() string

+ type RegisterRequestValidationError struct

+ func (e RegisterRequestValidationError) Cause() error

+ func (e RegisterRequestValidationError) Error() string

+ func (e RegisterRequestValidationError) ErrorName() string

+ func (e RegisterRequestValidationError) Field() string

+ func (e RegisterRequestValidationError) Key() bool

+ func (e RegisterRequestValidationError) Reason() string

+ type RegisterResponse struct

+ Id string

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

+ func (*RegisterResponse) ProtoMessage()

+ func (in *RegisterResponse) DeepCopy() *RegisterResponse

+ func (in *RegisterResponse) DeepCopyInterface() interface{}

+ func (in *RegisterResponse) DeepCopyInto(out *RegisterResponse)

+ func (m *RegisterResponse) Validate() error

+ func (m *RegisterResponse) ValidateAll() error

+ func (x *RegisterResponse) GetId() string

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

+ func (x *RegisterResponse) Reset()

+ func (x *RegisterResponse) String() string

+ type RegisterResponseMultiError []error

+ func (m RegisterResponseMultiError) AllErrors() []error

+ func (m RegisterResponseMultiError) Error() string

+ type RegisterResponseValidationError struct

+ func (e RegisterResponseValidationError) Cause() error

+ func (e RegisterResponseValidationError) Error() string

+ func (e RegisterResponseValidationError) ErrorName() string

+ func (e RegisterResponseValidationError) Field() string

+ func (e RegisterResponseValidationError) Key() bool

+ func (e RegisterResponseValidationError) Reason() string

+ type RegistrarClient interface

+ Lookup func(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error)

+ Register func(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)

+ func NewRegistrarClient(cc grpc.ClientConnInterface) RegistrarClient

+ type RegistrarServer interface

+ Lookup func(context.Context, *LookupRequest) (*LookupResponse, error)

+ Register func(context.Context, *RegisterRequest) (*RegisterResponse, error)

type Status

+ Description string

+ func (x *Status) GetDescription() string

+ type UnimplementedRegistrarServer struct

+ func (UnimplementedRegistrarServer) Lookup(context.Context, *LookupRequest) (*LookupResponse, error)

+ func (UnimplementedRegistrarServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)

+ type UnsafeRegistrarServer interface

v0.8.1

Oct 10, 2023

v0.8.0

Oct 8, 2023

Changes in this version

+ const Membership_GetCurrentConsensus_FullMethodName

+ var QueryRequest_QueryType_name = map[int32]string

+ var QueryRequest_QueryType_value = map[string]int32

type MembershipClient

+ GetCurrentConsensus func(ctx context.Context, in *StorageConsensusRequest, opts ...grpc.CallOption) (*StorageConsensusResponse, error)

type MembershipServer

+ GetCurrentConsensus func(context.Context, *StorageConsensusRequest) (*StorageConsensusResponse, error)

+ type NetworkState struct

+ Domain string

+ NetworkV4 string

+ NetworkV6 string

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

+ func (*NetworkState) ProtoMessage()

+ func (in *NetworkState) DeepCopy() *NetworkState

+ func (in *NetworkState) DeepCopyInterface() interface{}

+ func (in *NetworkState) DeepCopyInto(out *NetworkState)

+ func (m *NetworkState) Validate() error

+ func (m *NetworkState) ValidateAll() error

+ func (x *NetworkState) GetDomain() string

+ func (x *NetworkState) GetNetworkV4() string

+ func (x *NetworkState) GetNetworkV6() string

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

+ func (x *NetworkState) Reset()

+ func (x *NetworkState) String() string

+ type NetworkStateMultiError []error

+ func (m NetworkStateMultiError) AllErrors() []error

+ func (m NetworkStateMultiError) Error() string

+ type NetworkStateValidationError struct

+ func (e NetworkStateValidationError) Cause() error

+ func (e NetworkStateValidationError) Error() string

+ func (e NetworkStateValidationError) ErrorName() string

+ func (e NetworkStateValidationError) Field() string

+ func (e NetworkStateValidationError) Key() bool

+ func (e NetworkStateValidationError) Reason() string

type QueryRequest

+ Type QueryRequest_QueryType

+ func (x *QueryRequest) GetType() QueryRequest_QueryType

+ type QueryRequest_QueryType int32

+ const QueryRequest_ACLS

+ const QueryRequest_EDGES

+ const QueryRequest_GROUPS

+ const QueryRequest_KEYS

+ const QueryRequest_NETWORK_STATE

+ const QueryRequest_PEERS

+ const QueryRequest_RBAC_STATE

+ const QueryRequest_ROLEBINDINGS

+ const QueryRequest_ROLES

+ const QueryRequest_ROUTES

+ const QueryRequest_VALUE

+ func (QueryRequest_QueryType) Descriptor() protoreflect.EnumDescriptor

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

+ func (QueryRequest_QueryType) Type() protoreflect.EnumType

+ func (x QueryRequest_QueryType) Enum() *QueryRequest_QueryType

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

+ func (x QueryRequest_QueryType) String() string

type QueryResponse

+ Items [][]byte

+ func (x *QueryResponse) GetItems() [][]byte

+ type StorageConsensusRequest struct

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

+ func (*StorageConsensusRequest) ProtoMessage()

+ func (in *StorageConsensusRequest) DeepCopy() *StorageConsensusRequest

+ func (in *StorageConsensusRequest) DeepCopyInterface() interface{}

+ func (in *StorageConsensusRequest) DeepCopyInto(out *StorageConsensusRequest)

+ func (m *StorageConsensusRequest) Validate() error

+ func (m *StorageConsensusRequest) ValidateAll() error

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

+ func (x *StorageConsensusRequest) Reset()

+ func (x *StorageConsensusRequest) String() string

+ type StorageConsensusRequestMultiError []error

+ func (m StorageConsensusRequestMultiError) AllErrors() []error

+ func (m StorageConsensusRequestMultiError) Error() string

+ type StorageConsensusRequestValidationError struct

+ func (e StorageConsensusRequestValidationError) Cause() error

+ func (e StorageConsensusRequestValidationError) Error() string

+ func (e StorageConsensusRequestValidationError) ErrorName() string

+ func (e StorageConsensusRequestValidationError) Field() string

+ func (e StorageConsensusRequestValidationError) Key() bool

+ func (e StorageConsensusRequestValidationError) Reason() string

+ type StorageConsensusResponse struct

+ Servers []*StorageServer

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

+ func (*StorageConsensusResponse) ProtoMessage()

+ func (in *StorageConsensusResponse) DeepCopy() *StorageConsensusResponse

+ func (in *StorageConsensusResponse) DeepCopyInterface() interface{}

+ func (in *StorageConsensusResponse) DeepCopyInto(out *StorageConsensusResponse)

+ func (m *StorageConsensusResponse) Validate() error

+ func (m *StorageConsensusResponse) ValidateAll() error

+ func (x *StorageConsensusResponse) GetServers() []*StorageServer

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

+ func (x *StorageConsensusResponse) Reset()

+ func (x *StorageConsensusResponse) String() string

+ type StorageConsensusResponseMultiError []error

+ func (m StorageConsensusResponseMultiError) AllErrors() []error

+ func (m StorageConsensusResponseMultiError) Error() string

+ type StorageConsensusResponseValidationError struct

+ func (e StorageConsensusResponseValidationError) Cause() error

+ func (e StorageConsensusResponseValidationError) Error() string

+ func (e StorageConsensusResponseValidationError) ErrorName() string

+ func (e StorageConsensusResponseValidationError) Field() string

+ func (e StorageConsensusResponseValidationError) Key() bool

+ func (e StorageConsensusResponseValidationError) Reason() string

type StorageServer

+ PublicKey string

+ func (x *StorageServer) GetPublicKey() string

type UnimplementedMembershipServer

+ func (UnimplementedMembershipServer) GetCurrentConsensus(context.Context, *StorageConsensusRequest) (*StorageConsensusResponse, error)

v0.7.0

Sep 30, 2023

Changes in this version

type AllocateIPRequest

+ NodeID string

+ func (x *AllocateIPRequest) GetNodeID() string

type ConnectRequest

+ JoinPSK string

+ func (x *ConnectRequest) GetJoinPSK() string

type ConnectResponse

+ NodeID string

+ func (x *ConnectResponse) GetNodeID() string

type JoinRequest

+ AssignIPv4 bool

+ PreferStorageIPv6 bool

+ ZoneAwarenessID string

+ func (x *JoinRequest) GetAssignIPv4() bool

+ func (x *JoinRequest) GetPreferStorageIPv6() bool

+ func (x *JoinRequest) GetZoneAwarenessID() string

type JoinResponse

+ AddressIPv4 string

+ AddressIPv6 string

+ NetworkIPv4 string

+ NetworkIPv6 string

+ func (x *JoinResponse) GetAddressIPv4() string

+ func (x *JoinResponse) GetAddressIPv6() string

+ func (x *JoinResponse) GetNetworkIPv4() string

+ func (x *JoinResponse) GetNetworkIPv6() string

type MeshNode

+ PrivateIPv4 string

+ PrivateIPv6 string

+ ZoneAwarenessID string

+ func (x *MeshNode) GetPrivateIPv4() string

+ func (x *MeshNode) GetPrivateIPv6() string

+ func (x *MeshNode) GetZoneAwarenessID() string

type NetworkACL

+ DestinationCIDRs []string

+ SourceCIDRs []string

+ func (x *NetworkACL) GetDestinationCIDRs() []string

+ func (x *NetworkACL) GetSourceCIDRs() []string

type NetworkAction

+ DstCIDR string

+ SrcCIDR string

+ func (x *NetworkAction) GetDstCIDR() string

+ func (x *NetworkAction) GetSrcCIDR() string

type PeerMetrics

+ AllowedIPs []string

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

type ReleaseIPRequest

+ NodeID string

+ func (x *ReleaseIPRequest) GetNodeID() string

type Route

+ DestinationCIDRs []string

+ func (x *Route) GetDestinationCIDRs() []string

type UpdateRequest

+ ZoneAwarenessID string

+ func (x *UpdateRequest) GetZoneAwarenessID() string

type WebRTCSignal

+ NodeID string

+ func (x *WebRTCSignal) GetNodeID() string

type WireGuardPeer

+ AllowedIPs []string

+ func (x *WireGuardPeer) GetAllowedIPs() []string

v0.6.2

Sep 30, 2023

Changes in this version

type AddObserverResponse

+ func (in *AddObserverResponse) DeepCopy() *AddObserverResponse

+ func (in *AddObserverResponse) DeepCopyInterface() interface{}

+ func (in *AddObserverResponse) DeepCopyInto(out *AddObserverResponse)

+ func (m *AddObserverResponse) Validate() error

+ func (m *AddObserverResponse) ValidateAll() error

+ type AddObserverResponseMultiError []error

+ func (m AddObserverResponseMultiError) AllErrors() []error

+ func (m AddObserverResponseMultiError) Error() string

+ type AddObserverResponseValidationError struct

+ func (e AddObserverResponseValidationError) Cause() error

+ func (e AddObserverResponseValidationError) Error() string

+ func (e AddObserverResponseValidationError) ErrorName() string

+ func (e AddObserverResponseValidationError) Field() string

+ func (e AddObserverResponseValidationError) Key() bool

+ func (e AddObserverResponseValidationError) Reason() string

type AddVoterResponse

+ func (in *AddVoterResponse) DeepCopy() *AddVoterResponse

+ func (in *AddVoterResponse) DeepCopyInterface() interface{}

+ func (in *AddVoterResponse) DeepCopyInto(out *AddVoterResponse)

+ func (m *AddVoterResponse) Validate() error

+ func (m *AddVoterResponse) ValidateAll() error

+ type AddVoterResponseMultiError []error

+ func (m AddVoterResponseMultiError) AllErrors() []error

+ func (m AddVoterResponseMultiError) Error() string

+ type AddVoterResponseValidationError struct

+ func (e AddVoterResponseValidationError) Cause() error

+ func (e AddVoterResponseValidationError) Error() string

+ func (e AddVoterResponseValidationError) ErrorName() string

+ func (e AddVoterResponseValidationError) Field() string

+ func (e AddVoterResponseValidationError) Key() bool

+ func (e AddVoterResponseValidationError) Reason() string

type AllocateIPRequest

+ func (in *AllocateIPRequest) DeepCopy() *AllocateIPRequest

+ func (in *AllocateIPRequest) DeepCopyInterface() interface{}

+ func (in *AllocateIPRequest) DeepCopyInto(out *AllocateIPRequest)

+ func (m *AllocateIPRequest) Validate() error

+ func (m *AllocateIPRequest) ValidateAll() error

+ type AllocateIPRequestMultiError []error

+ func (m AllocateIPRequestMultiError) AllErrors() []error

+ func (m AllocateIPRequestMultiError) Error() string

+ type AllocateIPRequestValidationError struct

+ func (e AllocateIPRequestValidationError) Cause() error

+ func (e AllocateIPRequestValidationError) Error() string

+ func (e AllocateIPRequestValidationError) ErrorName() string

+ func (e AllocateIPRequestValidationError) Field() string

+ func (e AllocateIPRequestValidationError) Key() bool

+ func (e AllocateIPRequestValidationError) Reason() string

type AllocatedIP

+ func (in *AllocatedIP) DeepCopy() *AllocatedIP

+ func (in *AllocatedIP) DeepCopyInterface() interface{}

+ func (in *AllocatedIP) DeepCopyInto(out *AllocatedIP)

+ func (m *AllocatedIP) Validate() error

+ func (m *AllocatedIP) ValidateAll() error

+ type AllocatedIPMultiError []error

+ func (m AllocatedIPMultiError) AllErrors() []error

+ func (m AllocatedIPMultiError) Error() string

+ type AllocatedIPValidationError struct

+ func (e AllocatedIPValidationError) Cause() error

+ func (e AllocatedIPValidationError) Error() string

+ func (e AllocatedIPValidationError) ErrorName() string

+ func (e AllocatedIPValidationError) Field() string

+ func (e AllocatedIPValidationError) Key() bool

+ func (e AllocatedIPValidationError) Reason() string

type AnnounceDHTRequest

+ func (in *AnnounceDHTRequest) DeepCopy() *AnnounceDHTRequest

+ func (in *AnnounceDHTRequest) DeepCopyInterface() interface{}

+ func (in *AnnounceDHTRequest) DeepCopyInto(out *AnnounceDHTRequest)

+ func (m *AnnounceDHTRequest) Validate() error

+ func (m *AnnounceDHTRequest) ValidateAll() error

+ type AnnounceDHTRequestMultiError []error

+ func (m AnnounceDHTRequestMultiError) AllErrors() []error

+ func (m AnnounceDHTRequestMultiError) Error() string

+ type AnnounceDHTRequestValidationError struct

+ func (e AnnounceDHTRequestValidationError) Cause() error

+ func (e AnnounceDHTRequestValidationError) Error() string

+ func (e AnnounceDHTRequestValidationError) ErrorName() string

+ func (e AnnounceDHTRequestValidationError) Field() string

+ func (e AnnounceDHTRequestValidationError) Key() bool

+ func (e AnnounceDHTRequestValidationError) Reason() string

type AnnounceDHTResponse

+ func (in *AnnounceDHTResponse) DeepCopy() *AnnounceDHTResponse

+ func (in *AnnounceDHTResponse) DeepCopyInterface() interface{}

+ func (in *AnnounceDHTResponse) DeepCopyInto(out *AnnounceDHTResponse)

+ func (m *AnnounceDHTResponse) Validate() error

+ func (m *AnnounceDHTResponse) ValidateAll() error

+ type AnnounceDHTResponseMultiError []error

+ func (m AnnounceDHTResponseMultiError) AllErrors() []error

+ func (m AnnounceDHTResponseMultiError) Error() string

+ type AnnounceDHTResponseValidationError struct

+ func (e AnnounceDHTResponseValidationError) Cause() error

+ func (e AnnounceDHTResponseValidationError) Error() string

+ func (e AnnounceDHTResponseValidationError) ErrorName() string

+ func (e AnnounceDHTResponseValidationError) Field() string

+ func (e AnnounceDHTResponseValidationError) Key() bool

+ func (e AnnounceDHTResponseValidationError) Reason() string

type AuthenticationRequest

+ func (in *AuthenticationRequest) DeepCopy() *AuthenticationRequest

+ func (in *AuthenticationRequest) DeepCopyInterface() interface{}

+ func (in *AuthenticationRequest) DeepCopyInto(out *AuthenticationRequest)

+ func (m *AuthenticationRequest) Validate() error

+ func (m *AuthenticationRequest) ValidateAll() error

+ type AuthenticationRequestMultiError []error

+ func (m AuthenticationRequestMultiError) AllErrors() []error

+ func (m AuthenticationRequestMultiError) Error() string

+ type AuthenticationRequestValidationError struct

+ func (e AuthenticationRequestValidationError) Cause() error

+ func (e AuthenticationRequestValidationError) Error() string

+ func (e AuthenticationRequestValidationError) ErrorName() string

+ func (e AuthenticationRequestValidationError) Field() string

+ func (e AuthenticationRequestValidationError) Key() bool

+ func (e AuthenticationRequestValidationError) Reason() string

type AuthenticationResponse

+ func (in *AuthenticationResponse) DeepCopy() *AuthenticationResponse

+ func (in *AuthenticationResponse) DeepCopyInterface() interface{}

+ func (in *AuthenticationResponse) DeepCopyInto(out *AuthenticationResponse)

+ func (m *AuthenticationResponse) Validate() error

+ func (m *AuthenticationResponse) ValidateAll() error

+ type AuthenticationResponseMultiError []error

+ func (m AuthenticationResponseMultiError) AllErrors() []error

+ func (m AuthenticationResponseMultiError) Error() string

+ type AuthenticationResponseValidationError struct

+ func (e AuthenticationResponseValidationError) Cause() error

+ func (e AuthenticationResponseValidationError) Error() string

+ func (e AuthenticationResponseValidationError) ErrorName() string

+ func (e AuthenticationResponseValidationError) Field() string

+ func (e AuthenticationResponseValidationError) Key() bool

+ func (e AuthenticationResponseValidationError) Reason() string

type BootstrapRequest

+ func (in *BootstrapRequest) DeepCopy() *BootstrapRequest

+ func (in *BootstrapRequest) DeepCopyInterface() interface{}

+ func (in *BootstrapRequest) DeepCopyInto(out *BootstrapRequest)

+ func (m *BootstrapRequest) Validate() error

+ func (m *BootstrapRequest) ValidateAll() error

+ type BootstrapRequestMultiError []error

+ func (m BootstrapRequestMultiError) AllErrors() []error

+ func (m BootstrapRequestMultiError) Error() string

+ type BootstrapRequestValidationError struct

+ func (e BootstrapRequestValidationError) Cause() error

+ func (e BootstrapRequestValidationError) Error() string

+ func (e BootstrapRequestValidationError) ErrorName() string

+ func (e BootstrapRequestValidationError) Field() string

+ func (e BootstrapRequestValidationError) Key() bool

+ func (e BootstrapRequestValidationError) Reason() string

type BootstrapResponse

+ func (in *BootstrapResponse) DeepCopy() *BootstrapResponse

+ func (in *BootstrapResponse) DeepCopyInterface() interface{}

+ func (in *BootstrapResponse) DeepCopyInto(out *BootstrapResponse)

+ func (m *BootstrapResponse) Validate() error

+ func (m *BootstrapResponse) ValidateAll() error

+ type BootstrapResponseMultiError []error

+ func (m BootstrapResponseMultiError) AllErrors() []error

+ func (m BootstrapResponseMultiError) Error() string

+ type BootstrapResponseValidationError struct

+ func (e BootstrapResponseValidationError) Cause() error

+ func (e BootstrapResponseValidationError) Error() string

+ func (e BootstrapResponseValidationError) ErrorName() string

+ func (e BootstrapResponseValidationError) Field() string

+ func (e BootstrapResponseValidationError) Key() bool

+ func (e BootstrapResponseValidationError) Reason() string

type ConnectRequest

+ func (in *ConnectRequest) DeepCopy() *ConnectRequest

+ func (in *ConnectRequest) DeepCopyInterface() interface{}

+ func (in *ConnectRequest) DeepCopyInto(out *ConnectRequest)

+ func (m *ConnectRequest) Validate() error

+ func (m *ConnectRequest) ValidateAll() error

+ type ConnectRequestMultiError []error

+ func (m ConnectRequestMultiError) AllErrors() []error

+ func (m ConnectRequestMultiError) Error() string

+ type ConnectRequestValidationError struct

+ func (e ConnectRequestValidationError) Cause() error

+ func (e ConnectRequestValidationError) Error() string

+ func (e ConnectRequestValidationError) ErrorName() string

+ func (e ConnectRequestValidationError) Field() string

+ func (e ConnectRequestValidationError) Key() bool

+ func (e ConnectRequestValidationError) Reason() string

type ConnectResponse

+ func (in *ConnectResponse) DeepCopy() *ConnectResponse

+ func (in *ConnectResponse) DeepCopyInterface() interface{}

+ func (in *ConnectResponse) DeepCopyInto(out *ConnectResponse)

+ func (m *ConnectResponse) Validate() error

+ func (m *ConnectResponse) ValidateAll() error

+ type ConnectResponseMultiError []error

+ func (m ConnectResponseMultiError) AllErrors() []error

+ func (m ConnectResponseMultiError) Error() string

+ type ConnectResponseValidationError struct

+ func (e ConnectResponseValidationError) Cause() error

+ func (e ConnectResponseValidationError) Error() string

+ func (e ConnectResponseValidationError) ErrorName() string

+ func (e ConnectResponseValidationError) Field() string

+ func (e ConnectResponseValidationError) Key() bool

+ func (e ConnectResponseValidationError) Reason() string

type DataChannelNegotiation

+ func (in *DataChannelNegotiation) DeepCopy() *DataChannelNegotiation

+ func (in *DataChannelNegotiation) DeepCopyInterface() interface{}

+ func (in *DataChannelNegotiation) DeepCopyInto(out *DataChannelNegotiation)

+ func (m *DataChannelNegotiation) Validate() error

+ func (m *DataChannelNegotiation) ValidateAll() error

+ type DataChannelNegotiationMultiError []error

+ func (m DataChannelNegotiationMultiError) AllErrors() []error

+ func (m DataChannelNegotiationMultiError) Error() string

+ type DataChannelNegotiationValidationError struct

+ func (e DataChannelNegotiationValidationError) Cause() error

+ func (e DataChannelNegotiationValidationError) Error() string

+ func (e DataChannelNegotiationValidationError) ErrorName() string

+ func (e DataChannelNegotiationValidationError) Field() string

+ func (e DataChannelNegotiationValidationError) Key() bool

+ func (e DataChannelNegotiationValidationError) Reason() string

type DataChannelOffer

+ func (in *DataChannelOffer) DeepCopy() *DataChannelOffer

+ func (in *DataChannelOffer) DeepCopyInterface() interface{}

+ func (in *DataChannelOffer) DeepCopyInto(out *DataChannelOffer)

+ func (m *DataChannelOffer) Validate() error

+ func (m *DataChannelOffer) ValidateAll() error

+ type DataChannelOfferMultiError []error

+ func (m DataChannelOfferMultiError) AllErrors() []error

+ func (m DataChannelOfferMultiError) Error() string

+ type DataChannelOfferValidationError struct

+ func (e DataChannelOfferValidationError) Cause() error

+ func (e DataChannelOfferValidationError) Error() string

+ func (e DataChannelOfferValidationError) ErrorName() string

+ func (e DataChannelOfferValidationError) Field() string

+ func (e DataChannelOfferValidationError) Key() bool

+ func (e DataChannelOfferValidationError) Reason() string

type DeleteValueRequest

+ func (in *DeleteValueRequest) DeepCopy() *DeleteValueRequest

+ func (in *DeleteValueRequest) DeepCopyInterface() interface{}

+ func (in *DeleteValueRequest) DeepCopyInto(out *DeleteValueRequest)

+ func (m *DeleteValueRequest) Validate() error

+ func (m *DeleteValueRequest) ValidateAll() error

+ type DeleteValueRequestMultiError []error

+ func (m DeleteValueRequestMultiError) AllErrors() []error

+ func (m DeleteValueRequestMultiError) Error() string

+ type DeleteValueRequestValidationError struct

+ func (e DeleteValueRequestValidationError) Cause() error

+ func (e DeleteValueRequestValidationError) Error() string

+ func (e DeleteValueRequestValidationError) ErrorName() string

+ func (e DeleteValueRequestValidationError) Field() string

+ func (e DeleteValueRequestValidationError) Key() bool

+ func (e DeleteValueRequestValidationError) Reason() string

type DeleteValueResponse

+ func (in *DeleteValueResponse) DeepCopy() *DeleteValueResponse

+ func (in *DeleteValueResponse) DeepCopyInterface() interface{}

+ func (in *DeleteValueResponse) DeepCopyInto(out *DeleteValueResponse)

+ func (m *DeleteValueResponse) Validate() error

+ func (m *DeleteValueResponse) ValidateAll() error

+ type DeleteValueResponseMultiError []error

+ func (m DeleteValueResponseMultiError) AllErrors() []error

+ func (m DeleteValueResponseMultiError) Error() string

+ type DeleteValueResponseValidationError struct

+ func (e DeleteValueResponseValidationError) Cause() error

+ func (e DeleteValueResponseValidationError) Error() string

+ func (e DeleteValueResponseValidationError) ErrorName() string

+ func (e DeleteValueResponseValidationError) Field() string

+ func (e DeleteValueResponseValidationError) Key() bool

+ func (e DeleteValueResponseValidationError) Reason() string

type DemoteVoterResponse

+ func (in *DemoteVoterResponse) DeepCopy() *DemoteVoterResponse

+ func (in *DemoteVoterResponse) DeepCopyInterface() interface{}

+ func (in *DemoteVoterResponse) DeepCopyInto(out *DemoteVoterResponse)

+ func (m *DemoteVoterResponse) Validate() error

+ func (m *DemoteVoterResponse) ValidateAll() error

+ type DemoteVoterResponseMultiError []error

+ func (m DemoteVoterResponseMultiError) AllErrors() []error

+ func (m DemoteVoterResponseMultiError) Error() string

+ type DemoteVoterResponseValidationError struct

+ func (e DemoteVoterResponseValidationError) Cause() error

+ func (e DemoteVoterResponseValidationError) Error() string

+ func (e DemoteVoterResponseValidationError) ErrorName() string

+ func (e DemoteVoterResponseValidationError) Field() string

+ func (e DemoteVoterResponseValidationError) Key() bool

+ func (e DemoteVoterResponseValidationError) Reason() string

type DisconnectRequest

+ func (in *DisconnectRequest) DeepCopy() *DisconnectRequest

+ func (in *DisconnectRequest) DeepCopyInterface() interface{}

+ func (in *DisconnectRequest) DeepCopyInto(out *DisconnectRequest)

+ func (m *DisconnectRequest) Validate() error

+ func (m *DisconnectRequest) ValidateAll() error

+ type DisconnectRequestMultiError []error

+ func (m DisconnectRequestMultiError) AllErrors() []error

+ func (m DisconnectRequestMultiError) Error() string

+ type DisconnectRequestValidationError struct

+ func (e DisconnectRequestValidationError) Cause() error

+ func (e DisconnectRequestValidationError) Error() string

+ func (e DisconnectRequestValidationError) ErrorName() string

+ func (e DisconnectRequestValidationError) Field() string

+ func (e DisconnectRequestValidationError) Key() bool

+ func (e DisconnectRequestValidationError) Reason() string

type DisconnectResponse

+ func (in *DisconnectResponse) DeepCopy() *DisconnectResponse

+ func (in *DisconnectResponse) DeepCopyInterface() interface{}

+ func (in *DisconnectResponse) DeepCopyInto(out *DisconnectResponse)

+ func (m *DisconnectResponse) Validate() error

+ func (m *DisconnectResponse) ValidateAll() error

+ type DisconnectResponseMultiError []error

+ func (m DisconnectResponseMultiError) AllErrors() []error

+ func (m DisconnectResponseMultiError) Error() string

+ type DisconnectResponseValidationError struct

+ func (e DisconnectResponseValidationError) Cause() error

+ func (e DisconnectResponseValidationError) Error() string

+ func (e DisconnectResponseValidationError) ErrorName() string

+ func (e DisconnectResponseValidationError) Field() string

+ func (e DisconnectResponseValidationError) Key() bool

+ func (e DisconnectResponseValidationError) Reason() string

type Event

+ func (in *Event) DeepCopy() *Event

+ func (in *Event) DeepCopyInterface() interface{}

+ func (in *Event) DeepCopyInto(out *Event)

+ func (m *Event) Validate() error

+ func (m *Event) ValidateAll() error

+ type EventMultiError []error

+ func (m EventMultiError) AllErrors() []error

+ func (m EventMultiError) Error() string

+ type EventValidationError struct

+ func (e EventValidationError) Cause() error

+ func (e EventValidationError) Error() string

+ func (e EventValidationError) ErrorName() string

+ func (e EventValidationError) Field() string

+ func (e EventValidationError) Key() bool

+ func (e EventValidationError) Reason() string

type FeaturePort

+ func (in *FeaturePort) DeepCopy() *FeaturePort

+ func (in *FeaturePort) DeepCopyInterface() interface{}

+ func (in *FeaturePort) DeepCopyInto(out *FeaturePort)

+ func (m *FeaturePort) Validate() error

+ func (m *FeaturePort) ValidateAll() error

+ type FeaturePortMultiError []error

+ func (m FeaturePortMultiError) AllErrors() []error

+ func (m FeaturePortMultiError) Error() string

+ type FeaturePortValidationError struct

+ func (e FeaturePortValidationError) Cause() error

+ func (e FeaturePortValidationError) Error() string

+ func (e FeaturePortValidationError) ErrorName() string

+ func (e FeaturePortValidationError) Field() string

+ func (e FeaturePortValidationError) Key() bool

+ func (e FeaturePortValidationError) Reason() string

type GetLeaderRequest

+ func (in *GetLeaderRequest) DeepCopy() *GetLeaderRequest

+ func (in *GetLeaderRequest) DeepCopyInterface() interface{}

+ func (in *GetLeaderRequest) DeepCopyInto(out *GetLeaderRequest)

+ func (m *GetLeaderRequest) Validate() error

+ func (m *GetLeaderRequest) ValidateAll() error

+ type GetLeaderRequestMultiError []error

+ func (m GetLeaderRequestMultiError) AllErrors() []error

+ func (m GetLeaderRequestMultiError) Error() string

+ type GetLeaderRequestValidationError struct

+ func (e GetLeaderRequestValidationError) Cause() error

+ func (e GetLeaderRequestValidationError) Error() string

+ func (e GetLeaderRequestValidationError) ErrorName() string

+ func (e GetLeaderRequestValidationError) Field() string

+ func (e GetLeaderRequestValidationError) Key() bool

+ func (e GetLeaderRequestValidationError) Reason() string

type GetNodeRequest

+ func (in *GetNodeRequest) DeepCopy() *GetNodeRequest

+ func (in *GetNodeRequest) DeepCopyInterface() interface{}

+ func (in *GetNodeRequest) DeepCopyInto(out *GetNodeRequest)

+ func (m *GetNodeRequest) Validate() error

+ func (m *GetNodeRequest) ValidateAll() error

+ type GetNodeRequestMultiError []error

+ func (m GetNodeRequestMultiError) AllErrors() []error

+ func (m GetNodeRequestMultiError) Error() string

+ type GetNodeRequestValidationError struct

+ func (e GetNodeRequestValidationError) Cause() error

+ func (e GetNodeRequestValidationError) Error() string

+ func (e GetNodeRequestValidationError) ErrorName() string

+ func (e GetNodeRequestValidationError) Field() string

+ func (e GetNodeRequestValidationError) Key() bool

+ func (e GetNodeRequestValidationError) Reason() string

type GetPeersRequest

+ func (in *GetPeersRequest) DeepCopy() *GetPeersRequest

+ func (in *GetPeersRequest) DeepCopyInterface() interface{}

+ func (in *GetPeersRequest) DeepCopyInto(out *GetPeersRequest)

+ func (m *GetPeersRequest) Validate() error

+ func (m *GetPeersRequest) ValidateAll() error

+ type GetPeersRequestMultiError []error

+ func (m GetPeersRequestMultiError) AllErrors() []error

+ func (m GetPeersRequestMultiError) Error() string

+ type GetPeersRequestValidationError struct

+ func (e GetPeersRequestValidationError) Cause() error

+ func (e GetPeersRequestValidationError) Error() string

+ func (e GetPeersRequestValidationError) ErrorName() string

+ func (e GetPeersRequestValidationError) Field() string

+ func (e GetPeersRequestValidationError) Key() bool

+ func (e GetPeersRequestValidationError) Reason() string

type GetStatusRequest

+ func (in *GetStatusRequest) DeepCopy() *GetStatusRequest

+ func (in *GetStatusRequest) DeepCopyInterface() interface{}

+ func (in *GetStatusRequest) DeepCopyInto(out *GetStatusRequest)

+ func (m *GetStatusRequest) Validate() error

+ func (m *GetStatusRequest) ValidateAll() error

+ type GetStatusRequestMultiError []error

+ func (m GetStatusRequestMultiError) AllErrors() []error

+ func (m GetStatusRequestMultiError) Error() string

+ type GetStatusRequestValidationError struct

+ func (e GetStatusRequestValidationError) Cause() error

+ func (e GetStatusRequestValidationError) Error() string

+ func (e GetStatusRequestValidationError) ErrorName() string

+ func (e GetStatusRequestValidationError) Field() string

+ func (e GetStatusRequestValidationError) Key() bool

+ func (e GetStatusRequestValidationError) Reason() string

type GetValueRequest

+ func (in *GetValueRequest) DeepCopy() *GetValueRequest

+ func (in *GetValueRequest) DeepCopyInterface() interface{}

+ func (in *GetValueRequest) DeepCopyInto(out *GetValueRequest)

+ func (m *GetValueRequest) Validate() error

+ func (m *GetValueRequest) ValidateAll() error

+ type GetValueRequestMultiError []error

+ func (m GetValueRequestMultiError) AllErrors() []error

+ func (m GetValueRequestMultiError) Error() string

+ type GetValueRequestValidationError struct

+ func (e GetValueRequestValidationError) Cause() error

+ func (e GetValueRequestValidationError) Error() string

+ func (e GetValueRequestValidationError) ErrorName() string

+ func (e GetValueRequestValidationError) Field() string

+ func (e GetValueRequestValidationError) Key() bool

+ func (e GetValueRequestValidationError) Reason() string

type GetValueResponse

+ func (in *GetValueResponse) DeepCopy() *GetValueResponse

+ func (in *GetValueResponse) DeepCopyInterface() interface{}

+ func (in *GetValueResponse) DeepCopyInto(out *GetValueResponse)

+ func (m *GetValueResponse) Validate() error

+ func (m *GetValueResponse) ValidateAll() error

+ type GetValueResponseMultiError []error

+ func (m GetValueResponseMultiError) AllErrors() []error

+ func (m GetValueResponseMultiError) Error() string

+ type GetValueResponseValidationError struct

+ func (e GetValueResponseValidationError) Cause() error

+ func (e GetValueResponseValidationError) Error() string

+ func (e GetValueResponseValidationError) ErrorName() string

+ func (e GetValueResponseValidationError) Field() string

+ func (e GetValueResponseValidationError) Key() bool

+ func (e GetValueResponseValidationError) Reason() string

type Group

+ func (in *Group) DeepCopy() *Group

+ func (in *Group) DeepCopyInterface() interface{}

+ func (in *Group) DeepCopyInto(out *Group)

+ func (m *Group) Validate() error

+ func (m *Group) ValidateAll() error

+ type GroupMultiError []error

+ func (m GroupMultiError) AllErrors() []error

+ func (m GroupMultiError) Error() string

+ type GroupValidationError struct

+ func (e GroupValidationError) Cause() error

+ func (e GroupValidationError) Error() string

+ func (e GroupValidationError) ErrorName() string

+ func (e GroupValidationError) Field() string

+ func (e GroupValidationError) Key() bool

+ func (e GroupValidationError) Reason() string

type Groups

+ func (in *Groups) DeepCopy() *Groups

+ func (in *Groups) DeepCopyInterface() interface{}

+ func (in *Groups) DeepCopyInto(out *Groups)

+ func (m *Groups) Validate() error

+ func (m *Groups) ValidateAll() error

+ type GroupsMultiError []error

+ func (m GroupsMultiError) AllErrors() []error

+ func (m GroupsMultiError) Error() string

+ type GroupsValidationError struct

+ func (e GroupsValidationError) Cause() error

+ func (e GroupsValidationError) Error() string

+ func (e GroupsValidationError) ErrorName() string

+ func (e GroupsValidationError) Field() string

+ func (e GroupsValidationError) Key() bool

+ func (e GroupsValidationError) Reason() string

type InterfaceMetrics

+ func (in *InterfaceMetrics) DeepCopy() *InterfaceMetrics

+ func (in *InterfaceMetrics) DeepCopyInterface() interface{}

+ func (in *InterfaceMetrics) DeepCopyInto(out *InterfaceMetrics)

+ func (m *InterfaceMetrics) Validate() error

+ func (m *InterfaceMetrics) ValidateAll() error

+ type InterfaceMetricsMultiError []error

+ func (m InterfaceMetricsMultiError) AllErrors() []error

+ func (m InterfaceMetricsMultiError) Error() string

+ type InterfaceMetricsValidationError struct

+ func (e InterfaceMetricsValidationError) Cause() error

+ func (e InterfaceMetricsValidationError) Error() string

+ func (e InterfaceMetricsValidationError) ErrorName() string

+ func (e InterfaceMetricsValidationError) Field() string

+ func (e InterfaceMetricsValidationError) Key() bool

+ func (e InterfaceMetricsValidationError) Reason() string

type JoinRequest

+ func (in *JoinRequest) DeepCopy() *JoinRequest

+ func (in *JoinRequest) DeepCopyInterface() interface{}

+ func (in *JoinRequest) DeepCopyInto(out *JoinRequest)

+ func (m *JoinRequest) Validate() error

+ func (m *JoinRequest) ValidateAll() error

+ type JoinRequestMultiError []error

+ func (m JoinRequestMultiError) AllErrors() []error

+ func (m JoinRequestMultiError) Error() string

+ type JoinRequestValidationError struct

+ func (e JoinRequestValidationError) Cause() error

+ func (e JoinRequestValidationError) Error() string

+ func (e JoinRequestValidationError) ErrorName() string

+ func (e JoinRequestValidationError) Field() string

+ func (e JoinRequestValidationError) Key() bool

+ func (e JoinRequestValidationError) Reason() string

type JoinResponse

+ func (in *JoinResponse) DeepCopy() *JoinResponse

+ func (in *JoinResponse) DeepCopyInterface() interface{}

+ func (in *JoinResponse) DeepCopyInto(out *JoinResponse)

+ func (m *JoinResponse) Validate() error

+ func (m *JoinResponse) ValidateAll() error

+ type JoinResponseMultiError []error

+ func (m JoinResponseMultiError) AllErrors() []error

+ func (m JoinResponseMultiError) Error() string

+ type JoinResponseValidationError struct

+ func (e JoinResponseValidationError) Cause() error

+ func (e JoinResponseValidationError) Error() string

+ func (e JoinResponseValidationError) ErrorName() string

+ func (e JoinResponseValidationError) Field() string

+ func (e JoinResponseValidationError) Key() bool

+ func (e JoinResponseValidationError) Reason() string

type LeaveDHTRequest

+ func (in *LeaveDHTRequest) DeepCopy() *LeaveDHTRequest

+ func (in *LeaveDHTRequest) DeepCopyInterface() interface{}

+ func (in *LeaveDHTRequest) DeepCopyInto(out *LeaveDHTRequest)

+ func (m *LeaveDHTRequest) Validate() error

+ func (m *LeaveDHTRequest) ValidateAll() error

+ type LeaveDHTRequestMultiError []error

+ func (m LeaveDHTRequestMultiError) AllErrors() []error

+ func (m LeaveDHTRequestMultiError) Error() string

+ type LeaveDHTRequestValidationError struct

+ func (e LeaveDHTRequestValidationError) Cause() error

+ func (e LeaveDHTRequestValidationError) Error() string

+ func (e LeaveDHTRequestValidationError) ErrorName() string

+ func (e LeaveDHTRequestValidationError) Field() string

+ func (e LeaveDHTRequestValidationError) Key() bool

+ func (e LeaveDHTRequestValidationError) Reason() string

type LeaveDHTResponse

+ func (in *LeaveDHTResponse) DeepCopy() *LeaveDHTResponse

+ func (in *LeaveDHTResponse) DeepCopyInterface() interface{}

+ func (in *LeaveDHTResponse) DeepCopyInto(out *LeaveDHTResponse)

+ func (m *LeaveDHTResponse) Validate() error

+ func (m *LeaveDHTResponse) ValidateAll() error

+ type LeaveDHTResponseMultiError []error

+ func (m LeaveDHTResponseMultiError) AllErrors() []error

+ func (m LeaveDHTResponseMultiError) Error() string

+ type LeaveDHTResponseValidationError struct

+ func (e LeaveDHTResponseValidationError) Cause() error

+ func (e LeaveDHTResponseValidationError) Error() string

+ func (e LeaveDHTResponseValidationError) ErrorName() string

+ func (e LeaveDHTResponseValidationError) Field() string

+ func (e LeaveDHTResponseValidationError) Key() bool

+ func (e LeaveDHTResponseValidationError) Reason() string

type LeaveRequest

+ func (in *LeaveRequest) DeepCopy() *LeaveRequest

+ func (in *LeaveRequest) DeepCopyInterface() interface{}

+ func (in *LeaveRequest) DeepCopyInto(out *LeaveRequest)

+ func (m *LeaveRequest) Validate() error

+ func (m *LeaveRequest) ValidateAll() error

+ type LeaveRequestMultiError []error

+ func (m LeaveRequestMultiError) AllErrors() []error

+ func (m LeaveRequestMultiError) Error() string

+ type LeaveRequestValidationError struct

+ func (e LeaveRequestValidationError) Cause() error

+ func (e LeaveRequestValidationError) Error() string

+ func (e LeaveRequestValidationError) ErrorName() string

+ func (e LeaveRequestValidationError) Field() string

+ func (e LeaveRequestValidationError) Key() bool

+ func (e LeaveRequestValidationError) Reason() string

type LeaveResponse

+ func (in *LeaveResponse) DeepCopy() *LeaveResponse

+ func (in *LeaveResponse) DeepCopyInterface() interface{}

+ func (in *LeaveResponse) DeepCopyInto(out *LeaveResponse)

+ func (m *LeaveResponse) Validate() error

+ func (m *LeaveResponse) ValidateAll() error

+ type LeaveResponseMultiError []error

+ func (m LeaveResponseMultiError) AllErrors() []error

+ func (m LeaveResponseMultiError) Error() string

+ type LeaveResponseValidationError struct

+ func (e LeaveResponseValidationError) Cause() error

+ func (e LeaveResponseValidationError) Error() string

+ func (e LeaveResponseValidationError) ErrorName() string

+ func (e LeaveResponseValidationError) Field() string

+ func (e LeaveResponseValidationError) Key() bool

+ func (e LeaveResponseValidationError) Reason() string

type ListKeysRequest

+ func (in *ListKeysRequest) DeepCopy() *ListKeysRequest

+ func (in *ListKeysRequest) DeepCopyInterface() interface{}

+ func (in *ListKeysRequest) DeepCopyInto(out *ListKeysRequest)

+ func (m *ListKeysRequest) Validate() error

+ func (m *ListKeysRequest) ValidateAll() error

+ type ListKeysRequestMultiError []error

+ func (m ListKeysRequestMultiError) AllErrors() []error

+ func (m ListKeysRequestMultiError) Error() string

+ type ListKeysRequestValidationError struct

+ func (e ListKeysRequestValidationError) Cause() error

+ func (e ListKeysRequestValidationError) Error() string

+ func (e ListKeysRequestValidationError) ErrorName() string

+ func (e ListKeysRequestValidationError) Field() string

+ func (e ListKeysRequestValidationError) Key() bool

+ func (e ListKeysRequestValidationError) Reason() string

type ListKeysResponse

+ func (in *ListKeysResponse) DeepCopy() *ListKeysResponse

+ func (in *ListKeysResponse) DeepCopyInterface() interface{}

+ func (in *ListKeysResponse) DeepCopyInto(out *ListKeysResponse)

+ func (m *ListKeysResponse) Validate() error

+ func (m *ListKeysResponse) ValidateAll() error

+ type ListKeysResponseMultiError []error

+ func (m ListKeysResponseMultiError) AllErrors() []error

+ func (m ListKeysResponseMultiError) Error() string

+ type ListKeysResponseValidationError struct

+ func (e ListKeysResponseValidationError) Cause() error

+ func (e ListKeysResponseValidationError) Error() string

+ func (e ListKeysResponseValidationError) ErrorName() string

+ func (e ListKeysResponseValidationError) Field() string

+ func (e ListKeysResponseValidationError) Key() bool

+ func (e ListKeysResponseValidationError) Reason() string

type ListValuesRequest

+ func (in *ListValuesRequest) DeepCopy() *ListValuesRequest

+ func (in *ListValuesRequest) DeepCopyInterface() interface{}

+ func (in *ListValuesRequest) DeepCopyInto(out *ListValuesRequest)

+ func (m *ListValuesRequest) Validate() error

+ func (m *ListValuesRequest) ValidateAll() error

+ type ListValuesRequestMultiError []error

+ func (m ListValuesRequestMultiError) AllErrors() []error

+ func (m ListValuesRequestMultiError) Error() string

+ type ListValuesRequestValidationError struct

+ func (e ListValuesRequestValidationError) Cause() error

+ func (e ListValuesRequestValidationError) Error() string

+ func (e ListValuesRequestValidationError) ErrorName() string

+ func (e ListValuesRequestValidationError) Field() string

+ func (e ListValuesRequestValidationError) Key() bool

+ func (e ListValuesRequestValidationError) Reason() string

type ListValuesResponse

+ func (in *ListValuesResponse) DeepCopy() *ListValuesResponse

+ func (in *ListValuesResponse) DeepCopyInterface() interface{}

+ func (in *ListValuesResponse) DeepCopyInto(out *ListValuesResponse)

+ func (m *ListValuesResponse) Validate() error

+ func (m *ListValuesResponse) ValidateAll() error

+ type ListValuesResponseMultiError []error

+ func (m ListValuesResponseMultiError) AllErrors() []error

+ func (m ListValuesResponseMultiError) Error() string

+ type ListValuesResponseValidationError struct

+ func (e ListValuesResponseValidationError) Cause() error

+ func (e ListValuesResponseValidationError) Error() string

+ func (e ListValuesResponseValidationError) ErrorName() string

+ func (e ListValuesResponseValidationError) Field() string

+ func (e ListValuesResponseValidationError) Key() bool

+ func (e ListValuesResponseValidationError) Reason() string

type MeshEdge

+ func (in *MeshEdge) DeepCopy() *MeshEdge

+ func (in *MeshEdge) DeepCopyInterface() interface{}

+ func (in *MeshEdge) DeepCopyInto(out *MeshEdge)

+ func (m *MeshEdge) Validate() error

+ func (m *MeshEdge) ValidateAll() error

+ type MeshEdgeMultiError []error

+ func (m MeshEdgeMultiError) AllErrors() []error

+ func (m MeshEdgeMultiError) Error() string

+ type MeshEdgeValidationError struct

+ func (e MeshEdgeValidationError) Cause() error

+ func (e MeshEdgeValidationError) Error() string

+ func (e MeshEdgeValidationError) ErrorName() string

+ func (e MeshEdgeValidationError) Field() string

+ func (e MeshEdgeValidationError) Key() bool

+ func (e MeshEdgeValidationError) Reason() string

type MeshEdges

+ func (in *MeshEdges) DeepCopy() *MeshEdges

+ func (in *MeshEdges) DeepCopyInterface() interface{}

+ func (in *MeshEdges) DeepCopyInto(out *MeshEdges)

+ func (m *MeshEdges) Validate() error

+ func (m *MeshEdges) ValidateAll() error

+ type MeshEdgesMultiError []error

+ func (m MeshEdgesMultiError) AllErrors() []error

+ func (m MeshEdgesMultiError) Error() string

+ type MeshEdgesValidationError struct

+ func (e MeshEdgesValidationError) Cause() error

+ func (e MeshEdgesValidationError) Error() string

+ func (e MeshEdgesValidationError) ErrorName() string

+ func (e MeshEdgesValidationError) Field() string

+ func (e MeshEdgesValidationError) Key() bool

+ func (e MeshEdgesValidationError) Reason() string

type MeshGraph

+ func (in *MeshGraph) DeepCopy() *MeshGraph

+ func (in *MeshGraph) DeepCopyInterface() interface{}

+ func (in *MeshGraph) DeepCopyInto(out *MeshGraph)

+ func (m *MeshGraph) Validate() error

+ func (m *MeshGraph) ValidateAll() error

+ type MeshGraphMultiError []error

+ func (m MeshGraphMultiError) AllErrors() []error

+ func (m MeshGraphMultiError) Error() string

+ type MeshGraphValidationError struct

+ func (e MeshGraphValidationError) Cause() error

+ func (e MeshGraphValidationError) Error() string

+ func (e MeshGraphValidationError) ErrorName() string

+ func (e MeshGraphValidationError) Field() string

+ func (e MeshGraphValidationError) Key() bool

+ func (e MeshGraphValidationError) Reason() string

type MeshNode

+ func (in *MeshNode) DeepCopy() *MeshNode

+ func (in *MeshNode) DeepCopyInterface() interface{}

+ func (in *MeshNode) DeepCopyInto(out *MeshNode)

+ func (m *MeshNode) Validate() error

+ func (m *MeshNode) ValidateAll() error

+ type MeshNodeMultiError []error

+ func (m MeshNodeMultiError) AllErrors() []error

+ func (m MeshNodeMultiError) Error() string

+ type MeshNodeValidationError struct

+ func (e MeshNodeValidationError) Cause() error

+ func (e MeshNodeValidationError) Error() string

+ func (e MeshNodeValidationError) ErrorName() string

+ func (e MeshNodeValidationError) Field() string

+ func (e MeshNodeValidationError) Key() bool

+ func (e MeshNodeValidationError) Reason() string

type MetricsRequest

+ func (in *MetricsRequest) DeepCopy() *MetricsRequest

+ func (in *MetricsRequest) DeepCopyInterface() interface{}

+ func (in *MetricsRequest) DeepCopyInto(out *MetricsRequest)

+ func (m *MetricsRequest) Validate() error

+ func (m *MetricsRequest) ValidateAll() error

+ type MetricsRequestMultiError []error

+ func (m MetricsRequestMultiError) AllErrors() []error

+ func (m MetricsRequestMultiError) Error() string

+ type MetricsRequestValidationError struct

+ func (e MetricsRequestValidationError) Cause() error

+ func (e MetricsRequestValidationError) Error() string

+ func (e MetricsRequestValidationError) ErrorName() string

+ func (e MetricsRequestValidationError) Field() string

+ func (e MetricsRequestValidationError) Key() bool

+ func (e MetricsRequestValidationError) Reason() string

type MetricsResponse

+ func (in *MetricsResponse) DeepCopy() *MetricsResponse

+ func (in *MetricsResponse) DeepCopyInterface() interface{}

+ func (in *MetricsResponse) DeepCopyInto(out *MetricsResponse)

+ func (m *MetricsResponse) Validate() error

+ func (m *MetricsResponse) ValidateAll() error

+ type MetricsResponseMultiError []error

+ func (m MetricsResponseMultiError) AllErrors() []error

+ func (m MetricsResponseMultiError) Error() string

+ type MetricsResponseValidationError struct

+ func (e MetricsResponseValidationError) Cause() error

+ func (e MetricsResponseValidationError) Error() string

+ func (e MetricsResponseValidationError) ErrorName() string

+ func (e MetricsResponseValidationError) Field() string

+ func (e MetricsResponseValidationError) Key() bool

+ func (e MetricsResponseValidationError) Reason() string

type NetworkACL

+ func (in *NetworkACL) DeepCopy() *NetworkACL

+ func (in *NetworkACL) DeepCopyInterface() interface{}

+ func (in *NetworkACL) DeepCopyInto(out *NetworkACL)

+ func (m *NetworkACL) Validate() error

+ func (m *NetworkACL) ValidateAll() error

+ type NetworkACLMultiError []error

+ func (m NetworkACLMultiError) AllErrors() []error

+ func (m NetworkACLMultiError) Error() string

+ type NetworkACLValidationError struct

+ func (e NetworkACLValidationError) Cause() error

+ func (e NetworkACLValidationError) Error() string

+ func (e NetworkACLValidationError) ErrorName() string

+ func (e NetworkACLValidationError) Field() string

+ func (e NetworkACLValidationError) Key() bool

+ func (e NetworkACLValidationError) Reason() string

type NetworkACLs

+ func (in *NetworkACLs) DeepCopy() *NetworkACLs

+ func (in *NetworkACLs) DeepCopyInterface() interface{}

+ func (in *NetworkACLs) DeepCopyInto(out *NetworkACLs)

+ func (m *NetworkACLs) Validate() error

+ func (m *NetworkACLs) ValidateAll() error

+ type NetworkACLsMultiError []error

+ func (m NetworkACLsMultiError) AllErrors() []error

+ func (m NetworkACLsMultiError) Error() string

+ type NetworkACLsValidationError struct

+ func (e NetworkACLsValidationError) Cause() error

+ func (e NetworkACLsValidationError) Error() string

+ func (e NetworkACLsValidationError) ErrorName() string

+ func (e NetworkACLsValidationError) Field() string

+ func (e NetworkACLsValidationError) Key() bool

+ func (e NetworkACLsValidationError) Reason() string

type NetworkAction

+ func (in *NetworkAction) DeepCopy() *NetworkAction

+ func (in *NetworkAction) DeepCopyInterface() interface{}

+ func (in *NetworkAction) DeepCopyInto(out *NetworkAction)

+ func (m *NetworkAction) Validate() error

+ func (m *NetworkAction) ValidateAll() error

+ type NetworkActionMultiError []error

+ func (m NetworkActionMultiError) AllErrors() []error

+ func (m NetworkActionMultiError) Error() string

+ type NetworkActionValidationError struct

+ func (e NetworkActionValidationError) Cause() error

+ func (e NetworkActionValidationError) Error() string

+ func (e NetworkActionValidationError) ErrorName() string

+ func (e NetworkActionValidationError) Field() string

+ func (e NetworkActionValidationError) Key() bool

+ func (e NetworkActionValidationError) Reason() string

type NodeList

+ func (in *NodeList) DeepCopy() *NodeList

+ func (in *NodeList) DeepCopyInterface() interface{}

+ func (in *NodeList) DeepCopyInto(out *NodeList)

+ func (m *NodeList) Validate() error

+ func (m *NodeList) ValidateAll() error

+ type NodeListMultiError []error

+ func (m NodeListMultiError) AllErrors() []error

+ func (m NodeListMultiError) Error() string

+ type NodeListValidationError struct

+ func (e NodeListValidationError) Cause() error

+ func (e NodeListValidationError) Error() string

+ func (e NodeListValidationError) ErrorName() string

+ func (e NodeListValidationError) Field() string

+ func (e NodeListValidationError) Key() bool

+ func (e NodeListValidationError) Reason() string

type PeerConfigurations

+ func (in *PeerConfigurations) DeepCopy() *PeerConfigurations

+ func (in *PeerConfigurations) DeepCopyInterface() interface{}

+ func (in *PeerConfigurations) DeepCopyInto(out *PeerConfigurations)

+ func (m *PeerConfigurations) Validate() error

+ func (m *PeerConfigurations) ValidateAll() error

+ type PeerConfigurationsMultiError []error

+ func (m PeerConfigurationsMultiError) AllErrors() []error

+ func (m PeerConfigurationsMultiError) Error() string

+ type PeerConfigurationsValidationError struct

+ func (e PeerConfigurationsValidationError) Cause() error

+ func (e PeerConfigurationsValidationError) Error() string

+ func (e PeerConfigurationsValidationError) ErrorName() string

+ func (e PeerConfigurationsValidationError) Field() string

+ func (e PeerConfigurationsValidationError) Key() bool

+ func (e PeerConfigurationsValidationError) Reason() string

type PeerMetrics

+ func (in *PeerMetrics) DeepCopy() *PeerMetrics

+ func (in *PeerMetrics) DeepCopyInterface() interface{}

+ func (in *PeerMetrics) DeepCopyInto(out *PeerMetrics)

+ func (m *PeerMetrics) Validate() error

+ func (m *PeerMetrics) ValidateAll() error

+ type PeerMetricsMultiError []error

+ func (m PeerMetricsMultiError) AllErrors() []error

+ func (m PeerMetricsMultiError) Error() string

+ type PeerMetricsValidationError struct

+ func (e PeerMetricsValidationError) Cause() error

+ func (e PeerMetricsValidationError) Error() string

+ func (e PeerMetricsValidationError) ErrorName() string

+ func (e PeerMetricsValidationError) Field() string

+ func (e PeerMetricsValidationError) Key() bool

+ func (e PeerMetricsValidationError) Reason() string

type PluginConfiguration

+ func (in *PluginConfiguration) DeepCopy() *PluginConfiguration

+ func (in *PluginConfiguration) DeepCopyInterface() interface{}

+ func (in *PluginConfiguration) DeepCopyInto(out *PluginConfiguration)

+ func (m *PluginConfiguration) Validate() error

+ func (m *PluginConfiguration) ValidateAll() error

+ type PluginConfigurationMultiError []error

+ func (m PluginConfigurationMultiError) AllErrors() []error

+ func (m PluginConfigurationMultiError) Error() string

+ type PluginConfigurationValidationError struct

+ func (e PluginConfigurationValidationError) Cause() error

+ func (e PluginConfigurationValidationError) Error() string

+ func (e PluginConfigurationValidationError) ErrorName() string

+ func (e PluginConfigurationValidationError) Field() string

+ func (e PluginConfigurationValidationError) Key() bool

+ func (e PluginConfigurationValidationError) Reason() string

type PluginInfo

+ func (in *PluginInfo) DeepCopy() *PluginInfo

+ func (in *PluginInfo) DeepCopyInterface() interface{}

+ func (in *PluginInfo) DeepCopyInto(out *PluginInfo)

+ func (m *PluginInfo) Validate() error

+ func (m *PluginInfo) ValidateAll() error

+ type PluginInfoMultiError []error

+ func (m PluginInfoMultiError) AllErrors() []error

+ func (m PluginInfoMultiError) Error() string

+ type PluginInfoValidationError struct

+ func (e PluginInfoValidationError) Cause() error

+ func (e PluginInfoValidationError) Error() string

+ func (e PluginInfoValidationError) ErrorName() string

+ func (e PluginInfoValidationError) Field() string

+ func (e PluginInfoValidationError) Key() bool

+ func (e PluginInfoValidationError) Reason() string

type PluginQuery

+ func (in *PluginQuery) DeepCopy() *PluginQuery

+ func (in *PluginQuery) DeepCopyInterface() interface{}

+ func (in *PluginQuery) DeepCopyInto(out *PluginQuery)

+ func (m *PluginQuery) Validate() error

+ func (m *PluginQuery) ValidateAll() error

+ type PluginQueryMultiError []error

+ func (m PluginQueryMultiError) AllErrors() []error

+ func (m PluginQueryMultiError) Error() string

type PluginQueryResult

+ func (in *PluginQueryResult) DeepCopy() *PluginQueryResult

+ func (in *PluginQueryResult) DeepCopyInterface() interface{}

+ func (in *PluginQueryResult) DeepCopyInto(out *PluginQueryResult)

+ func (m *PluginQueryResult) Validate() error

+ func (m *PluginQueryResult) ValidateAll() error

+ type PluginQueryResultMultiError []error

+ func (m PluginQueryResultMultiError) AllErrors() []error

+ func (m PluginQueryResultMultiError) Error() string

+ type PluginQueryResultValidationError struct

+ func (e PluginQueryResultValidationError) Cause() error

+ func (e PluginQueryResultValidationError) Error() string

+ func (e PluginQueryResultValidationError) ErrorName() string

+ func (e PluginQueryResultValidationError) Field() string

+ func (e PluginQueryResultValidationError) Key() bool

+ func (e PluginQueryResultValidationError) Reason() string

+ type PluginQueryValidationError struct

+ func (e PluginQueryValidationError) Cause() error

+ func (e PluginQueryValidationError) Error() string

+ func (e PluginQueryValidationError) ErrorName() string

+ func (e PluginQueryValidationError) Field() string

+ func (e PluginQueryValidationError) Key() bool

+ func (e PluginQueryValidationError) Reason() string

type PrefixEvent

+ func (in *PrefixEvent) DeepCopy() *PrefixEvent

+ func (in *PrefixEvent) DeepCopyInterface() interface{}

+ func (in *PrefixEvent) DeepCopyInto(out *PrefixEvent)

+ func (m *PrefixEvent) Validate() error

+ func (m *PrefixEvent) ValidateAll() error

+ type PrefixEventMultiError []error

+ func (m PrefixEventMultiError) AllErrors() []error

+ func (m PrefixEventMultiError) Error() string

+ type PrefixEventValidationError struct

+ func (e PrefixEventValidationError) Cause() error

+ func (e PrefixEventValidationError) Error() string

+ func (e PrefixEventValidationError) ErrorName() string

+ func (e PrefixEventValidationError) Field() string

+ func (e PrefixEventValidationError) Key() bool

+ func (e PrefixEventValidationError) Reason() string

type PublishRequest

+ func (in *PublishRequest) DeepCopy() *PublishRequest

+ func (in *PublishRequest) DeepCopyInterface() interface{}

+ func (in *PublishRequest) DeepCopyInto(out *PublishRequest)

+ func (m *PublishRequest) Validate() error

+ func (m *PublishRequest) ValidateAll() error

+ type PublishRequestMultiError []error

+ func (m PublishRequestMultiError) AllErrors() []error

+ func (m PublishRequestMultiError) Error() string

+ type PublishRequestValidationError struct

+ func (e PublishRequestValidationError) Cause() error

+ func (e PublishRequestValidationError) Error() string

+ func (e PublishRequestValidationError) ErrorName() string

+ func (e PublishRequestValidationError) Field() string

+ func (e PublishRequestValidationError) Key() bool

+ func (e PublishRequestValidationError) Reason() string

type PublishResponse

+ func (in *PublishResponse) DeepCopy() *PublishResponse

+ func (in *PublishResponse) DeepCopyInterface() interface{}

+ func (in *PublishResponse) DeepCopyInto(out *PublishResponse)

+ func (m *PublishResponse) Validate() error

+ func (m *PublishResponse) ValidateAll() error

+ type PublishResponseMultiError []error

+ func (m PublishResponseMultiError) AllErrors() []error

+ func (m PublishResponseMultiError) Error() string

+ type PublishResponseValidationError struct

+ func (e PublishResponseValidationError) Cause() error

+ func (e PublishResponseValidationError) Error() string

+ func (e PublishResponseValidationError) ErrorName() string

+ func (e PublishResponseValidationError) Field() string

+ func (e PublishResponseValidationError) Key() bool

+ func (e PublishResponseValidationError) Reason() string

type PutValueRequest

+ func (in *PutValueRequest) DeepCopy() *PutValueRequest

+ func (in *PutValueRequest) DeepCopyInterface() interface{}

+ func (in *PutValueRequest) DeepCopyInto(out *PutValueRequest)

+ func (m *PutValueRequest) Validate() error

+ func (m *PutValueRequest) ValidateAll() error

+ type PutValueRequestMultiError []error

+ func (m PutValueRequestMultiError) AllErrors() []error

+ func (m PutValueRequestMultiError) Error() string

+ type PutValueRequestValidationError struct

+ func (e PutValueRequestValidationError) Cause() error

+ func (e PutValueRequestValidationError) Error() string

+ func (e PutValueRequestValidationError) ErrorName() string

+ func (e PutValueRequestValidationError) Field() string

+ func (e PutValueRequestValidationError) Key() bool

+ func (e PutValueRequestValidationError) Reason() string

type PutValueResponse

+ func (in *PutValueResponse) DeepCopy() *PutValueResponse

+ func (in *PutValueResponse) DeepCopyInterface() interface{}

+ func (in *PutValueResponse) DeepCopyInto(out *PutValueResponse)

+ func (m *PutValueResponse) Validate() error

+ func (m *PutValueResponse) ValidateAll() error

+ type PutValueResponseMultiError []error

+ func (m PutValueResponseMultiError) AllErrors() []error

+ func (m PutValueResponseMultiError) Error() string

+ type PutValueResponseValidationError struct

+ func (e PutValueResponseValidationError) Cause() error

+ func (e PutValueResponseValidationError) Error() string

+ func (e PutValueResponseValidationError) ErrorName() string

+ func (e PutValueResponseValidationError) Field() string

+ func (e PutValueResponseValidationError) Key() bool

+ func (e PutValueResponseValidationError) Reason() string

type QueryRequest

+ func (in *QueryRequest) DeepCopy() *QueryRequest

+ func (in *QueryRequest) DeepCopyInterface() interface{}

+ func (in *QueryRequest) DeepCopyInto(out *QueryRequest)

+ func (m *QueryRequest) Validate() error

+ func (m *QueryRequest) ValidateAll() error

+ type QueryRequestMultiError []error

+ func (m QueryRequestMultiError) AllErrors() []error

+ func (m QueryRequestMultiError) Error() string

+ type QueryRequestValidationError struct

+ func (e QueryRequestValidationError) Cause() error

+ func (e QueryRequestValidationError) Error() string

+ func (e QueryRequestValidationError) ErrorName() string

+ func (e QueryRequestValidationError) Field() string

+ func (e QueryRequestValidationError) Key() bool

+ func (e QueryRequestValidationError) Reason() string

type QueryResponse

+ func (in *QueryResponse) DeepCopy() *QueryResponse

+ func (in *QueryResponse) DeepCopyInterface() interface{}

+ func (in *QueryResponse) DeepCopyInto(out *QueryResponse)

+ func (m *QueryResponse) Validate() error

+ func (m *QueryResponse) ValidateAll() error

+ type QueryResponseMultiError []error

+ func (m QueryResponseMultiError) AllErrors() []error

+ func (m QueryResponseMultiError) Error() string

+ type QueryResponseValidationError struct

+ func (e QueryResponseValidationError) Cause() error

+ func (e QueryResponseValidationError) Error() string

+ func (e QueryResponseValidationError) ErrorName() string

+ func (e QueryResponseValidationError) Field() string

+ func (e QueryResponseValidationError) Key() bool

+ func (e QueryResponseValidationError) Reason() string

type RBACAction

+ func (in *RBACAction) DeepCopy() *RBACAction

+ func (in *RBACAction) DeepCopyInterface() interface{}

+ func (in *RBACAction) DeepCopyInto(out *RBACAction)

+ func (m *RBACAction) Validate() error

+ func (m *RBACAction) ValidateAll() error

+ type RBACActionMultiError []error

+ func (m RBACActionMultiError) AllErrors() []error

+ func (m RBACActionMultiError) Error() string

+ type RBACActionValidationError struct

+ func (e RBACActionValidationError) Cause() error

+ func (e RBACActionValidationError) Error() string

+ func (e RBACActionValidationError) ErrorName() string

+ func (e RBACActionValidationError) Field() string

+ func (e RBACActionValidationError) Key() bool

+ func (e RBACActionValidationError) Reason() string

type RaftApplyResponse

+ func (in *RaftApplyResponse) DeepCopy() *RaftApplyResponse

+ func (in *RaftApplyResponse) DeepCopyInterface() interface{}

+ func (in *RaftApplyResponse) DeepCopyInto(out *RaftApplyResponse)

+ func (m *RaftApplyResponse) Validate() error

+ func (m *RaftApplyResponse) ValidateAll() error

+ type RaftApplyResponseMultiError []error

+ func (m RaftApplyResponseMultiError) AllErrors() []error

+ func (m RaftApplyResponseMultiError) Error() string

+ type RaftApplyResponseValidationError struct

+ func (e RaftApplyResponseValidationError) Cause() error

+ func (e RaftApplyResponseValidationError) Error() string

+ func (e RaftApplyResponseValidationError) ErrorName() string

+ func (e RaftApplyResponseValidationError) Field() string

+ func (e RaftApplyResponseValidationError) Key() bool

+ func (e RaftApplyResponseValidationError) Reason() string

type RaftDataItem

+ func (in *RaftDataItem) DeepCopy() *RaftDataItem

+ func (in *RaftDataItem) DeepCopyInterface() interface{}

+ func (in *RaftDataItem) DeepCopyInto(out *RaftDataItem)

+ func (m *RaftDataItem) Validate() error

+ func (m *RaftDataItem) ValidateAll() error

+ type RaftDataItemMultiError []error

+ func (m RaftDataItemMultiError) AllErrors() []error

+ func (m RaftDataItemMultiError) Error() string

+ type RaftDataItemValidationError struct

+ func (e RaftDataItemValidationError) Cause() error

+ func (e RaftDataItemValidationError) Error() string

+ func (e RaftDataItemValidationError) ErrorName() string

+ func (e RaftDataItemValidationError) Field() string

+ func (e RaftDataItemValidationError) Key() bool

+ func (e RaftDataItemValidationError) Reason() string

type RaftLogEntry

+ func (in *RaftLogEntry) DeepCopy() *RaftLogEntry

+ func (in *RaftLogEntry) DeepCopyInterface() interface{}

+ func (in *RaftLogEntry) DeepCopyInto(out *RaftLogEntry)

+ func (m *RaftLogEntry) Validate() error

+ func (m *RaftLogEntry) ValidateAll() error

+ type RaftLogEntryMultiError []error

+ func (m RaftLogEntryMultiError) AllErrors() []error

+ func (m RaftLogEntryMultiError) Error() string

+ type RaftLogEntryValidationError struct

+ func (e RaftLogEntryValidationError) Cause() error

+ func (e RaftLogEntryValidationError) Error() string

+ func (e RaftLogEntryValidationError) ErrorName() string

+ func (e RaftLogEntryValidationError) Field() string

+ func (e RaftLogEntryValidationError) Key() bool

+ func (e RaftLogEntryValidationError) Reason() string

type RaftSnapshot

+ func (in *RaftSnapshot) DeepCopy() *RaftSnapshot

+ func (in *RaftSnapshot) DeepCopyInterface() interface{}

+ func (in *RaftSnapshot) DeepCopyInto(out *RaftSnapshot)

+ func (m *RaftSnapshot) Validate() error

+ func (m *RaftSnapshot) ValidateAll() error

+ type RaftSnapshotMultiError []error

+ func (m RaftSnapshotMultiError) AllErrors() []error

+ func (m RaftSnapshotMultiError) Error() string

+ type RaftSnapshotValidationError struct

+ func (e RaftSnapshotValidationError) Cause() error

+ func (e RaftSnapshotValidationError) Error() string

+ func (e RaftSnapshotValidationError) ErrorName() string

+ func (e RaftSnapshotValidationError) Field() string

+ func (e RaftSnapshotValidationError) Key() bool

+ func (e RaftSnapshotValidationError) Reason() string

type ReleaseIPRequest

+ func (in *ReleaseIPRequest) DeepCopy() *ReleaseIPRequest

+ func (in *ReleaseIPRequest) DeepCopyInterface() interface{}

+ func (in *ReleaseIPRequest) DeepCopyInto(out *ReleaseIPRequest)

+ func (m *ReleaseIPRequest) Validate() error

+ func (m *ReleaseIPRequest) ValidateAll() error

+ type ReleaseIPRequestMultiError []error

+ func (m ReleaseIPRequestMultiError) AllErrors() []error

+ func (m ReleaseIPRequestMultiError) Error() string

+ type ReleaseIPRequestValidationError struct

+ func (e ReleaseIPRequestValidationError) Cause() error

+ func (e ReleaseIPRequestValidationError) Error() string

+ func (e ReleaseIPRequestValidationError) ErrorName() string

+ func (e ReleaseIPRequestValidationError) Field() string

+ func (e ReleaseIPRequestValidationError) Key() bool

+ func (e ReleaseIPRequestValidationError) Reason() string

type RemoveServerResponse

+ func (in *RemoveServerResponse) DeepCopy() *RemoveServerResponse

+ func (in *RemoveServerResponse) DeepCopyInterface() interface{}

+ func (in *RemoveServerResponse) DeepCopyInto(out *RemoveServerResponse)

+ func (m *RemoveServerResponse) Validate() error

+ func (m *RemoveServerResponse) ValidateAll() error

+ type RemoveServerResponseMultiError []error

+ func (m RemoveServerResponseMultiError) AllErrors() []error

+ func (m RemoveServerResponseMultiError) Error() string

+ type RemoveServerResponseValidationError struct

+ func (e RemoveServerResponseValidationError) Cause() error

+ func (e RemoveServerResponseValidationError) Error() string

+ func (e RemoveServerResponseValidationError) ErrorName() string

+ func (e RemoveServerResponseValidationError) Field() string

+ func (e RemoveServerResponseValidationError) Key() bool

+ func (e RemoveServerResponseValidationError) Reason() string

type Role

+ func (in *Role) DeepCopy() *Role

+ func (in *Role) DeepCopyInterface() interface{}

+ func (in *Role) DeepCopyInto(out *Role)

+ func (m *Role) Validate() error

+ func (m *Role) ValidateAll() error

type RoleBinding

+ func (in *RoleBinding) DeepCopy() *RoleBinding

+ func (in *RoleBinding) DeepCopyInterface() interface{}

+ func (in *RoleBinding) DeepCopyInto(out *RoleBinding)

+ func (m *RoleBinding) Validate() error

+ func (m *RoleBinding) ValidateAll() error

+ type RoleBindingMultiError []error

+ func (m RoleBindingMultiError) AllErrors() []error

+ func (m RoleBindingMultiError) Error() string

+ type RoleBindingValidationError struct

+ func (e RoleBindingValidationError) Cause() error

+ func (e RoleBindingValidationError) Error() string

+ func (e RoleBindingValidationError) ErrorName() string

+ func (e RoleBindingValidationError) Field() string

+ func (e RoleBindingValidationError) Key() bool

+ func (e RoleBindingValidationError) Reason() string

type RoleBindings

+ func (in *RoleBindings) DeepCopy() *RoleBindings

+ func (in *RoleBindings) DeepCopyInterface() interface{}

+ func (in *RoleBindings) DeepCopyInto(out *RoleBindings)

+ func (m *RoleBindings) Validate() error

+ func (m *RoleBindings) ValidateAll() error

+ type RoleBindingsMultiError []error

+ func (m RoleBindingsMultiError) AllErrors() []error

+ func (m RoleBindingsMultiError) Error() string

+ type RoleBindingsValidationError struct

+ func (e RoleBindingsValidationError) Cause() error

+ func (e RoleBindingsValidationError) Error() string

+ func (e RoleBindingsValidationError) ErrorName() string

+ func (e RoleBindingsValidationError) Field() string

+ func (e RoleBindingsValidationError) Key() bool

+ func (e RoleBindingsValidationError) Reason() string

+ type RoleMultiError []error

+ func (m RoleMultiError) AllErrors() []error

+ func (m RoleMultiError) Error() string

+ type RoleValidationError struct

+ func (e RoleValidationError) Cause() error

+ func (e RoleValidationError) Error() string

+ func (e RoleValidationError) ErrorName() string

+ func (e RoleValidationError) Field() string

+ func (e RoleValidationError) Key() bool

+ func (e RoleValidationError) Reason() string

type Roles

+ func (in *Roles) DeepCopy() *Roles

+ func (in *Roles) DeepCopyInterface() interface{}

+ func (in *Roles) DeepCopyInto(out *Roles)

+ func (m *Roles) Validate() error

+ func (m *Roles) ValidateAll() error

+ type RolesMultiError []error

+ func (m RolesMultiError) AllErrors() []error

+ func (m RolesMultiError) Error() string

+ type RolesValidationError struct

+ func (e RolesValidationError) Cause() error

+ func (e RolesValidationError) Error() string

+ func (e RolesValidationError) ErrorName() string

+ func (e RolesValidationError) Field() string

+ func (e RolesValidationError) Key() bool

+ func (e RolesValidationError) Reason() string

type Route

+ func (in *Route) DeepCopy() *Route

+ func (in *Route) DeepCopyInterface() interface{}

+ func (in *Route) DeepCopyInto(out *Route)

+ func (m *Route) Validate() error

+ func (m *Route) ValidateAll() error

+ type RouteMultiError []error

+ func (m RouteMultiError) AllErrors() []error

+ func (m RouteMultiError) Error() string

+ type RouteValidationError struct

+ func (e RouteValidationError) Cause() error

+ func (e RouteValidationError) Error() string

+ func (e RouteValidationError) ErrorName() string

+ func (e RouteValidationError) Field() string

+ func (e RouteValidationError) Key() bool

+ func (e RouteValidationError) Reason() string

type Routes

+ func (in *Routes) DeepCopy() *Routes

+ func (in *Routes) DeepCopyInterface() interface{}

+ func (in *Routes) DeepCopyInto(out *Routes)

+ func (m *Routes) Validate() error

+ func (m *Routes) ValidateAll() error

+ type RoutesMultiError []error

+ func (m RoutesMultiError) AllErrors() []error

+ func (m RoutesMultiError) Error() string

+ type RoutesValidationError struct

+ func (e RoutesValidationError) Cause() error

+ func (e RoutesValidationError) Error() string

+ func (e RoutesValidationError) ErrorName() string

+ func (e RoutesValidationError) Field() string

+ func (e RoutesValidationError) Key() bool

+ func (e RoutesValidationError) Reason() string

type Rule

+ func (in *Rule) DeepCopy() *Rule

+ func (in *Rule) DeepCopyInterface() interface{}

+ func (in *Rule) DeepCopyInto(out *Rule)

+ func (m *Rule) Validate() error

+ func (m *Rule) ValidateAll() error

+ type RuleMultiError []error

+ func (m RuleMultiError) AllErrors() []error

+ func (m RuleMultiError) Error() string

+ type RuleValidationError struct

+ func (e RuleValidationError) Cause() error

+ func (e RuleValidationError) Error() string

+ func (e RuleValidationError) ErrorName() string

+ func (e RuleValidationError) Field() string

+ func (e RuleValidationError) Key() bool

+ func (e RuleValidationError) Reason() string

type StartDataChannelRequest

+ func (in *StartDataChannelRequest) DeepCopy() *StartDataChannelRequest

+ func (in *StartDataChannelRequest) DeepCopyInterface() interface{}

+ func (in *StartDataChannelRequest) DeepCopyInto(out *StartDataChannelRequest)

+ func (m *StartDataChannelRequest) Validate() error

+ func (m *StartDataChannelRequest) ValidateAll() error

+ type StartDataChannelRequestMultiError []error

+ func (m StartDataChannelRequestMultiError) AllErrors() []error

+ func (m StartDataChannelRequestMultiError) Error() string

+ type StartDataChannelRequestValidationError struct

+ func (e StartDataChannelRequestValidationError) Cause() error

+ func (e StartDataChannelRequestValidationError) Error() string

+ func (e StartDataChannelRequestValidationError) ErrorName() string

+ func (e StartDataChannelRequestValidationError) Field() string

+ func (e StartDataChannelRequestValidationError) Key() bool

+ func (e StartDataChannelRequestValidationError) Reason() string

type Status

+ func (in *Status) DeepCopy() *Status

+ func (in *Status) DeepCopyInterface() interface{}

+ func (in *Status) DeepCopyInto(out *Status)

+ func (m *Status) Validate() error

+ func (m *Status) ValidateAll() error

+ type StatusMultiError []error

+ func (m StatusMultiError) AllErrors() []error

+ func (m StatusMultiError) Error() string

type StatusRequest

+ func (in *StatusRequest) DeepCopy() *StatusRequest

+ func (in *StatusRequest) DeepCopyInterface() interface{}

+ func (in *StatusRequest) DeepCopyInto(out *StatusRequest)

+ func (m *StatusRequest) Validate() error

+ func (m *StatusRequest) ValidateAll() error

+ type StatusRequestMultiError []error

+ func (m StatusRequestMultiError) AllErrors() []error

+ func (m StatusRequestMultiError) Error() string

+ type StatusRequestValidationError struct

+ func (e StatusRequestValidationError) Cause() error

+ func (e StatusRequestValidationError) Error() string

+ func (e StatusRequestValidationError) ErrorName() string

+ func (e StatusRequestValidationError) Field() string

+ func (e StatusRequestValidationError) Key() bool

+ func (e StatusRequestValidationError) Reason() string

type StatusResponse

+ func (in *StatusResponse) DeepCopy() *StatusResponse

+ func (in *StatusResponse) DeepCopyInterface() interface{}

+ func (in *StatusResponse) DeepCopyInto(out *StatusResponse)

+ func (m *StatusResponse) Validate() error

+ func (m *StatusResponse) ValidateAll() error

+ type StatusResponseMultiError []error

+ func (m StatusResponseMultiError) AllErrors() []error

+ func (m StatusResponseMultiError) Error() string

+ type StatusResponseValidationError struct

+ func (e StatusResponseValidationError) Cause() error

+ func (e StatusResponseValidationError) Error() string

+ func (e StatusResponseValidationError) ErrorName() string

+ func (e StatusResponseValidationError) Field() string

+ func (e StatusResponseValidationError) Key() bool

+ func (e StatusResponseValidationError) Reason() string

+ type StatusValidationError struct

+ func (e StatusValidationError) Cause() error

+ func (e StatusValidationError) Error() string

+ func (e StatusValidationError) ErrorName() string

+ func (e StatusValidationError) Field() string

+ func (e StatusValidationError) Key() bool

+ func (e StatusValidationError) Reason() string

type StorageConfigurationRequest

+ func (in *StorageConfigurationRequest) DeepCopy() *StorageConfigurationRequest

+ func (in *StorageConfigurationRequest) DeepCopyInterface() interface{}

+ func (in *StorageConfigurationRequest) DeepCopyInto(out *StorageConfigurationRequest)

+ func (m *StorageConfigurationRequest) Validate() error

+ func (m *StorageConfigurationRequest) ValidateAll() error

+ type StorageConfigurationRequestMultiError []error

+ func (m StorageConfigurationRequestMultiError) AllErrors() []error

+ func (m StorageConfigurationRequestMultiError) Error() string

+ type StorageConfigurationRequestValidationError struct

+ func (e StorageConfigurationRequestValidationError) Cause() error

+ func (e StorageConfigurationRequestValidationError) Error() string

+ func (e StorageConfigurationRequestValidationError) ErrorName() string

+ func (e StorageConfigurationRequestValidationError) Field() string

+ func (e StorageConfigurationRequestValidationError) Key() bool

+ func (e StorageConfigurationRequestValidationError) Reason() string

type StorageConfigurationResponse

+ func (in *StorageConfigurationResponse) DeepCopy() *StorageConfigurationResponse

+ func (in *StorageConfigurationResponse) DeepCopyInterface() interface{}

+ func (in *StorageConfigurationResponse) DeepCopyInto(out *StorageConfigurationResponse)

+ func (m *StorageConfigurationResponse) Validate() error

+ func (m *StorageConfigurationResponse) ValidateAll() error

+ type StorageConfigurationResponseMultiError []error

+ func (m StorageConfigurationResponseMultiError) AllErrors() []error

+ func (m StorageConfigurationResponseMultiError) Error() string

+ type StorageConfigurationResponseValidationError struct

+ func (e StorageConfigurationResponseValidationError) Cause() error

+ func (e StorageConfigurationResponseValidationError) Error() string

+ func (e StorageConfigurationResponseValidationError) ErrorName() string

+ func (e StorageConfigurationResponseValidationError) Field() string

+ func (e StorageConfigurationResponseValidationError) Key() bool

+ func (e StorageConfigurationResponseValidationError) Reason() string

type StoragePeer

+ func (in *StoragePeer) DeepCopy() *StoragePeer

+ func (in *StoragePeer) DeepCopyInterface() interface{}

+ func (in *StoragePeer) DeepCopyInto(out *StoragePeer)

+ func (m *StoragePeer) Validate() error

+ func (m *StoragePeer) ValidateAll() error

+ type StoragePeerMultiError []error

+ func (m StoragePeerMultiError) AllErrors() []error

+ func (m StoragePeerMultiError) Error() string

+ type StoragePeerValidationError struct

+ func (e StoragePeerValidationError) Cause() error

+ func (e StoragePeerValidationError) Error() string

+ func (e StoragePeerValidationError) ErrorName() string

+ func (e StoragePeerValidationError) Field() string

+ func (e StoragePeerValidationError) Key() bool

+ func (e StoragePeerValidationError) Reason() string

type StoragePeers

+ func (in *StoragePeers) DeepCopy() *StoragePeers

+ func (in *StoragePeers) DeepCopyInterface() interface{}

+ func (in *StoragePeers) DeepCopyInto(out *StoragePeers)

+ func (m *StoragePeers) Validate() error

+ func (m *StoragePeers) ValidateAll() error

+ type StoragePeersMultiError []error

+ func (m StoragePeersMultiError) AllErrors() []error

+ func (m StoragePeersMultiError) Error() string

+ type StoragePeersValidationError struct

+ func (e StoragePeersValidationError) Cause() error

+ func (e StoragePeersValidationError) Error() string

+ func (e StoragePeersValidationError) ErrorName() string

+ func (e StoragePeersValidationError) Field() string

+ func (e StoragePeersValidationError) Key() bool

+ func (e StoragePeersValidationError) Reason() string

type StorageServer

+ func (in *StorageServer) DeepCopy() *StorageServer

+ func (in *StorageServer) DeepCopyInterface() interface{}

+ func (in *StorageServer) DeepCopyInto(out *StorageServer)

+ func (m *StorageServer) Validate() error

+ func (m *StorageServer) ValidateAll() error

+ type StorageServerMultiError []error

+ func (m StorageServerMultiError) AllErrors() []error

+ func (m StorageServerMultiError) Error() string

+ type StorageServerValidationError struct

+ func (e StorageServerValidationError) Cause() error

+ func (e StorageServerValidationError) Error() string

+ func (e StorageServerValidationError) ErrorName() string

+ func (e StorageServerValidationError) Field() string

+ func (e StorageServerValidationError) Key() bool

+ func (e StorageServerValidationError) Reason() string

type StorageStatus

+ func (in *StorageStatus) DeepCopy() *StorageStatus

+ func (in *StorageStatus) DeepCopyInterface() interface{}

+ func (in *StorageStatus) DeepCopyInto(out *StorageStatus)

+ func (m *StorageStatus) Validate() error

+ func (m *StorageStatus) ValidateAll() error

+ type StorageStatusMultiError []error

+ func (m StorageStatusMultiError) AllErrors() []error

+ func (m StorageStatusMultiError) Error() string

type StorageStatusRequest

+ func (in *StorageStatusRequest) DeepCopy() *StorageStatusRequest

+ func (in *StorageStatusRequest) DeepCopyInterface() interface{}

+ func (in *StorageStatusRequest) DeepCopyInto(out *StorageStatusRequest)

+ func (m *StorageStatusRequest) Validate() error

+ func (m *StorageStatusRequest) ValidateAll() error

+ type StorageStatusRequestMultiError []error

+ func (m StorageStatusRequestMultiError) AllErrors() []error

+ func (m StorageStatusRequestMultiError) Error() string

+ type StorageStatusRequestValidationError struct

+ func (e StorageStatusRequestValidationError) Cause() error

+ func (e StorageStatusRequestValidationError) Error() string

+ func (e StorageStatusRequestValidationError) ErrorName() string

+ func (e StorageStatusRequestValidationError) Field() string

+ func (e StorageStatusRequestValidationError) Key() bool

+ func (e StorageStatusRequestValidationError) Reason() string

+ type StorageStatusValidationError struct

+ func (e StorageStatusValidationError) Cause() error

+ func (e StorageStatusValidationError) Error() string

+ func (e StorageStatusValidationError) ErrorName() string

+ func (e StorageStatusValidationError) Field() string

+ func (e StorageStatusValidationError) Key() bool

+ func (e StorageStatusValidationError) Reason() string

type StorageValue

+ func (in *StorageValue) DeepCopy() *StorageValue

+ func (in *StorageValue) DeepCopyInterface() interface{}

+ func (in *StorageValue) DeepCopyInto(out *StorageValue)

+ func (m *StorageValue) Validate() error

+ func (m *StorageValue) ValidateAll() error

+ type StorageValueMultiError []error

+ func (m StorageValueMultiError) AllErrors() []error

+ func (m StorageValueMultiError) Error() string

+ type StorageValueValidationError struct

+ func (e StorageValueValidationError) Cause() error

+ func (e StorageValueValidationError) Error() string

+ func (e StorageValueValidationError) ErrorName() string

+ func (e StorageValueValidationError) Field() string

+ func (e StorageValueValidationError) Key() bool

+ func (e StorageValueValidationError) Reason() string

type Subject

+ func (in *Subject) DeepCopy() *Subject

+ func (in *Subject) DeepCopyInterface() interface{}

+ func (in *Subject) DeepCopyInto(out *Subject)

+ func (m *Subject) Validate() error

+ func (m *Subject) ValidateAll() error

+ type SubjectMultiError []error

+ func (m SubjectMultiError) AllErrors() []error

+ func (m SubjectMultiError) Error() string

+ type SubjectValidationError struct

+ func (e SubjectValidationError) Cause() error

+ func (e SubjectValidationError) Error() string

+ func (e SubjectValidationError) ErrorName() string

+ func (e SubjectValidationError) Field() string

+ func (e SubjectValidationError) Key() bool

+ func (e SubjectValidationError) Reason() string

type SubscribePeersRequest

+ func (in *SubscribePeersRequest) DeepCopy() *SubscribePeersRequest

+ func (in *SubscribePeersRequest) DeepCopyInterface() interface{}

+ func (in *SubscribePeersRequest) DeepCopyInto(out *SubscribePeersRequest)

+ func (m *SubscribePeersRequest) Validate() error

+ func (m *SubscribePeersRequest) ValidateAll() error

+ type SubscribePeersRequestMultiError []error

+ func (m SubscribePeersRequestMultiError) AllErrors() []error

+ func (m SubscribePeersRequestMultiError) Error() string

+ type SubscribePeersRequestValidationError struct

+ func (e SubscribePeersRequestValidationError) Cause() error

+ func (e SubscribePeersRequestValidationError) Error() string

+ func (e SubscribePeersRequestValidationError) ErrorName() string

+ func (e SubscribePeersRequestValidationError) Field() string

+ func (e SubscribePeersRequestValidationError) Key() bool

+ func (e SubscribePeersRequestValidationError) Reason() string

type SubscribePrefixRequest

+ func (in *SubscribePrefixRequest) DeepCopy() *SubscribePrefixRequest

+ func (in *SubscribePrefixRequest) DeepCopyInterface() interface{}

+ func (in *SubscribePrefixRequest) DeepCopyInto(out *SubscribePrefixRequest)

+ func (m *SubscribePrefixRequest) Validate() error

+ func (m *SubscribePrefixRequest) ValidateAll() error

+ type SubscribePrefixRequestMultiError []error

+ func (m SubscribePrefixRequestMultiError) AllErrors() []error

+ func (m SubscribePrefixRequestMultiError) Error() string

+ type SubscribePrefixRequestValidationError struct

+ func (e SubscribePrefixRequestValidationError) Cause() error

+ func (e SubscribePrefixRequestValidationError) Error() string

+ func (e SubscribePrefixRequestValidationError) ErrorName() string

+ func (e SubscribePrefixRequestValidationError) Field() string

+ func (e SubscribePrefixRequestValidationError) Key() bool

+ func (e SubscribePrefixRequestValidationError) Reason() string

type SubscribeRequest

+ func (in *SubscribeRequest) DeepCopy() *SubscribeRequest

+ func (in *SubscribeRequest) DeepCopyInterface() interface{}

+ func (in *SubscribeRequest) DeepCopyInto(out *SubscribeRequest)

+ func (m *SubscribeRequest) Validate() error

+ func (m *SubscribeRequest) ValidateAll() error

+ type SubscribeRequestMultiError []error

+ func (m SubscribeRequestMultiError) AllErrors() []error

+ func (m SubscribeRequestMultiError) Error() string

+ type SubscribeRequestValidationError struct

+ func (e SubscribeRequestValidationError) Cause() error

+ func (e SubscribeRequestValidationError) Error() string

+ func (e SubscribeRequestValidationError) ErrorName() string

+ func (e SubscribeRequestValidationError) Field() string

+ func (e SubscribeRequestValidationError) Key() bool

+ func (e SubscribeRequestValidationError) Reason() string

type SubscriptionEvent

+ func (in *SubscriptionEvent) DeepCopy() *SubscriptionEvent

+ func (in *SubscriptionEvent) DeepCopyInterface() interface{}

+ func (in *SubscriptionEvent) DeepCopyInto(out *SubscriptionEvent)

+ func (m *SubscriptionEvent) Validate() error

+ func (m *SubscriptionEvent) ValidateAll() error

+ type SubscriptionEventMultiError []error

+ func (m SubscriptionEventMultiError) AllErrors() []error

+ func (m SubscriptionEventMultiError) Error() string

+ type SubscriptionEventValidationError struct

+ func (e SubscriptionEventValidationError) Cause() error

+ func (e SubscriptionEventValidationError) Error() string

+ func (e SubscriptionEventValidationError) ErrorName() string

+ func (e SubscriptionEventValidationError) Field() string

+ func (e SubscriptionEventValidationError) Key() bool

+ func (e SubscriptionEventValidationError) Reason() string

type UpdateRequest

+ func (in *UpdateRequest) DeepCopy() *UpdateRequest

+ func (in *UpdateRequest) DeepCopyInterface() interface{}

+ func (in *UpdateRequest) DeepCopyInto(out *UpdateRequest)

+ func (m *UpdateRequest) Validate() error

+ func (m *UpdateRequest) ValidateAll() error

+ type UpdateRequestMultiError []error

+ func (m UpdateRequestMultiError) AllErrors() []error

+ func (m UpdateRequestMultiError) Error() string

+ type UpdateRequestValidationError struct

+ func (e UpdateRequestValidationError) Cause() error

+ func (e UpdateRequestValidationError) Error() string

+ func (e UpdateRequestValidationError) ErrorName() string

+ func (e UpdateRequestValidationError) Field() string

+ func (e UpdateRequestValidationError) Key() bool

+ func (e UpdateRequestValidationError) Reason() string

type UpdateResponse

+ func (in *UpdateResponse) DeepCopy() *UpdateResponse

+ func (in *UpdateResponse) DeepCopyInterface() interface{}

+ func (in *UpdateResponse) DeepCopyInto(out *UpdateResponse)

+ func (m *UpdateResponse) Validate() error

+ func (m *UpdateResponse) ValidateAll() error

+ type UpdateResponseMultiError []error

+ func (m UpdateResponseMultiError) AllErrors() []error

+ func (m UpdateResponseMultiError) Error() string

+ type UpdateResponseValidationError struct

+ func (e UpdateResponseValidationError) Cause() error

+ func (e UpdateResponseValidationError) Error() string

+ func (e UpdateResponseValidationError) ErrorName() string

+ func (e UpdateResponseValidationError) Field() string

+ func (e UpdateResponseValidationError) Key() bool

+ func (e UpdateResponseValidationError) Reason() string

type WebRTCSignal

+ func (in *WebRTCSignal) DeepCopy() *WebRTCSignal

+ func (in *WebRTCSignal) DeepCopyInterface() interface{}

+ func (in *WebRTCSignal) DeepCopyInto(out *WebRTCSignal)

+ func (m *WebRTCSignal) Validate() error

+ func (m *WebRTCSignal) ValidateAll() error

+ type WebRTCSignalMultiError []error

+ func (m WebRTCSignalMultiError) AllErrors() []error

+ func (m WebRTCSignalMultiError) Error() string

+ type WebRTCSignalValidationError struct

+ func (e WebRTCSignalValidationError) Cause() error

+ func (e WebRTCSignalValidationError) Error() string

+ func (e WebRTCSignalValidationError) ErrorName() string

+ func (e WebRTCSignalValidationError) Field() string

+ func (e WebRTCSignalValidationError) Key() bool

+ func (e WebRTCSignalValidationError) Reason() string

type WireGuardPeer

+ func (in *WireGuardPeer) DeepCopy() *WireGuardPeer

+ func (in *WireGuardPeer) DeepCopyInterface() interface{}

+ func (in *WireGuardPeer) DeepCopyInto(out *WireGuardPeer)

+ func (m *WireGuardPeer) Validate() error

+ func (m *WireGuardPeer) ValidateAll() error

+ type WireGuardPeerMultiError []error

+ func (m WireGuardPeerMultiError) AllErrors() []error

+ func (m WireGuardPeerMultiError) Error() string

+ type WireGuardPeerValidationError struct

+ func (e WireGuardPeerValidationError) Cause() error

+ func (e WireGuardPeerValidationError) Error() string

+ func (e WireGuardPeerValidationError) ErrorName() string

+ func (e WireGuardPeerValidationError) Field() string

+ func (e WireGuardPeerValidationError) Key() bool

+ func (e WireGuardPeerValidationError) Reason() string

v0.6.1

Sep 27, 2023

v0.6.0

Sep 27, 2023

v0.5.0

Sep 26, 2023

Changes in this version

+ const StorageProviderPlugin_GetPeers_FullMethodName

+ var File_v1_storage_provider_proto protoreflect.FileDescriptor

+ var File_v1_storage_query_proto protoreflect.FileDescriptor

+ type GetPeersRequest struct

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

+ func (*GetPeersRequest) ProtoMessage()

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

+ func (x *GetPeersRequest) Reset()

+ func (x *GetPeersRequest) String() string

+ type StoragePeers struct

+ Peers []*StoragePeer

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

+ func (*StoragePeers) ProtoMessage()

+ func (x *StoragePeers) GetPeers() []*StoragePeer

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

+ func (x *StoragePeers) Reset()

+ func (x *StoragePeers) String() string

type StorageProviderPluginClient

+ GetPeers func(ctx context.Context, in *GetPeersRequest, opts ...grpc.CallOption) (*StoragePeers, error)

type StorageProviderPluginServer

+ GetPeers func(context.Context, *GetPeersRequest) (*StoragePeers, error)

type UnimplementedStorageProviderPluginServer

+ func (UnimplementedStorageProviderPluginServer) GetPeers(context.Context, *GetPeersRequest) (*StoragePeers, error)

v0.4.2

Sep 26, 2023

v0.4.1

Sep 26, 2023

v0.4.0

Sep 26, 2023

Changes in this version

+ const Membership_GetStorageConfiguration_FullMethodName

+ const Node_ReceiveSignalChannel_FullMethodName

+ const StorageProviderPlugin_AddObserver_FullMethodName

+ const StorageProviderPlugin_AddVoter_FullMethodName

+ const StorageProviderPlugin_Bootstrap_FullMethodName

+ const StorageProviderPlugin_DeleteValue_FullMethodName

+ const StorageProviderPlugin_DemoteVoter_FullMethodName

+ const StorageProviderPlugin_GetLeader_FullMethodName

+ const StorageProviderPlugin_GetStatus_FullMethodName

+ const StorageProviderPlugin_GetValue_FullMethodName

+ const StorageProviderPlugin_IsMember_FullMethodName

+ const StorageProviderPlugin_ListKeys_FullMethodName

+ const StorageProviderPlugin_ListValues_FullMethodName

+ const StorageProviderPlugin_PutValue_FullMethodName

+ const StorageProviderPlugin_RemovePeer_FullMethodName

+ const StorageProviderPlugin_SubscribePrefix_FullMethodName

+ const StorageQuerierPlugin_InjectQuerier_FullMethodName

+ const StorageQueryService_Publish_FullMethodName

+ const StorageQueryService_Query_FullMethodName

+ const StorageQueryService_Subscribe_FullMethodName

+ const WebRTC_StartSignalChannel_FullMethodName

+ var ConnectProtocol_name = map[int32]string

+ var ConnectProtocol_value = map[string]int32

+ var EdgeAttribute_name = map[int32]string

+ var EdgeAttribute_value = map[string]int32

+ var File_v1_plugin_storage_provider_proto protoreflect.FileDescriptor

+ var PrefixEvent_EventType_name = map[int32]string

+ var PrefixEvent_EventType_value = map[string]int32

+ var StorageProviderPlugin_ServiceDesc = grpc.ServiceDesc

+ var StorageQuerierPlugin_ServiceDesc = grpc.ServiceDesc

+ var StorageQueryService_ServiceDesc = grpc.ServiceDesc

+ func RegisterStorageProviderPluginServer(s grpc.ServiceRegistrar, srv StorageProviderPluginServer)

+ func RegisterStorageQuerierPluginServer(s grpc.ServiceRegistrar, srv StorageQuerierPluginServer)

+ func RegisterStorageQueryServiceServer(s grpc.ServiceRegistrar, srv StorageQueryServiceServer)

+ type AddObserverResponse struct

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

+ func (*AddObserverResponse) ProtoMessage()

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

+ func (x *AddObserverResponse) Reset()

+ func (x *AddObserverResponse) String() string

+ type AddVoterResponse struct

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

+ func (*AddVoterResponse) ProtoMessage()

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

+ func (x *AddVoterResponse) Reset()

+ func (x *AddVoterResponse) String() string

+ type BootstrapRequest struct

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

+ func (*BootstrapRequest) ProtoMessage()

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

+ func (x *BootstrapRequest) Reset()

+ func (x *BootstrapRequest) String() string

+ type BootstrapResponse struct

+ Status *StorageStatus

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

+ func (*BootstrapResponse) ProtoMessage()

+ func (x *BootstrapResponse) GetStatus() *StorageStatus

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

+ func (x *BootstrapResponse) Reset()

+ func (x *BootstrapResponse) String() string

type ClusterStatus

+ const ClusterStatus_CLUSTER_OBSERVER

+ type ConnectProtocol int32

+ const ConnectProtocol_CONNECT_ICE

+ const ConnectProtocol_CONNECT_LIBP2P

+ const ConnectProtocol_CONNECT_NATIVE

+ func (ConnectProtocol) Descriptor() protoreflect.EnumDescriptor

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

+ func (ConnectProtocol) Type() protoreflect.EnumType

+ func (x ConnectProtocol) Enum() *ConnectProtocol

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

+ func (x ConnectProtocol) String() string

+ type DeleteValueRequest struct

+ Key string

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

+ func (*DeleteValueRequest) ProtoMessage()

+ func (x *DeleteValueRequest) GetKey() string

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

+ func (x *DeleteValueRequest) Reset()

+ func (x *DeleteValueRequest) String() string

+ type DeleteValueResponse struct

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

+ func (*DeleteValueResponse) ProtoMessage()

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

+ func (x *DeleteValueResponse) Reset()

+ func (x *DeleteValueResponse) String() string

+ type DemoteVoterResponse struct

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

+ func (*DemoteVoterResponse) ProtoMessage()

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

+ func (x *DemoteVoterResponse) Reset()

+ func (x *DemoteVoterResponse) String() string

+ type EdgeAttribute int32

+ const EdgeAttribute_EDGE_ATTRIBUTE_ICE

+ const EdgeAttribute_EDGE_ATTRIBUTE_LIBP2P

+ const EdgeAttribute_EDGE_ATTRIBUTE_NATIVE

+ const EdgeAttribute_EDGE_ATTRIBUTE_UNKNOWN

+ func (EdgeAttribute) Descriptor() protoreflect.EnumDescriptor

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

+ func (EdgeAttribute) Type() protoreflect.EnumType

+ func (x EdgeAttribute) Enum() *EdgeAttribute

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

+ func (x EdgeAttribute) String() string

type Feature

+ const Feature_STORAGE_PROVIDER

+ const Feature_STORAGE_QUERIER

+ type FeaturePort struct

+ Feature Feature

+ Port int32

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

+ func (*FeaturePort) ProtoMessage()

+ func (x *FeaturePort) GetFeature() Feature

+ func (x *FeaturePort) GetPort() int32

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

+ func (x *FeaturePort) Reset()

+ func (x *FeaturePort) String() string

+ type GetLeaderRequest struct

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

+ func (*GetLeaderRequest) ProtoMessage()

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

+ func (x *GetLeaderRequest) Reset()

+ func (x *GetLeaderRequest) String() string

+ type GetValueRequest struct

+ Key string

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

+ func (*GetValueRequest) ProtoMessage()

+ func (x *GetValueRequest) GetKey() string

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

+ func (x *GetValueRequest) Reset()

+ func (x *GetValueRequest) String() string

+ type GetValueResponse struct

+ Value *StorageValue

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

+ func (*GetValueResponse) ProtoMessage()

+ func (x *GetValueResponse) GetValue() *StorageValue

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

+ func (x *GetValueResponse) Reset()

+ func (x *GetValueResponse) String() string

+ type IsMemberRequest struct

+ Peer string

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

+ func (*IsMemberRequest) ProtoMessage()

+ func (x *IsMemberRequest) GetPeer() string

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

+ func (x *IsMemberRequest) Reset()

+ func (x *IsMemberRequest) String() string

+ type IsMemberResponse struct

+ IsMember bool

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

+ func (*IsMemberResponse) ProtoMessage()

+ func (x *IsMemberResponse) GetIsMember() bool

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

+ func (x *IsMemberResponse) Reset()

+ func (x *IsMemberResponse) String() string

type JoinRequest

+ Multiaddrs []string

+ PreferStorageIpv6 bool

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

+ func (x *JoinRequest) GetPreferStorageIpv6() bool

+ type ListKeysRequest struct

+ Prefix string

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

+ func (*ListKeysRequest) ProtoMessage()

+ func (x *ListKeysRequest) GetPrefix() string

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

+ func (x *ListKeysRequest) Reset()

+ func (x *ListKeysRequest) String() string

+ type ListKeysResponse struct

+ Keys []string

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

+ func (*ListKeysResponse) ProtoMessage()

+ func (x *ListKeysResponse) GetKeys() []string

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

+ func (x *ListKeysResponse) Reset()

+ func (x *ListKeysResponse) String() string

+ type ListValuesRequest struct

+ Prefix string

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

+ func (*ListValuesRequest) ProtoMessage()

+ func (x *ListValuesRequest) GetPrefix() string

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

+ func (x *ListValuesRequest) Reset()

+ func (x *ListValuesRequest) String() string

+ type ListValuesResponse struct

+ Values []*StorageValue

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

+ func (*ListValuesResponse) ProtoMessage()

+ func (x *ListValuesResponse) GetValues() []*StorageValue

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

+ func (x *ListValuesResponse) Reset()

+ func (x *ListValuesResponse) String() string

type MembershipClient

+ GetStorageConfiguration func(ctx context.Context, in *StorageConfigurationRequest, opts ...grpc.CallOption) (*StorageConfigurationResponse, error)

type MembershipServer

+ GetStorageConfiguration func(context.Context, *StorageConfigurationRequest) (*StorageConfigurationResponse, error)

type MeshNode

+ JoinedAt *timestamppb.Timestamp

+ Multiaddrs []string

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

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

type NodeClient

+ ReceiveSignalChannel func(ctx context.Context, opts ...grpc.CallOption) (Node_ReceiveSignalChannelClient, error)

type NodeServer

+ ReceiveSignalChannel func(Node_ReceiveSignalChannelServer) error

+ type Node_ReceiveSignalChannelClient interface

+ Recv func() (*WebRTCSignal, error)

+ Send func(*WebRTCSignal) error

+ type Node_ReceiveSignalChannelServer interface

+ Recv func() (*WebRTCSignal, error)

+ Send func(*WebRTCSignal) error

type PluginInfo_PluginCapability

+ const PluginInfo_STORAGE_PROVIDER

+ const PluginInfo_STORAGE_QUERIER

+ type PrefixEvent struct

+ EventType PrefixEvent_EventType

+ Prefix string

+ Value *StorageValue

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

+ func (*PrefixEvent) ProtoMessage()

+ func (x *PrefixEvent) GetEventType() PrefixEvent_EventType

+ func (x *PrefixEvent) GetPrefix() string

+ func (x *PrefixEvent) GetValue() *StorageValue

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

+ func (x *PrefixEvent) Reset()

+ func (x *PrefixEvent) String() string

+ type PrefixEvent_EventType int32

+ const PrefixEvent_EventTypeRemoved

+ const PrefixEvent_EventTypeUnknown

+ const PrefixEvent_EventTypeUpdated

+ func (PrefixEvent_EventType) Descriptor() protoreflect.EnumDescriptor

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

+ func (PrefixEvent_EventType) Type() protoreflect.EnumType

+ func (x PrefixEvent_EventType) Enum() *PrefixEvent_EventType

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

+ func (x PrefixEvent_EventType) String() string

+ type PutValueRequest struct

+ Ttl *durationpb.Duration

+ Value *StorageValue

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

+ func (*PutValueRequest) ProtoMessage()

+ func (x *PutValueRequest) GetTtl() *durationpb.Duration

+ func (x *PutValueRequest) GetValue() *StorageValue

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

+ func (x *PutValueRequest) Reset()

+ func (x *PutValueRequest) String() string

+ type PutValueResponse struct

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

+ func (*PutValueResponse) ProtoMessage()

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

+ func (x *PutValueResponse) Reset()

+ func (x *PutValueResponse) String() string

+ type RemoveServerResponse struct

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

+ func (*RemoveServerResponse) ProtoMessage()

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

+ func (x *RemoveServerResponse) Reset()

+ func (x *RemoveServerResponse) String() string

+ type StorageConfigurationRequest struct

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

+ func (*StorageConfigurationRequest) ProtoMessage()

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

+ func (x *StorageConfigurationRequest) Reset()

+ func (x *StorageConfigurationRequest) String() string

+ type StorageConfigurationResponse struct

+ Servers []*StorageServer

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

+ func (*StorageConfigurationResponse) ProtoMessage()

+ func (x *StorageConfigurationResponse) GetServers() []*StorageServer

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

+ func (x *StorageConfigurationResponse) Reset()

+ func (x *StorageConfigurationResponse) String() string

+ type StoragePeer struct

+ Address string

+ ClusterStatus ClusterStatus

+ Id string

+ PublicKey string

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

+ func (*StoragePeer) ProtoMessage()

+ func (x *StoragePeer) GetAddress() string

+ func (x *StoragePeer) GetClusterStatus() ClusterStatus

+ func (x *StoragePeer) GetId() string

+ func (x *StoragePeer) GetPublicKey() string

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

+ func (x *StoragePeer) Reset()

+ func (x *StoragePeer) String() string

+ type StorageProviderPluginClient interface

+ AddObserver func(ctx context.Context, in *StoragePeer, opts ...grpc.CallOption) (*AddObserverResponse, error)

+ AddVoter func(ctx context.Context, in *StoragePeer, opts ...grpc.CallOption) (*AddVoterResponse, error)

+ Bootstrap func(ctx context.Context, in *BootstrapRequest, opts ...grpc.CallOption) (*BootstrapResponse, error)

+ DeleteValue func(ctx context.Context, in *DeleteValueRequest, opts ...grpc.CallOption) (*DeleteValueResponse, error)

+ DemoteVoter func(ctx context.Context, in *StoragePeer, opts ...grpc.CallOption) (*DemoteVoterResponse, error)

+ GetLeader func(ctx context.Context, in *GetLeaderRequest, opts ...grpc.CallOption) (*StoragePeer, error)

+ GetStatus func(ctx context.Context, in *StorageStatusRequest, opts ...grpc.CallOption) (*StorageStatus, error)

+ GetValue func(ctx context.Context, in *GetValueRequest, opts ...grpc.CallOption) (*GetValueResponse, error)

+ IsMember func(ctx context.Context, in *IsMemberRequest, opts ...grpc.CallOption) (*IsMemberResponse, error)

+ ListKeys func(ctx context.Context, in *ListKeysRequest, opts ...grpc.CallOption) (*ListKeysResponse, error)

+ ListValues func(ctx context.Context, in *ListValuesRequest, opts ...grpc.CallOption) (*ListValuesResponse, error)

+ PutValue func(ctx context.Context, in *PutValueRequest, opts ...grpc.CallOption) (*PutValueResponse, error)

+ RemovePeer func(ctx context.Context, in *StoragePeer, opts ...grpc.CallOption) (*RemoveServerResponse, error)

+ SubscribePrefix func(ctx context.Context, in *SubscribePrefixRequest, opts ...grpc.CallOption) (StorageProviderPlugin_SubscribePrefixClient, error)

+ func NewStorageProviderPluginClient(cc grpc.ClientConnInterface) StorageProviderPluginClient

+ type StorageProviderPluginServer interface

+ AddObserver func(context.Context, *StoragePeer) (*AddObserverResponse, error)

+ AddVoter func(context.Context, *StoragePeer) (*AddVoterResponse, error)

+ Bootstrap func(context.Context, *BootstrapRequest) (*BootstrapResponse, error)

+ DeleteValue func(context.Context, *DeleteValueRequest) (*DeleteValueResponse, error)

+ DemoteVoter func(context.Context, *StoragePeer) (*DemoteVoterResponse, error)

+ GetLeader func(context.Context, *GetLeaderRequest) (*StoragePeer, error)

+ GetStatus func(context.Context, *StorageStatusRequest) (*StorageStatus, error)

+ GetValue func(context.Context, *GetValueRequest) (*GetValueResponse, error)

+ IsMember func(context.Context, *IsMemberRequest) (*IsMemberResponse, error)

+ ListKeys func(context.Context, *ListKeysRequest) (*ListKeysResponse, error)

+ ListValues func(context.Context, *ListValuesRequest) (*ListValuesResponse, error)

+ PutValue func(context.Context, *PutValueRequest) (*PutValueResponse, error)

+ RemovePeer func(context.Context, *StoragePeer) (*RemoveServerResponse, error)

+ SubscribePrefix func(*SubscribePrefixRequest, StorageProviderPlugin_SubscribePrefixServer) error

+ type StorageProviderPlugin_SubscribePrefixClient interface

+ Recv func() (*PrefixEvent, error)

+ type StorageProviderPlugin_SubscribePrefixServer interface

+ Send func(*PrefixEvent) error

+ type StorageQuerierPluginClient interface

+ InjectQuerier func(ctx context.Context, opts ...grpc.CallOption) (StorageQuerierPlugin_InjectQuerierClient, error)

+ func NewStorageQuerierPluginClient(cc grpc.ClientConnInterface) StorageQuerierPluginClient

+ type StorageQuerierPluginServer interface

+ InjectQuerier func(StorageQuerierPlugin_InjectQuerierServer) error

+ type StorageQuerierPlugin_InjectQuerierClient interface

+ Recv func() (*PluginQuery, error)

+ Send func(*PluginQueryResult) error

+ type StorageQuerierPlugin_InjectQuerierServer interface

+ Recv func() (*PluginQueryResult, error)

+ Send func(*PluginQuery) error

+ type StorageQueryServiceClient interface

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (StorageQueryService_QueryClient, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (StorageQueryService_SubscribeClient, error)

+ func NewStorageQueryServiceClient(cc grpc.ClientConnInterface) StorageQueryServiceClient

+ type StorageQueryServiceServer interface

+ Publish func(context.Context, *PublishRequest) (*PublishResponse, error)

+ Query func(*QueryRequest, StorageQueryService_QueryServer) error

+ Subscribe func(*SubscribeRequest, StorageQueryService_SubscribeServer) error

+ type StorageQueryService_QueryClient interface

+ Recv func() (*QueryResponse, error)

+ type StorageQueryService_QueryServer interface

+ Send func(*QueryResponse) error

+ type StorageQueryService_SubscribeClient interface

+ Recv func() (*SubscriptionEvent, error)

+ type StorageQueryService_SubscribeServer interface

+ Send func(*SubscriptionEvent) error

type StorageServer

+ Address string

+ Id string

+ Suffrage ClusterStatus

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

+ func (*StorageServer) ProtoMessage()

+ func (x *StorageServer) GetAddress() string

+ func (x *StorageServer) GetId() string

+ func (x *StorageServer) GetSuffrage() ClusterStatus

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

+ func (x *StorageServer) Reset()

+ func (x *StorageServer) String() string

+ type StorageStatus struct

+ ClusterStatus ClusterStatus

+ IsWritable bool

+ Message string

+ Peers []*StoragePeer

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

+ func (*StorageStatus) ProtoMessage()

+ func (x *StorageStatus) GetClusterStatus() ClusterStatus

+ func (x *StorageStatus) GetIsWritable() bool

+ func (x *StorageStatus) GetMessage() string

+ func (x *StorageStatus) GetPeers() []*StoragePeer

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

+ func (x *StorageStatus) Reset()

+ func (x *StorageStatus) String() string

+ type StorageStatusRequest struct

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

+ func (*StorageStatusRequest) ProtoMessage()

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

+ func (x *StorageStatusRequest) Reset()

+ func (x *StorageStatusRequest) String() string

+ type StorageValue struct

+ Key string

+ Value string

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

+ func (*StorageValue) ProtoMessage()

+ func (x *StorageValue) GetKey() string

+ func (x *StorageValue) GetValue() string

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

+ func (x *StorageValue) Reset()

+ func (x *StorageValue) String() string

+ type SubscribePrefixRequest struct

+ Prefix string

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

+ func (*SubscribePrefixRequest) ProtoMessage()

+ func (x *SubscribePrefixRequest) GetPrefix() string

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

+ func (x *SubscribePrefixRequest) Reset()

+ func (x *SubscribePrefixRequest) String() string

type UnimplementedMembershipServer

+ func (UnimplementedMembershipServer) GetStorageConfiguration(context.Context, *StorageConfigurationRequest) (*StorageConfigurationResponse, error)

type UnimplementedNodeServer

+ func (UnimplementedNodeServer) ReceiveSignalChannel(Node_ReceiveSignalChannelServer) error

+ type UnimplementedStorageProviderPluginServer struct

+ func (UnimplementedStorageProviderPluginServer) AddObserver(context.Context, *StoragePeer) (*AddObserverResponse, error)

+ func (UnimplementedStorageProviderPluginServer) AddVoter(context.Context, *StoragePeer) (*AddVoterResponse, error)

+ func (UnimplementedStorageProviderPluginServer) Bootstrap(context.Context, *BootstrapRequest) (*BootstrapResponse, error)

+ func (UnimplementedStorageProviderPluginServer) DeleteValue(context.Context, *DeleteValueRequest) (*DeleteValueResponse, error)

+ func (UnimplementedStorageProviderPluginServer) DemoteVoter(context.Context, *StoragePeer) (*DemoteVoterResponse, error)

+ func (UnimplementedStorageProviderPluginServer) GetLeader(context.Context, *GetLeaderRequest) (*StoragePeer, error)

+ func (UnimplementedStorageProviderPluginServer) GetStatus(context.Context, *StorageStatusRequest) (*StorageStatus, error)

+ func (UnimplementedStorageProviderPluginServer) GetValue(context.Context, *GetValueRequest) (*GetValueResponse, error)

+ func (UnimplementedStorageProviderPluginServer) IsMember(context.Context, *IsMemberRequest) (*IsMemberResponse, error)

+ func (UnimplementedStorageProviderPluginServer) ListKeys(context.Context, *ListKeysRequest) (*ListKeysResponse, error)

+ func (UnimplementedStorageProviderPluginServer) ListValues(context.Context, *ListValuesRequest) (*ListValuesResponse, error)

+ func (UnimplementedStorageProviderPluginServer) PutValue(context.Context, *PutValueRequest) (*PutValueResponse, error)

+ func (UnimplementedStorageProviderPluginServer) RemovePeer(context.Context, *StoragePeer) (*RemoveServerResponse, error)

+ func (UnimplementedStorageProviderPluginServer) SubscribePrefix(*SubscribePrefixRequest, StorageProviderPlugin_SubscribePrefixServer) error

+ type UnimplementedStorageQuerierPluginServer struct

+ func (UnimplementedStorageQuerierPluginServer) InjectQuerier(StorageQuerierPlugin_InjectQuerierServer) error

+ type UnimplementedStorageQueryServiceServer struct

+ func (UnimplementedStorageQueryServiceServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

+ func (UnimplementedStorageQueryServiceServer) Query(*QueryRequest, StorageQueryService_QueryServer) error

+ func (UnimplementedStorageQueryServiceServer) Subscribe(*SubscribeRequest, StorageQueryService_SubscribeServer) error

type UnimplementedWebRTCServer

+ func (UnimplementedWebRTCServer) StartSignalChannel(WebRTC_StartSignalChannelServer) error

+ type UnsafeStorageProviderPluginServer interface

+ type UnsafeStorageQuerierPluginServer interface

+ type UnsafeStorageQueryServiceServer interface

type UpdateRequest

+ Multiaddrs []string

+ func (x *UpdateRequest) GetMultiaddrs() []string

type WebRTCClient

+ StartSignalChannel func(ctx context.Context, opts ...grpc.CallOption) (WebRTC_StartSignalChannelClient, error)

type WebRTCServer

+ StartSignalChannel func(WebRTC_StartSignalChannelServer) error

+ type WebRTCSignal struct

+ Candidate string

+ Description string

+ NodeId string

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

+ func (*WebRTCSignal) ProtoMessage()

+ func (x *WebRTCSignal) GetCandidate() string

+ func (x *WebRTCSignal) GetDescription() string

+ func (x *WebRTCSignal) GetNodeId() string

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

+ func (x *WebRTCSignal) Reset()

+ func (x *WebRTCSignal) String() string

+ type WebRTC_StartSignalChannelClient interface

+ Recv func() (*WebRTCSignal, error)

+ Send func(*WebRTCSignal) error

+ type WebRTC_StartSignalChannelServer interface

+ Recv func() (*WebRTCSignal, error)

+ Send func(*WebRTCSignal) error

type WireGuardPeer

+ Node *MeshNode

+ Proto ConnectProtocol

+ func (x *WireGuardPeer) GetNode() *MeshNode

+ func (x *WireGuardPeer) GetProto() ConnectProtocol

v0.3.0

Aug 28, 2023

Changes in this version

+ const Membership_SubscribePeers_FullMethodName

+ const RaftPlugin_RestoreSnapshot_FullMethodName

+ const RaftPlugin_Store_FullMethodName

+ const StoragePlugin_InjectQuerier_FullMethodName

+ const Storage_Publish_FullMethodName

+ const Storage_Query_FullMethodName

+ const Storage_Subscribe_FullMethodName

+ var Event_WatchEvent_name = map[int32]string

+ var Event_WatchEvent_value = map[string]int32

+ var File_v1_storage_proto protoreflect.FileDescriptor

+ var PluginInfo_PluginCapability_name = map[int32]string

+ var PluginInfo_PluginCapability_value = map[string]int32

+ var RaftPlugin_ServiceDesc = grpc.ServiceDesc

+ var Storage_ServiceDesc = grpc.ServiceDesc

+ func RegisterRaftPluginServer(s grpc.ServiceRegistrar, srv RaftPluginServer)

+ func RegisterStorageServer(s grpc.ServiceRegistrar, srv StorageServer)

+ type Event_WatchEvent int32

+ const Event_LEADER_CHANGE

+ const Event_NODE_JOIN

+ const Event_NODE_LEAVE

+ const Event_UNKNOWN

+ func (Event_WatchEvent) Descriptor() protoreflect.EnumDescriptor

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

+ func (Event_WatchEvent) Type() protoreflect.EnumType

+ func (x Event_WatchEvent) Enum() *Event_WatchEvent

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

+ func (x Event_WatchEvent) String() string

type Feature

+ const Feature_STORAGE

type MembershipClient

+ SubscribePeers func(ctx context.Context, in *SubscribePeersRequest, opts ...grpc.CallOption) (Membership_SubscribePeersClient, error)

type MembershipServer

+ SubscribePeers func(*SubscribePeersRequest, Membership_SubscribePeersServer) error

+ type Membership_SubscribePeersClient interface

+ Recv func() (*PeerConfigurations, error)

+ type Membership_SubscribePeersServer interface

+ Send func(*PeerConfigurations) error

+ type PeerConfigurations struct

+ DnsServers []string

+ IceServers []string

+ Peers []*WireGuardPeer

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

+ func (*PeerConfigurations) ProtoMessage()

+ func (x *PeerConfigurations) GetDnsServers() []string

+ func (x *PeerConfigurations) GetIceServers() []string

+ func (x *PeerConfigurations) GetPeers() []*WireGuardPeer

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

+ func (x *PeerConfigurations) Reset()

+ func (x *PeerConfigurations) String() string

+ type PluginInfo_PluginCapability int32

+ const PluginInfo_AUTH

+ const PluginInfo_IPAMV4

+ const PluginInfo_RAFT

+ const PluginInfo_STORAGE

+ const PluginInfo_UNKNOWN

+ const PluginInfo_WATCH

+ func (PluginInfo_PluginCapability) Descriptor() protoreflect.EnumDescriptor

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

+ func (PluginInfo_PluginCapability) Type() protoreflect.EnumType

+ func (x PluginInfo_PluginCapability) Enum() *PluginInfo_PluginCapability

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

+ func (x PluginInfo_PluginCapability) String() string

type PluginQuery_QueryCommand

+ const PluginQuery_DELETE

+ const PluginQuery_PUT

+ const PluginQuery_SUBSCRIBE

+ type RaftDataItem struct

+ Key string

+ Ttl *durationpb.Duration

+ Value string

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

+ func (*RaftDataItem) ProtoMessage()

+ func (x *RaftDataItem) GetKey() string

+ func (x *RaftDataItem) GetTtl() *durationpb.Duration

+ func (x *RaftDataItem) GetValue() string

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

+ func (x *RaftDataItem) Reset()

+ func (x *RaftDataItem) String() string

+ type RaftPluginClient interface

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

+ Store func(ctx context.Context, in *StoreLogRequest, opts ...grpc.CallOption) (*RaftApplyResponse, error)

+ func NewRaftPluginClient(cc grpc.ClientConnInterface) RaftPluginClient

+ type RaftPluginServer interface

+ RestoreSnapshot func(context.Context, *DataSnapshot) (*emptypb.Empty, error)

+ Store func(context.Context, *StoreLogRequest) (*RaftApplyResponse, error)

+ type RaftSnapshot struct

+ Kv map[string]*RaftDataItem

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

+ func (*RaftSnapshot) ProtoMessage()

+ func (x *RaftSnapshot) GetKv() map[string]*RaftDataItem

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

+ func (x *RaftSnapshot) Reset()

+ func (x *RaftSnapshot) String() string

+ type StorageClient interface

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Storage_QueryClient, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Storage_SubscribeClient, error)

+ func NewStorageClient(cc grpc.ClientConnInterface) StorageClient

type StoragePluginClient

+ InjectQuerier func(ctx context.Context, opts ...grpc.CallOption) (StoragePlugin_InjectQuerierClient, error)

type StoragePluginServer

+ InjectQuerier func(StoragePlugin_InjectQuerierServer) error

+ type StoragePlugin_InjectQuerierClient interface

+ Recv func() (*PluginQuery, error)

+ Send func(*PluginQueryResult) error

+ type StoragePlugin_InjectQuerierServer interface

+ Recv func() (*PluginQueryResult, error)

+ Send func(*PluginQuery) error

+ type StorageServer interface

+ Publish func(context.Context, *PublishRequest) (*PublishResponse, error)

+ Query func(*QueryRequest, Storage_QueryServer) error

+ Subscribe func(*SubscribeRequest, Storage_SubscribeServer) error

+ type Storage_QueryClient interface

+ Recv func() (*QueryResponse, error)

+ type Storage_QueryServer interface

+ Send func(*QueryResponse) error

+ type Storage_SubscribeClient interface

+ Recv func() (*SubscriptionEvent, error)

+ type Storage_SubscribeServer interface

+ Send func(*SubscriptionEvent) error

+ type SubscribePeersRequest struct

+ Id string

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

+ func (*SubscribePeersRequest) ProtoMessage()

+ func (x *SubscribePeersRequest) GetId() string

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

+ func (x *SubscribePeersRequest) Reset()

+ func (x *SubscribePeersRequest) String() string

type UnimplementedMembershipServer

+ func (UnimplementedMembershipServer) SubscribePeers(*SubscribePeersRequest, Membership_SubscribePeersServer) error

+ type UnimplementedRaftPluginServer struct

+ func (UnimplementedRaftPluginServer) RestoreSnapshot(context.Context, *DataSnapshot) (*emptypb.Empty, error)

+ func (UnimplementedRaftPluginServer) Store(context.Context, *StoreLogRequest) (*RaftApplyResponse, error)

type UnimplementedStoragePluginServer

+ func (UnimplementedStoragePluginServer) InjectQuerier(StoragePlugin_InjectQuerierServer) error

+ type UnimplementedStorageServer struct

+ func (UnimplementedStorageServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

+ func (UnimplementedStorageServer) Query(*QueryRequest, Storage_QueryServer) error

+ func (UnimplementedStorageServer) Subscribe(*SubscribeRequest, Storage_SubscribeServer) error

+ type UnsafeRaftPluginServer interface

+ type UnsafeStorageServer interface

type WireGuardPeer

+ Features []Feature

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

v0.2.4

Aug 23, 2023

Changes in this version

+ const AppDaemon_AnnounceDHT_FullMethodName

+ const AppDaemon_LeaveDHT_FullMethodName

+ type AnnounceDHTRequest struct

+ BootstrapServers []string

+ Psk string

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

+ func (*AnnounceDHTRequest) ProtoMessage()

+ func (x *AnnounceDHTRequest) GetBootstrapServers() []string

+ func (x *AnnounceDHTRequest) GetPsk() string

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

+ func (x *AnnounceDHTRequest) Reset()

+ func (x *AnnounceDHTRequest) String() string

+ type AnnounceDHTResponse struct

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

+ func (*AnnounceDHTResponse) ProtoMessage()

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

+ func (x *AnnounceDHTResponse) Reset()

+ func (x *AnnounceDHTResponse) String() string

type AppDaemonClient

+ AnnounceDHT func(ctx context.Context, in *AnnounceDHTRequest, opts ...grpc.CallOption) (*AnnounceDHTResponse, error)

+ LeaveDHT func(ctx context.Context, in *LeaveDHTRequest, opts ...grpc.CallOption) (*LeaveDHTResponse, error)

type AppDaemonServer

+ AnnounceDHT func(context.Context, *AnnounceDHTRequest) (*AnnounceDHTResponse, error)

+ LeaveDHT func(context.Context, *LeaveDHTRequest) (*LeaveDHTResponse, error)

type ConnectRequest

+ JoinPsk string

+ func (x *ConnectRequest) GetJoinPsk() string

type Feature

+ const Feature_MEMBERSHIP

+ type LeaveDHTRequest struct

+ Psk string

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

+ func (*LeaveDHTRequest) ProtoMessage()

+ func (x *LeaveDHTRequest) GetPsk() string

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

+ func (x *LeaveDHTRequest) Reset()

+ func (x *LeaveDHTRequest) String() string

+ type LeaveDHTResponse struct

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

+ func (*LeaveDHTResponse) ProtoMessage()

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

+ func (x *LeaveDHTResponse) Reset()

+ func (x *LeaveDHTResponse) String() string

type UnimplementedAppDaemonServer

+ func (UnimplementedAppDaemonServer) AnnounceDHT(context.Context, *AnnounceDHTRequest) (*AnnounceDHTResponse, error)

+ func (UnimplementedAppDaemonServer) LeaveDHT(context.Context, *LeaveDHTRequest) (*LeaveDHTResponse, error)

v0.2.3

Aug 22, 2023

v0.2.2

Aug 22, 2023

Changes in this version

+ const AppDaemon_Connect_FullMethodName

+ const AppDaemon_Disconnect_FullMethodName

+ const AppDaemon_Metrics_FullMethodName

+ const AppDaemon_Publish_FullMethodName

+ const AppDaemon_Query_FullMethodName

+ const AppDaemon_Status_FullMethodName

+ const AppDaemon_Subscribe_FullMethodName

+ const Membership_Apply_FullMethodName

+ const Membership_GetRaftConfiguration_FullMethodName

+ const Membership_Join_FullMethodName

+ const Membership_Leave_FullMethodName

+ const Membership_Update_FullMethodName

+ const Node_Publish_FullMethodName

+ const Node_Query_FullMethodName

+ const Node_Subscribe_FullMethodName

+ var AppDaemon_ServiceDesc = grpc.ServiceDesc

+ var File_v1_app_proto protoreflect.FileDescriptor

+ var File_v1_members_proto protoreflect.FileDescriptor

+ var Membership_ServiceDesc = grpc.ServiceDesc

+ var QueryRequest_QueryCommand_name = map[int32]string

+ var QueryRequest_QueryCommand_value = map[string]int32

+ var StatusResponse_ConnectionStatus_name = map[int32]string

+ var StatusResponse_ConnectionStatus_value = map[string]int32

+ func RegisterAppDaemonServer(s grpc.ServiceRegistrar, srv AppDaemonServer)

+ func RegisterMembershipServer(s grpc.ServiceRegistrar, srv MembershipServer)

+ type AppDaemonClient interface

+ Connect func(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)

+ Disconnect func(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (*DisconnectResponse, error)

+ Metrics func(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error)

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

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (AppDaemon_QueryClient, error)

+ Status func(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (AppDaemon_SubscribeClient, error)

+ func NewAppDaemonClient(cc grpc.ClientConnInterface) AppDaemonClient

+ type AppDaemonServer interface

+ Connect func(context.Context, *ConnectRequest) (*ConnectResponse, error)

+ Disconnect func(context.Context, *DisconnectRequest) (*DisconnectResponse, error)

+ Metrics func(context.Context, *MetricsRequest) (*MetricsResponse, error)

+ Publish func(context.Context, *PublishRequest) (*emptypb.Empty, error)

+ Query func(*QueryRequest, AppDaemon_QueryServer) error

+ Status func(context.Context, *StatusRequest) (*StatusResponse, error)

+ Subscribe func(*SubscribeRequest, AppDaemon_SubscribeServer) error

+ type AppDaemon_QueryClient interface

+ Recv func() (*QueryResponse, error)

+ type AppDaemon_QueryServer interface

+ Send func(*QueryResponse) error

+ type AppDaemon_SubscribeClient interface

+ Recv func() (*SubscriptionEvent, error)

+ type AppDaemon_SubscribeServer interface

+ Send func(*SubscriptionEvent) error

type ClusterStatus

+ const ClusterStatus_CLUSTER_NODE

+ type ConnectRequest struct

+ Config *structpb.Struct

+ DisableBootstrap bool

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

+ func (*ConnectRequest) ProtoMessage()

+ func (x *ConnectRequest) GetConfig() *structpb.Struct

+ func (x *ConnectRequest) GetDisableBootstrap() bool

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

+ func (x *ConnectRequest) Reset()

+ func (x *ConnectRequest) String() string

+ type ConnectResponse struct

+ Ipv4 string

+ Ipv6 string

+ MeshDomain string

+ NodeId string

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

+ func (*ConnectResponse) ProtoMessage()

+ func (x *ConnectResponse) GetIpv4() string

+ func (x *ConnectResponse) GetIpv6() string

+ func (x *ConnectResponse) GetMeshDomain() string

+ func (x *ConnectResponse) GetNodeId() string

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

+ func (x *ConnectResponse) Reset()

+ func (x *ConnectResponse) String() string

+ type DisconnectRequest struct

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

+ func (*DisconnectRequest) ProtoMessage()

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

+ func (x *DisconnectRequest) Reset()

+ func (x *DisconnectRequest) String() string

+ type DisconnectResponse struct

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

+ func (*DisconnectResponse) ProtoMessage()

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

+ func (x *DisconnectResponse) Reset()

+ func (x *DisconnectResponse) String() string

type Feature

+ const Feature_FORWARD_MESH_DNS

type JoinRequest

+ AsObserver bool

+ func (x *JoinRequest) GetAsObserver() bool

+ type LeaveResponse struct

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

+ func (*LeaveResponse) ProtoMessage()

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

+ func (x *LeaveResponse) Reset()

+ func (x *LeaveResponse) String() string

+ type MembershipClient interface

+ Apply func(ctx context.Context, in *RaftLogEntry, opts ...grpc.CallOption) (*RaftApplyResponse, error)

+ GetRaftConfiguration func(ctx context.Context, in *RaftConfigurationRequest, opts ...grpc.CallOption) (*RaftConfigurationResponse, error)

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

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

+ Update func(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)

+ func NewMembershipClient(cc grpc.ClientConnInterface) MembershipClient

+ type MembershipServer interface

+ Apply func(context.Context, *RaftLogEntry) (*RaftApplyResponse, error)

+ GetRaftConfiguration func(context.Context, *RaftConfigurationRequest) (*RaftConfigurationResponse, error)

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

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

+ Update func(context.Context, *UpdateRequest) (*UpdateResponse, error)

+ type MetricsRequest struct

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

+ func (*MetricsRequest) ProtoMessage()

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

+ func (x *MetricsRequest) Reset()

+ func (x *MetricsRequest) String() string

+ type MetricsResponse struct

+ Interfaces map[string]*InterfaceMetrics

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

+ func (*MetricsResponse) ProtoMessage()

+ func (x *MetricsResponse) GetInterfaces() map[string]*InterfaceMetrics

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

+ func (x *MetricsResponse) Reset()

+ func (x *MetricsResponse) String() string

type NodeClient

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Node_QueryClient, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Node_SubscribeClient, error)

type NodeServer

+ Publish func(context.Context, *PublishRequest) (*PublishResponse, error)

+ Query func(*QueryRequest, Node_QueryServer) error

+ Subscribe func(*SubscribeRequest, Node_SubscribeServer) error

+ type Node_QueryClient interface

+ Recv func() (*QueryResponse, error)

+ type Node_QueryServer interface

+ Send func(*QueryResponse) error

+ type Node_SubscribeClient interface

+ Recv func() (*SubscriptionEvent, error)

+ type Node_SubscribeServer interface

+ Send func(*SubscriptionEvent) error

type PluginQuery_QueryCommand

+ const PluginQuery_UNKNOWN

+ type PublishRequest struct

+ Key string

+ Ttl *durationpb.Duration

+ Value string

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

+ func (*PublishRequest) ProtoMessage()

+ func (x *PublishRequest) GetKey() string

+ func (x *PublishRequest) GetTtl() *durationpb.Duration

+ func (x *PublishRequest) GetValue() string

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

+ func (x *PublishRequest) Reset()

+ func (x *PublishRequest) String() string

+ type PublishResponse struct

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

+ func (*PublishResponse) ProtoMessage()

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

+ func (x *PublishResponse) Reset()

+ func (x *PublishResponse) String() string

+ type QueryRequest struct

+ Command QueryRequest_QueryCommand

+ Query string

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

+ func (*QueryRequest) ProtoMessage()

+ func (x *QueryRequest) GetCommand() QueryRequest_QueryCommand

+ func (x *QueryRequest) GetQuery() string

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

+ func (x *QueryRequest) Reset()

+ func (x *QueryRequest) String() string

+ type QueryRequest_QueryCommand int32

+ const QueryRequest_GET

+ const QueryRequest_ITER

+ const QueryRequest_LIST

+ const QueryRequest_UNKNOWN

+ func (QueryRequest_QueryCommand) Descriptor() protoreflect.EnumDescriptor

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

+ func (QueryRequest_QueryCommand) Type() protoreflect.EnumType

+ func (x QueryRequest_QueryCommand) Enum() *QueryRequest_QueryCommand

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

+ func (x QueryRequest_QueryCommand) String() string

+ type QueryResponse struct

+ Error string

+ Key string

+ Value []string

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

+ func (*QueryResponse) ProtoMessage()

+ func (x *QueryResponse) GetError() string

+ func (x *QueryResponse) GetKey() string

+ func (x *QueryResponse) GetValue() []string

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

+ func (x *QueryResponse) Reset()

+ func (x *QueryResponse) String() string

+ type RaftConfigurationRequest struct

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

+ func (*RaftConfigurationRequest) ProtoMessage()

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

+ func (x *RaftConfigurationRequest) Reset()

+ func (x *RaftConfigurationRequest) String() string

+ type RaftConfigurationResponse struct

+ Servers []*RaftServer

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

+ func (*RaftConfigurationResponse) ProtoMessage()

+ func (x *RaftConfigurationResponse) GetServers() []*RaftServer

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

+ func (x *RaftConfigurationResponse) Reset()

+ func (x *RaftConfigurationResponse) String() string

type RaftLogEntry

+ Ttl *durationpb.Duration

+ func (x *RaftLogEntry) GetTtl() *durationpb.Duration

+ type RaftServer struct

+ Address string

+ Id string

+ Suffrage ClusterStatus

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

+ func (*RaftServer) ProtoMessage()

+ func (x *RaftServer) GetAddress() string

+ func (x *RaftServer) GetId() string

+ func (x *RaftServer) GetSuffrage() ClusterStatus

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

+ func (x *RaftServer) Reset()

+ func (x *RaftServer) String() string

type RuleResource

+ const RuleResource_RESOURCE_OBSERVERS

+ const RuleResource_RESOURCE_PUBSUB

+ type StatusRequest struct

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

+ func (*StatusRequest) ProtoMessage()

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

+ func (x *StatusRequest) Reset()

+ func (x *StatusRequest) String() string

+ type StatusResponse struct

+ ConnectionStatus StatusResponse_ConnectionStatus

+ Node *MeshNode

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

+ func (*StatusResponse) ProtoMessage()

+ func (x *StatusResponse) GetConnectionStatus() StatusResponse_ConnectionStatus

+ func (x *StatusResponse) GetNode() *MeshNode

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

+ func (x *StatusResponse) Reset()

+ func (x *StatusResponse) String() string

+ type StatusResponse_ConnectionStatus int32

+ const StatusResponse_CONNECTED

+ const StatusResponse_CONNECTING

+ const StatusResponse_DISCONNECTED

+ func (StatusResponse_ConnectionStatus) Descriptor() protoreflect.EnumDescriptor

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

+ func (StatusResponse_ConnectionStatus) Type() protoreflect.EnumType

+ func (x StatusResponse_ConnectionStatus) Enum() *StatusResponse_ConnectionStatus

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

+ func (x StatusResponse_ConnectionStatus) String() string

+ type SubscribeRequest struct

+ Prefix string

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

+ func (*SubscribeRequest) ProtoMessage()

+ func (x *SubscribeRequest) GetPrefix() string

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

+ func (x *SubscribeRequest) Reset()

+ func (x *SubscribeRequest) String() string

+ type SubscriptionEvent struct

+ Key string

+ Value string

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

+ func (*SubscriptionEvent) ProtoMessage()

+ func (x *SubscriptionEvent) GetKey() string

+ func (x *SubscriptionEvent) GetValue() string

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

+ func (x *SubscriptionEvent) Reset()

+ func (x *SubscriptionEvent) String() string

+ type UnimplementedAppDaemonServer struct

+ func (UnimplementedAppDaemonServer) Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)

+ func (UnimplementedAppDaemonServer) Disconnect(context.Context, *DisconnectRequest) (*DisconnectResponse, error)

+ func (UnimplementedAppDaemonServer) Metrics(context.Context, *MetricsRequest) (*MetricsResponse, error)

+ func (UnimplementedAppDaemonServer) Publish(context.Context, *PublishRequest) (*emptypb.Empty, error)

+ func (UnimplementedAppDaemonServer) Query(*QueryRequest, AppDaemon_QueryServer) error

+ func (UnimplementedAppDaemonServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

+ func (UnimplementedAppDaemonServer) Subscribe(*SubscribeRequest, AppDaemon_SubscribeServer) error

+ type UnimplementedMembershipServer struct

+ func (UnimplementedMembershipServer) Apply(context.Context, *RaftLogEntry) (*RaftApplyResponse, error)

+ func (UnimplementedMembershipServer) GetRaftConfiguration(context.Context, *RaftConfigurationRequest) (*RaftConfigurationResponse, error)

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

+ func (UnimplementedMembershipServer) Leave(context.Context, *LeaveRequest) (*LeaveResponse, error)

+ func (UnimplementedMembershipServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)

type UnimplementedNodeServer

+ func (UnimplementedNodeServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

+ func (UnimplementedNodeServer) Query(*QueryRequest, Node_QueryServer) error

+ func (UnimplementedNodeServer) Subscribe(*SubscribeRequest, Node_SubscribeServer) error

+ type UnsafeAppDaemonServer interface

+ type UnsafeMembershipServer interface

+ type UpdateRequest struct

+ AsVoter bool

+ Features []Feature

+ GrpcPort int32

+ Id string

+ MeshdnsPort int32

+ PrimaryEndpoint string

+ PublicKey string

+ RaftPort int32

+ Routes []string

+ WireguardEndpoints []string

+ ZoneAwarenessId string

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

+ func (*UpdateRequest) ProtoMessage()

+ func (x *UpdateRequest) GetAsVoter() bool

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

+ func (x *UpdateRequest) GetGrpcPort() int32

+ func (x *UpdateRequest) GetId() string

+ func (x *UpdateRequest) GetMeshdnsPort() int32

+ func (x *UpdateRequest) GetPrimaryEndpoint() string

+ func (x *UpdateRequest) GetPublicKey() string

+ func (x *UpdateRequest) GetRaftPort() int32

+ func (x *UpdateRequest) GetRoutes() []string

+ func (x *UpdateRequest) GetWireguardEndpoints() []string

+ func (x *UpdateRequest) GetZoneAwarenessId() string

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

+ func (x *UpdateRequest) Reset()

+ func (x *UpdateRequest) String() string

+ type UpdateResponse struct

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

+ func (*UpdateResponse) ProtoMessage()

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

+ func (x *UpdateResponse) Reset()

+ func (x *UpdateResponse) String() string

type WireGuardPeer

+ GrpcPort int32

+ RaftMember bool

+ func (x *WireGuardPeer) GetGrpcPort() int32

+ func (x *WireGuardPeer) GetRaftMember() bool

v0.2.1

Jul 29, 2023

Changes in this version

type JoinRequest

+ Features []Feature

+ MeshdnsPort int32

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

+ func (x *JoinRequest) GetMeshdnsPort() int32

type JoinResponse

+ DnsServers []string

+ func (x *JoinResponse) GetDnsServers() []string

type MeshNode

+ Features []Feature

+ MeshdnsPort int32

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

+ func (x *MeshNode) GetMeshdnsPort() int32

v0.2.0

Jul 25, 2023

Changes in this version

+ var PluginQuery_QueryCommand_name = map[int32]string

+ var PluginQuery_QueryCommand_value = map[string]int32

type JoinResponse

+ MeshDomain string

+ func (x *JoinResponse) GetMeshDomain() string

+ type PluginQuery struct

+ Command PluginQuery_QueryCommand

+ Id string

+ Query string

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

+ func (*PluginQuery) ProtoMessage()

+ func (x *PluginQuery) GetCommand() PluginQuery_QueryCommand

+ func (x *PluginQuery) GetId() string

+ func (x *PluginQuery) GetQuery() string

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

+ func (x *PluginQuery) Reset()

+ func (x *PluginQuery) String() string

+ type PluginQueryResult struct

+ Error string

+ Id string

+ Key string

+ Value []string

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

+ func (*PluginQueryResult) ProtoMessage()

+ func (x *PluginQueryResult) GetError() string

+ func (x *PluginQueryResult) GetId() string

+ func (x *PluginQueryResult) GetKey() string

+ func (x *PluginQueryResult) GetValue() []string

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

+ func (x *PluginQueryResult) Reset()

+ func (x *PluginQueryResult) String() string

+ type PluginQuery_QueryCommand int32

+ const PluginQuery_GET

+ const PluginQuery_ITER

+ const PluginQuery_LIST

+ func (PluginQuery_QueryCommand) Descriptor() protoreflect.EnumDescriptor

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

+ func (PluginQuery_QueryCommand) Type() protoreflect.EnumType

+ func (x PluginQuery_QueryCommand) Enum() *PluginQuery_QueryCommand

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

+ func (x PluginQuery_QueryCommand) String() string

type RaftCommandType

+ const RaftCommandType_DELETE

+ const RaftCommandType_PUT

type RaftLogEntry

+ Key string

+ Value string

+ func (x *RaftLogEntry) GetKey() string

+ func (x *RaftLogEntry) GetValue() string

v0.1.4

Jul 21, 2023

Changes in this version

+ const AuthPlugin_Authenticate_FullMethodName

+ const IPAMPlugin_Allocate_FullMethodName

+ const IPAMPlugin_Release_FullMethodName

+ const Plugin_Close_FullMethodName

+ const Plugin_InjectQuerier_FullMethodName

+ const StoragePlugin_RestoreSnapshot_FullMethodName

+ const StoragePlugin_Store_FullMethodName

+ const WatchPlugin_Emit_FullMethodName

+ var AllocateIPRequest_IPVersion_name = map[int32]string

+ var AllocateIPRequest_IPVersion_value = map[string]int32

+ var AuthPlugin_ServiceDesc = grpc.ServiceDesc

+ var IPAMPlugin_ServiceDesc = grpc.ServiceDesc

+ var StoragePlugin_ServiceDesc = grpc.ServiceDesc

+ var WatchPlugin_ServiceDesc = grpc.ServiceDesc

+ func RegisterAuthPluginServer(s grpc.ServiceRegistrar, srv AuthPluginServer)

+ func RegisterIPAMPluginServer(s grpc.ServiceRegistrar, srv IPAMPluginServer)

+ func RegisterStoragePluginServer(s grpc.ServiceRegistrar, srv StoragePluginServer)

+ func RegisterWatchPluginServer(s grpc.ServiceRegistrar, srv WatchPluginServer)

+ type AllocateIPRequest struct

+ NodeId string

+ Subnet string

+ Version AllocateIPRequest_IPVersion

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

+ func (*AllocateIPRequest) ProtoMessage()

+ func (x *AllocateIPRequest) GetNodeId() string

+ func (x *AllocateIPRequest) GetSubnet() string

+ func (x *AllocateIPRequest) GetVersion() AllocateIPRequest_IPVersion

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

+ func (x *AllocateIPRequest) Reset()

+ func (x *AllocateIPRequest) String() string

+ type AllocateIPRequest_IPVersion int32

+ const AllocateIPRequest_IP_VERSION_4

+ const AllocateIPRequest_IP_VERSION_6

+ const AllocateIPRequest_IP_VERSION_UNKNOWN

+ func (AllocateIPRequest_IPVersion) Descriptor() protoreflect.EnumDescriptor

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

+ func (AllocateIPRequest_IPVersion) Type() protoreflect.EnumType

+ func (x AllocateIPRequest_IPVersion) Enum() *AllocateIPRequest_IPVersion

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

+ func (x AllocateIPRequest_IPVersion) String() string

+ type AllocatedIP struct

+ Ip string

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

+ func (*AllocatedIP) ProtoMessage()

+ func (x *AllocatedIP) GetIp() string

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

+ func (x *AllocatedIP) Reset()

+ func (x *AllocatedIP) String() string

+ type AuthPluginClient interface

+ Authenticate func(ctx context.Context, in *AuthenticationRequest, opts ...grpc.CallOption) (*AuthenticationResponse, error)

+ func NewAuthPluginClient(cc grpc.ClientConnInterface) AuthPluginClient

+ type AuthPluginServer interface

+ Authenticate func(context.Context, *AuthenticationRequest) (*AuthenticationResponse, error)

+ type IPAMPluginClient interface

+ Allocate func(ctx context.Context, in *AllocateIPRequest, opts ...grpc.CallOption) (*AllocatedIP, error)

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

+ func NewIPAMPluginClient(cc grpc.ClientConnInterface) IPAMPluginClient

+ type IPAMPluginServer interface

+ Allocate func(context.Context, *AllocateIPRequest) (*AllocatedIP, error)

+ Release func(context.Context, *ReleaseIPRequest) (*emptypb.Empty, error)

type JoinResponse

+ NetworkIpv4 string

+ func (x *JoinResponse) GetNetworkIpv4() string

type PluginCapability

+ const PluginCapability_PLUGIN_CAPABILITY_IPAMV4

+ const PluginCapability_PLUGIN_CAPABILITY_IPAMV6

type PluginClient

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

+ InjectQuerier func(ctx context.Context, opts ...grpc.CallOption) (Plugin_InjectQuerierClient, error)

+ type PluginSQLQuery struct

+ Id string

+ Query *SQLQuery

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

+ func (*PluginSQLQuery) ProtoMessage()

+ func (x *PluginSQLQuery) GetId() string

+ func (x *PluginSQLQuery) GetQuery() *SQLQuery

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

+ func (x *PluginSQLQuery) Reset()

+ func (x *PluginSQLQuery) String() string

+ type PluginSQLQueryResult struct

+ Error string

+ Id string

+ Result *SQLQueryResult

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

+ func (*PluginSQLQueryResult) ProtoMessage()

+ func (x *PluginSQLQueryResult) GetError() string

+ func (x *PluginSQLQueryResult) GetId() string

+ func (x *PluginSQLQueryResult) GetResult() *SQLQueryResult

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

+ func (x *PluginSQLQueryResult) Reset()

+ func (x *PluginSQLQueryResult) String() string

type PluginServer

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

+ InjectQuerier func(Plugin_InjectQuerierServer) error

+ type Plugin_InjectQuerierClient interface

+ Recv func() (*PluginSQLQuery, error)

+ Send func(*PluginSQLQueryResult) error

+ type Plugin_InjectQuerierServer interface

+ Recv func() (*PluginSQLQueryResult, error)

+ Send func(*PluginSQLQuery) error

+ type ReleaseIPRequest struct

+ Ip string

+ NodeId string

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

+ func (*ReleaseIPRequest) ProtoMessage()

+ func (x *ReleaseIPRequest) GetIp() string

+ func (x *ReleaseIPRequest) GetNodeId() string

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

+ func (x *ReleaseIPRequest) Reset()

+ func (x *ReleaseIPRequest) String() string

+ type StoragePluginClient interface

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

+ Store func(ctx context.Context, in *StoreLogRequest, opts ...grpc.CallOption) (*RaftApplyResponse, error)

+ func NewStoragePluginClient(cc grpc.ClientConnInterface) StoragePluginClient

+ type StoragePluginServer interface

+ RestoreSnapshot func(context.Context, *DataSnapshot) (*emptypb.Empty, error)

+ Store func(context.Context, *StoreLogRequest) (*RaftApplyResponse, error)

+ type UnimplementedAuthPluginServer struct

+ func (UnimplementedAuthPluginServer) Authenticate(context.Context, *AuthenticationRequest) (*AuthenticationResponse, error)

+ type UnimplementedIPAMPluginServer struct

+ func (UnimplementedIPAMPluginServer) Allocate(context.Context, *AllocateIPRequest) (*AllocatedIP, error)

+ func (UnimplementedIPAMPluginServer) Release(context.Context, *ReleaseIPRequest) (*emptypb.Empty, error)

type UnimplementedPluginServer

+ func (UnimplementedPluginServer) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

+ func (UnimplementedPluginServer) InjectQuerier(Plugin_InjectQuerierServer) error

+ type UnimplementedStoragePluginServer struct

+ func (UnimplementedStoragePluginServer) RestoreSnapshot(context.Context, *DataSnapshot) (*emptypb.Empty, error)

+ func (UnimplementedStoragePluginServer) Store(context.Context, *StoreLogRequest) (*RaftApplyResponse, error)

+ type UnimplementedWatchPluginServer struct

+ func (UnimplementedWatchPluginServer) Emit(context.Context, *Event) (*emptypb.Empty, error)

+ type UnsafeAuthPluginServer interface

+ type UnsafeIPAMPluginServer interface

+ type UnsafeStoragePluginServer interface

+ type UnsafeWatchPluginServer interface

+ type WatchPluginClient interface

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

+ func NewWatchPluginClient(cc grpc.ClientConnInterface) WatchPluginClient

+ type WatchPluginServer interface

+ Emit func(context.Context, *Event) (*emptypb.Empty, error)

v0.1.3

Jun 27, 2023

Changes in this version

+ const Admin_DeleteEdge_FullMethodName

+ const Admin_GetEdge_FullMethodName

+ const Admin_ListEdges_FullMethodName

+ const Admin_PutEdge_FullMethodName

+ const Node_Snapshot_FullMethodName

+ const Plugin_RestoreSnapshot_FullMethodName

+ var EdgeAttributes_name = map[int32]string

+ var EdgeAttributes_value = map[string]int32

+ var RuleVerb_name = map[int32]string

+ var RuleVerb_value = map[string]int32

type AdminClient

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

+ GetEdge func(ctx context.Context, in *MeshEdge, opts ...grpc.CallOption) (*MeshEdge, error)

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

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

type AdminServer

+ DeleteEdge func(context.Context, *MeshEdge) (*emptypb.Empty, error)

+ GetEdge func(context.Context, *MeshEdge) (*MeshEdge, error)

+ ListEdges func(context.Context, *emptypb.Empty) (*MeshEdges, error)

+ PutEdge func(context.Context, *MeshEdge) (*emptypb.Empty, error)

+ type DataSnapshot struct

+ Data []byte

+ Index uint64

+ Term uint64

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

+ func (*DataSnapshot) ProtoMessage()

+ func (x *DataSnapshot) GetData() []byte

+ func (x *DataSnapshot) GetIndex() uint64

+ func (x *DataSnapshot) GetTerm() uint64

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

+ func (x *DataSnapshot) Reset()

+ func (x *DataSnapshot) String() string

+ type EdgeAttributes int32

+ const EdgeAttributes_EDGE_ATTRIBUTE_ICE

+ const EdgeAttributes_EDGE_ATTRIBUTE_UNKNOWN

+ func (EdgeAttributes) Descriptor() protoreflect.EnumDescriptor

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

+ func (EdgeAttributes) Type() protoreflect.EnumType

+ func (x EdgeAttributes) Enum() *EdgeAttributes

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

+ func (x EdgeAttributes) String() string

type JoinRequest

+ DirectPeers []string

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

type JoinResponse

+ IceServers []string

+ func (x *JoinResponse) GetIceServers() []string

type MeshEdge

+ Attributes map[string]string

+ func (x *MeshEdge) GetAttributes() map[string]string

+ type MeshEdges struct

+ Items []*MeshEdge

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

+ func (*MeshEdges) ProtoMessage()

+ func (x *MeshEdges) GetItems() []*MeshEdge

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

+ func (x *MeshEdges) Reset()

+ func (x *MeshEdges) String() string

type NodeClient

+ Snapshot func(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (*SnapshotResponse, error)

type NodeServer

+ Snapshot func(context.Context, *SnapshotRequest) (*SnapshotResponse, error)

type PluginClient

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

type PluginServer

+ RestoreSnapshot func(context.Context, *DataSnapshot) (*emptypb.Empty, error)

type RuleResource

+ const RuleResource_RESOURCE_EDGES

+ type RuleVerb int32

+ const RuleVerb_VERB_ALL

+ const RuleVerb_VERB_DELETE

+ const RuleVerb_VERB_GET

+ const RuleVerb_VERB_PUT

+ const RuleVerb_VERB_UNKNOWN

+ func (RuleVerb) Descriptor() protoreflect.EnumDescriptor

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

+ func (RuleVerb) Type() protoreflect.EnumType

+ func (x RuleVerb) Enum() *RuleVerb

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

+ func (x RuleVerb) String() string

+ type SnapshotRequest struct

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

+ func (*SnapshotRequest) ProtoMessage()

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

+ func (x *SnapshotRequest) Reset()

+ func (x *SnapshotRequest) String() string

+ type SnapshotResponse struct

+ Snapshot []byte

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

+ func (*SnapshotResponse) ProtoMessage()

+ func (x *SnapshotResponse) GetSnapshot() []byte

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

+ func (x *SnapshotResponse) Reset()

+ func (x *SnapshotResponse) String() string

type UnimplementedAdminServer

+ func (UnimplementedAdminServer) DeleteEdge(context.Context, *MeshEdge) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) GetEdge(context.Context, *MeshEdge) (*MeshEdge, error)

+ func (UnimplementedAdminServer) ListEdges(context.Context, *emptypb.Empty) (*MeshEdges, error)

+ func (UnimplementedAdminServer) PutEdge(context.Context, *MeshEdge) (*emptypb.Empty, error)

type UnimplementedNodeServer

+ func (UnimplementedNodeServer) Snapshot(context.Context, *SnapshotRequest) (*SnapshotResponse, error)

type UnimplementedPluginServer

+ func (UnimplementedPluginServer) RestoreSnapshot(context.Context, *DataSnapshot) (*emptypb.Empty, error)

type WireGuardPeer

+ Ice bool

+ func (x *WireGuardPeer) GetIce() bool

v0.1.2

Jun 13, 2023

Changes in this version

+ type StoreLogRequest struct

+ Index uint64

+ Log *RaftLogEntry

+ Term uint64

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

+ func (*StoreLogRequest) ProtoMessage()

+ func (x *StoreLogRequest) GetIndex() uint64

+ func (x *StoreLogRequest) GetLog() *RaftLogEntry

+ func (x *StoreLogRequest) GetTerm() uint64

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

+ func (x *StoreLogRequest) Reset()

+ func (x *StoreLogRequest) String() string

v0.1.1

Jun 13, 2023

v0.1.0

Jun 11, 2023

Changes in this version

+ const Admin_DeleteGroup_FullMethodName

+ const Admin_DeleteNetworkACL_FullMethodName

+ const Admin_DeleteRoleBinding_FullMethodName

+ const Admin_DeleteRole_FullMethodName

+ const Admin_DeleteRoute_FullMethodName

+ const Admin_GetGroup_FullMethodName

+ const Admin_GetNetworkACL_FullMethodName

+ const Admin_GetRoleBinding_FullMethodName

+ const Admin_GetRole_FullMethodName

+ const Admin_GetRoute_FullMethodName

+ const Admin_ListGroups_FullMethodName

+ const Admin_ListNetworkACLs_FullMethodName

+ const Admin_ListRoleBindings_FullMethodName

+ const Admin_ListRoles_FullMethodName

+ const Admin_ListRoutes_FullMethodName

+ const Admin_PutGroup_FullMethodName

+ const Admin_PutNetworkACL_FullMethodName

+ const Admin_PutRoleBinding_FullMethodName

+ const Admin_PutRole_FullMethodName

+ const Admin_PutRoute_FullMethodName

+ const Mesh_GetMeshGraph_FullMethodName

+ const Mesh_GetNode_FullMethodName

+ const Mesh_ListNodes_FullMethodName

+ const Node_GetStatus_FullMethodName

+ const Node_Join_FullMethodName

+ const Node_Leave_FullMethodName

+ const Node_NegotiateDataChannel_FullMethodName

+ const PeerDiscovery_ListPeers_FullMethodName

+ const Plugin_Authenticate_FullMethodName

+ const Plugin_Configure_FullMethodName

+ const Plugin_Emit_FullMethodName

+ const Plugin_GetInfo_FullMethodName

+ const Plugin_Store_FullMethodName

+ const WebRTC_StartDataChannel_FullMethodName

+ var ACLAction_name = map[int32]string

+ var ACLAction_value = map[string]int32

+ var Admin_ServiceDesc = grpc.ServiceDesc

+ var ClusterStatus_name = map[int32]string

+ var ClusterStatus_value = map[string]int32

+ 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_admin_proto protoreflect.FileDescriptor

+ var File_v1_mesh_proto protoreflect.FileDescriptor

+ var File_v1_network_acls_proto protoreflect.FileDescriptor

+ var File_v1_node_proto protoreflect.FileDescriptor

+ var File_v1_peer_discovery_proto protoreflect.FileDescriptor

+ var File_v1_plugin_proto protoreflect.FileDescriptor

+ var File_v1_raft_proto protoreflect.FileDescriptor

+ var File_v1_rbac_proto protoreflect.FileDescriptor

+ var File_v1_webrtc_proto protoreflect.FileDescriptor

+ var Mesh_ServiceDesc = grpc.ServiceDesc

+ var Node_ServiceDesc = grpc.ServiceDesc

+ var PeerDiscovery_ServiceDesc = grpc.ServiceDesc

+ var PluginCapability_name = map[int32]string

+ var PluginCapability_value = map[string]int32

+ var Plugin_ServiceDesc = grpc.ServiceDesc

+ var RaftCommandType_name = map[int32]string

+ var RaftCommandType_value = map[string]int32

+ var RuleResource_name = map[int32]string

+ var RuleResource_value = map[string]int32

+ var RuleVerbs_name = map[int32]string

+ var RuleVerbs_value = map[string]int32

+ var SQLParameterType_name = map[int32]string

+ var SQLParameterType_value = map[string]int32

+ var SubjectType_name = map[int32]string

+ var SubjectType_value = map[string]int32

+ var WatchEvent_name = map[int32]string

+ var WatchEvent_value = map[string]int32

+ var WebRTC_ServiceDesc = grpc.ServiceDesc

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

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

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

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

+ func RegisterPluginServer(s grpc.ServiceRegistrar, srv PluginServer)

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

+ type ACLAction int32

+ const ACLAction_ACTION_ACCEPT

+ const ACLAction_ACTION_DENY

+ const ACLAction_ACTION_UNKNOWN

+ 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

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

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

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

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

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

+ GetGroup func(ctx context.Context, in *Group, opts ...grpc.CallOption) (*Group, error)

+ GetNetworkACL func(ctx context.Context, in *NetworkACL, opts ...grpc.CallOption) (*NetworkACL, error)

+ GetRole func(ctx context.Context, in *Role, opts ...grpc.CallOption) (*Role, error)

+ GetRoleBinding func(ctx context.Context, in *RoleBinding, opts ...grpc.CallOption) (*RoleBinding, error)

+ GetRoute func(ctx context.Context, in *Route, opts ...grpc.CallOption) (*Route, error)

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

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

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

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

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

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

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

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

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

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

+ func NewAdminClient(cc grpc.ClientConnInterface) AdminClient

+ type AdminServer interface

+ DeleteGroup func(context.Context, *Group) (*emptypb.Empty, error)

+ DeleteNetworkACL func(context.Context, *NetworkACL) (*emptypb.Empty, error)

+ DeleteRole func(context.Context, *Role) (*emptypb.Empty, error)

+ DeleteRoleBinding func(context.Context, *RoleBinding) (*emptypb.Empty, error)

+ DeleteRoute func(context.Context, *Route) (*emptypb.Empty, error)

+ GetGroup func(context.Context, *Group) (*Group, error)

+ GetNetworkACL func(context.Context, *NetworkACL) (*NetworkACL, error)

+ GetRole func(context.Context, *Role) (*Role, error)

+ GetRoleBinding func(context.Context, *RoleBinding) (*RoleBinding, error)

+ GetRoute func(context.Context, *Route) (*Route, error)

+ ListGroups func(context.Context, *emptypb.Empty) (*Groups, error)

+ ListNetworkACLs func(context.Context, *emptypb.Empty) (*NetworkACLs, error)

+ ListRoleBindings func(context.Context, *emptypb.Empty) (*RoleBindings, error)

+ ListRoles func(context.Context, *emptypb.Empty) (*Roles, error)

+ ListRoutes func(context.Context, *emptypb.Empty) (*Routes, error)

+ PutGroup func(context.Context, *Group) (*emptypb.Empty, error)

+ PutNetworkACL func(context.Context, *NetworkACL) (*emptypb.Empty, error)

+ PutRole func(context.Context, *Role) (*emptypb.Empty, error)

+ PutRoleBinding func(context.Context, *RoleBinding) (*emptypb.Empty, error)

+ PutRoute func(context.Context, *Route) (*emptypb.Empty, error)

+ type AuthenticationRequest struct

+ Certificates [][]byte

+ Headers map[string]string

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

+ func (*AuthenticationRequest) ProtoMessage()

+ func (x *AuthenticationRequest) GetCertificates() [][]byte

+ func (x *AuthenticationRequest) GetHeaders() map[string]string

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

+ func (x *AuthenticationRequest) Reset()

+ func (x *AuthenticationRequest) String() string

+ type AuthenticationResponse struct

+ Id string

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

+ func (*AuthenticationResponse) ProtoMessage()

+ func (x *AuthenticationResponse) GetId() string

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

+ func (x *AuthenticationResponse) Reset()

+ func (x *AuthenticationResponse) String() string

+ type ClusterStatus int32

+ const ClusterStatus_CLUSTER_LEADER

+ const ClusterStatus_CLUSTER_NON_VOTER

+ const ClusterStatus_CLUSTER_STATUS_UNKNOWN

+ const ClusterStatus_CLUSTER_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 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

+ Src 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) GetSrc() 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 Event struct

+ Event isEvent_Event

+ Type WatchEvent

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

+ func (*Event) ProtoMessage()

+ func (m *Event) GetEvent() isEvent_Event

+ func (x *Event) GetNode() *MeshNode

+ func (x *Event) GetType() WatchEvent

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

+ func (x *Event) Reset()

+ func (x *Event) String() string

+ type Event_Node struct

+ Node *MeshNode

+ type Feature int32

+ const Feature_ADMIN_API

+ const Feature_FEATURE_NONE

+ const Feature_ICE_NEGOTIATION

+ const Feature_LEADER_PROXY

+ const Feature_MESH_API

+ const Feature_MESH_DNS

+ const Feature_METRICS

+ const Feature_NODES

+ const Feature_PEER_DISCOVERY

+ const Feature_TURN_SERVER

+ 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 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 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 Group struct

+ Name string

+ Subjects []*Subject

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

+ func (*Group) ProtoMessage()

+ func (x *Group) GetName() string

+ func (x *Group) GetSubjects() []*Subject

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

+ func (x *Group) Reset()

+ func (x *Group) String() string

+ type Groups struct

+ Items []*Group

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

+ func (*Groups) ProtoMessage()

+ func (x *Groups) GetItems() []*Group

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

+ func (x *Groups) Reset()

+ func (x *Groups) String() string

+ type InterfaceMetrics struct

+ AddressV4 string

+ AddressV6 string

+ DeviceName string

+ ListenPort int32

+ NumPeers int32

+ Peers []*PeerMetrics

+ PublicKey string

+ TotalReceiveBytes uint64

+ TotalTransmitBytes uint64

+ Type string

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

+ func (*InterfaceMetrics) ProtoMessage()

+ func (x *InterfaceMetrics) GetAddressV4() string

+ func (x *InterfaceMetrics) GetAddressV6() string

+ func (x *InterfaceMetrics) GetDeviceName() string

+ func (x *InterfaceMetrics) GetListenPort() int32

+ func (x *InterfaceMetrics) GetNumPeers() int32

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

+ func (x *InterfaceMetrics) GetPublicKey() string

+ func (x *InterfaceMetrics) GetTotalReceiveBytes() uint64

+ func (x *InterfaceMetrics) GetTotalTransmitBytes() uint64

+ func (x *InterfaceMetrics) GetType() string

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

+ func (x *InterfaceMetrics) Reset()

+ func (x *InterfaceMetrics) String() string

+ type JoinRequest struct

+ AsVoter bool

+ AssignIpv4 bool

+ GrpcPort int32

+ Id string

+ PreferRaftIpv6 bool

+ PrimaryEndpoint string

+ PublicKey string

+ RaftPort int32

+ Routes []string

+ WireguardEndpoints []string

+ ZoneAwarenessId string

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

+ func (*JoinRequest) ProtoMessage()

+ func (x *JoinRequest) GetAsVoter() bool

+ func (x *JoinRequest) GetAssignIpv4() bool

+ func (x *JoinRequest) GetGrpcPort() int32

+ func (x *JoinRequest) GetId() string

+ func (x *JoinRequest) GetPreferRaftIpv6() bool

+ func (x *JoinRequest) GetPrimaryEndpoint() string

+ func (x *JoinRequest) GetPublicKey() string

+ func (x *JoinRequest) GetRaftPort() int32

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

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

+ func (x *JoinRequest) GetZoneAwarenessId() string

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

+ func (x *JoinRequest) Reset()

+ func (x *JoinRequest) String() string

+ type JoinResponse struct

+ AddressIpv4 string

+ AddressIpv6 string

+ NetworkIpv6 string

+ Peers []*WireGuardPeer

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

+ func (*JoinResponse) ProtoMessage()

+ func (x *JoinResponse) GetAddressIpv4() string

+ func (x *JoinResponse) GetAddressIpv6() string

+ 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 MeshClient interface

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

+ 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 MeshEdge struct

+ Source string

+ Target string

+ Weight int32

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

+ func (*MeshEdge) ProtoMessage()

+ func (x *MeshEdge) GetSource() string

+ func (x *MeshEdge) GetTarget() string

+ func (x *MeshEdge) GetWeight() int32

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

+ func (x *MeshEdge) Reset()

+ func (x *MeshEdge) String() string

+ type MeshGraph struct

+ Dot string

+ Edges []*MeshEdge

+ Nodes []string

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

+ func (*MeshGraph) ProtoMessage()

+ func (x *MeshGraph) GetDot() string

+ func (x *MeshGraph) GetEdges() []*MeshEdge

+ func (x *MeshGraph) GetNodes() []string

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

+ func (x *MeshGraph) Reset()

+ func (x *MeshGraph) String() string

+ type MeshNode struct

+ ClusterStatus ClusterStatus

+ CreatedAt *timestamppb.Timestamp

+ GrpcPort int32

+ Id string

+ PrimaryEndpoint string

+ PrivateIpv4 string

+ PrivateIpv6 string

+ PublicKey string

+ RaftPort int32

+ UpdatedAt *timestamppb.Timestamp

+ WireguardEndpoints []string

+ ZoneAwarenessId string

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

+ func (*MeshNode) ProtoMessage()

+ func (x *MeshNode) GetClusterStatus() ClusterStatus

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

+ func (x *MeshNode) GetGrpcPort() int32

+ func (x *MeshNode) GetId() string

+ func (x *MeshNode) GetPrimaryEndpoint() string

+ func (x *MeshNode) GetPrivateIpv4() string

+ func (x *MeshNode) GetPrivateIpv6() string

+ func (x *MeshNode) GetPublicKey() string

+ func (x *MeshNode) GetRaftPort() int32

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

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

+ func (x *MeshNode) GetZoneAwarenessId() string

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

+ func (x *MeshNode) Reset()

+ func (x *MeshNode) String() string

+ type MeshServer interface

+ GetMeshGraph func(context.Context, *emptypb.Empty) (*MeshGraph, error)

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

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

+ type NetworkACL struct

+ Action ACLAction

+ DestinationCidrs []string

+ DestinationNodes []string

+ Name string

+ Ports []uint32

+ Priority int32

+ Protocols []string

+ SourceCidrs []string

+ SourceNodes []string

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

+ func (*NetworkACL) ProtoMessage()

+ func (x *NetworkACL) GetAction() ACLAction

+ func (x *NetworkACL) GetDestinationCidrs() []string

+ func (x *NetworkACL) GetDestinationNodes() []string

+ func (x *NetworkACL) GetName() string

+ func (x *NetworkACL) GetPorts() []uint32

+ func (x *NetworkACL) GetPriority() int32

+ func (x *NetworkACL) GetProtocols() []string

+ func (x *NetworkACL) GetSourceCidrs() []string

+ func (x *NetworkACL) GetSourceNodes() []string

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

+ func (x *NetworkACL) Reset()

+ func (x *NetworkACL) String() string

+ type NetworkACLs struct

+ Items []*NetworkACL

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

+ func (*NetworkACLs) ProtoMessage()

+ func (x *NetworkACLs) GetItems() []*NetworkACL

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

+ func (x *NetworkACLs) Reset()

+ func (x *NetworkACLs) String() string

+ type NetworkAction struct

+ DstCidr string

+ DstNode string

+ Port uint32

+ Protocol string

+ SrcCidr string

+ SrcNode string

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

+ func (*NetworkAction) ProtoMessage()

+ func (x *NetworkAction) GetDstCidr() string

+ func (x *NetworkAction) GetDstNode() string

+ func (x *NetworkAction) GetPort() uint32

+ func (x *NetworkAction) GetProtocol() string

+ func (x *NetworkAction) GetSrcCidr() string

+ func (x *NetworkAction) GetSrcNode() string

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

+ func (x *NetworkAction) Reset()

+ func (x *NetworkAction) String() string

+ type NodeClient interface

+ GetStatus func(ctx context.Context, in *GetStatusRequest, 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)

+ NegotiateDataChannel func(ctx context.Context, opts ...grpc.CallOption) (Node_NegotiateDataChannelClient, 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 NodeServer interface

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

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

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

+ 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 PeerDiscoveryClient interface

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

+ func NewPeerDiscoveryClient(cc grpc.ClientConnInterface) PeerDiscoveryClient

+ type PeerDiscoveryServer interface

+ ListPeers func(context.Context, *emptypb.Empty) (*ListRaftPeersResponse, 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 PluginCapability int32

+ const PluginCapability_PLUGIN_CAPABILITY_AUTH

+ const PluginCapability_PLUGIN_CAPABILITY_STORE

+ const PluginCapability_PLUGIN_CAPABILITY_UNKNOWN

+ const PluginCapability_PLUGIN_CAPABILITY_WATCH

+ func (PluginCapability) Descriptor() protoreflect.EnumDescriptor

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

+ func (PluginCapability) Type() protoreflect.EnumType

+ func (x PluginCapability) Enum() *PluginCapability

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

+ func (x PluginCapability) String() string

+ type PluginClient interface

+ Authenticate func(ctx context.Context, in *AuthenticationRequest, opts ...grpc.CallOption) (*AuthenticationResponse, error)

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

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

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

+ Store func(ctx context.Context, in *RaftLogEntry, opts ...grpc.CallOption) (*RaftApplyResponse, error)

+ func NewPluginClient(cc grpc.ClientConnInterface) PluginClient

+ type PluginConfiguration struct

+ Config *structpb.Struct

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

+ func (*PluginConfiguration) ProtoMessage()

+ func (x *PluginConfiguration) GetConfig() *structpb.Struct

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

+ func (x *PluginConfiguration) Reset()

+ func (x *PluginConfiguration) String() string

+ type PluginInfo struct

+ Capabilities []PluginCapability

+ Description string

+ Name string

+ Version string

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

+ func (*PluginInfo) ProtoMessage()

+ func (x *PluginInfo) GetCapabilities() []PluginCapability

+ func (x *PluginInfo) GetDescription() string

+ func (x *PluginInfo) GetName() string

+ func (x *PluginInfo) GetVersion() string

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

+ func (x *PluginInfo) Reset()

+ func (x *PluginInfo) String() string

+ type PluginServer interface

+ Authenticate func(context.Context, *AuthenticationRequest) (*AuthenticationResponse, error)

+ Configure func(context.Context, *PluginConfiguration) (*emptypb.Empty, error)

+ Emit func(context.Context, *Event) (*emptypb.Empty, error)

+ GetInfo func(context.Context, *emptypb.Empty) (*PluginInfo, error)

+ Store func(context.Context, *RaftLogEntry) (*RaftApplyResponse, error)

+ type RBACAction struct

+ Resource RuleResource

+ ResourceName string

+ Verb RuleVerbs

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

+ func (*RBACAction) ProtoMessage()

+ func (x *RBACAction) GetResource() RuleResource

+ func (x *RBACAction) GetResourceName() string

+ func (x *RBACAction) GetVerb() RuleVerbs

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

+ func (x *RBACAction) Reset()

+ func (x *RBACAction) String() string

+ type RaftApplyResponse struct

+ Error string

+ ExecResult *SQLExecResult

+ QueryResult *SQLQueryResult

+ Time string

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

+ func (*RaftApplyResponse) ProtoMessage()

+ func (x *RaftApplyResponse) GetError() string

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

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

+ func (x *RaftApplyResponse) GetTime() string

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

+ func (x *RaftApplyResponse) Reset()

+ func (x *RaftApplyResponse) String() string

+ 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

+ SqlExec *SQLExec

+ SqlQuery *SQLQuery

+ Type RaftCommandType

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

+ func (*RaftLogEntry) ProtoMessage()

+ 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 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 Role struct

+ Name string

+ Rules []*Rule

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

+ func (*Role) ProtoMessage()

+ func (x *Role) GetName() string

+ func (x *Role) GetRules() []*Rule

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

+ func (x *Role) Reset()

+ func (x *Role) String() string

+ type RoleBinding struct

+ Name string

+ Role string

+ Subjects []*Subject

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

+ func (*RoleBinding) ProtoMessage()

+ func (x *RoleBinding) GetName() string

+ func (x *RoleBinding) GetRole() string

+ func (x *RoleBinding) GetSubjects() []*Subject

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

+ func (x *RoleBinding) Reset()

+ func (x *RoleBinding) String() string

+ type RoleBindings struct

+ Items []*RoleBinding

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

+ func (*RoleBindings) ProtoMessage()

+ func (x *RoleBindings) GetItems() []*RoleBinding

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

+ func (x *RoleBindings) Reset()

+ func (x *RoleBindings) String() string

+ type Roles struct

+ Items []*Role

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

+ func (*Roles) ProtoMessage()

+ func (x *Roles) GetItems() []*Role

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

+ func (x *Roles) Reset()

+ func (x *Roles) String() string

+ type Route struct

+ DestinationCidrs []string

+ Name string

+ NextHopNode string

+ Node string

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

+ func (*Route) ProtoMessage()

+ func (x *Route) GetDestinationCidrs() []string

+ func (x *Route) GetName() string

+ func (x *Route) GetNextHopNode() string

+ func (x *Route) GetNode() string

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

+ func (x *Route) Reset()

+ func (x *Route) String() string

+ type Routes struct

+ Items []*Route

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

+ func (*Routes) ProtoMessage()

+ func (x *Routes) GetItems() []*Route

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

+ func (x *Routes) Reset()

+ func (x *Routes) String() string

+ type Rule struct

+ ResourceNames []string

+ Resources []RuleResource

+ Verbs []RuleVerbs

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

+ func (*Rule) ProtoMessage()

+ func (x *Rule) GetResourceNames() []string

+ func (x *Rule) GetResources() []RuleResource

+ func (x *Rule) GetVerbs() []RuleVerbs

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

+ func (x *Rule) Reset()

+ func (x *Rule) String() string

+ type RuleResource int32

+ const RuleResource_RESOURCE_ALL

+ const RuleResource_RESOURCE_DATA_CHANNELS

+ const RuleResource_RESOURCE_GROUPS

+ const RuleResource_RESOURCE_NETWORK_ACLS

+ const RuleResource_RESOURCE_ROLES

+ const RuleResource_RESOURCE_ROLE_BINDINGS

+ const RuleResource_RESOURCE_ROUTES

+ const RuleResource_RESOURCE_UNKNOWN

+ const RuleResource_RESOURCE_VOTES

+ func (RuleResource) Descriptor() protoreflect.EnumDescriptor

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

+ func (RuleResource) Type() protoreflect.EnumType

+ func (x RuleResource) Enum() *RuleResource

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

+ func (x RuleResource) String() string

+ type RuleVerbs int32

+ const RuleVerbs_VERB_ALL

+ const RuleVerbs_VERB_DELETE

+ const RuleVerbs_VERB_GET

+ const RuleVerbs_VERB_PUT

+ const RuleVerbs_VERB_UNKNOWN

+ func (RuleVerbs) Descriptor() protoreflect.EnumDescriptor

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

+ func (RuleVerbs) Type() protoreflect.EnumType

+ func (x RuleVerbs) Enum() *RuleVerbs

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

+ func (x RuleVerbs) 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

+ Bool bool

+ Bytes []byte

+ Double float64

+ Int64 int64

+ Name string

+ Str string

+ Time *timestamppb.Timestamp

+ Type SQLParameterType

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

+ func (*SQLParameter) ProtoMessage()

+ 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) GetType() SQLParameterType

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

+ func (x *SQLParameter) Reset()

+ func (x *SQLParameter) String() string

+ 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 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

+ ClusterStatus ClusterStatus

+ Commit string

+ CurrentLeader string

+ CurrentTerm uint64

+ Features []Feature

+ Id string

+ InterfaceMetrics *InterfaceMetrics

+ LastApplied uint64

+ LastLogIndex uint64

+ StartedAt *timestamppb.Timestamp

+ Uptime string

+ Version string

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

+ func (*Status) ProtoMessage()

+ func (x *Status) GetBuildDate() string

+ func (x *Status) GetClusterStatus() ClusterStatus

+ func (x *Status) GetCommit() string

+ func (x *Status) GetCurrentLeader() string

+ func (x *Status) GetCurrentTerm() uint64

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

+ func (x *Status) GetId() string

+ func (x *Status) GetInterfaceMetrics() *InterfaceMetrics

+ func (x *Status) GetLastApplied() uint64

+ func (x *Status) GetLastLogIndex() uint64

+ 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 Subject struct

+ Name string

+ Type SubjectType

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

+ func (*Subject) ProtoMessage()

+ func (x *Subject) GetName() string

+ func (x *Subject) GetType() SubjectType

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

+ func (x *Subject) Reset()

+ func (x *Subject) String() string

+ type SubjectType int32

+ const SubjectType_SUBJECT_ALL

+ const SubjectType_SUBJECT_GROUP

+ const SubjectType_SUBJECT_NODE

+ const SubjectType_SUBJECT_UNKNOWN

+ const SubjectType_SUBJECT_USER

+ func (SubjectType) Descriptor() protoreflect.EnumDescriptor

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

+ func (SubjectType) Type() protoreflect.EnumType

+ func (x SubjectType) Enum() *SubjectType

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

+ func (x SubjectType) String() string

+ type UnimplementedAdminServer struct

+ func (UnimplementedAdminServer) DeleteGroup(context.Context, *Group) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) DeleteNetworkACL(context.Context, *NetworkACL) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) DeleteRole(context.Context, *Role) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) DeleteRoleBinding(context.Context, *RoleBinding) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) DeleteRoute(context.Context, *Route) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) GetGroup(context.Context, *Group) (*Group, error)

+ func (UnimplementedAdminServer) GetNetworkACL(context.Context, *NetworkACL) (*NetworkACL, error)

+ func (UnimplementedAdminServer) GetRole(context.Context, *Role) (*Role, error)

+ func (UnimplementedAdminServer) GetRoleBinding(context.Context, *RoleBinding) (*RoleBinding, error)

+ func (UnimplementedAdminServer) GetRoute(context.Context, *Route) (*Route, error)

+ func (UnimplementedAdminServer) ListGroups(context.Context, *emptypb.Empty) (*Groups, error)

+ func (UnimplementedAdminServer) ListNetworkACLs(context.Context, *emptypb.Empty) (*NetworkACLs, error)

+ func (UnimplementedAdminServer) ListRoleBindings(context.Context, *emptypb.Empty) (*RoleBindings, error)

+ func (UnimplementedAdminServer) ListRoles(context.Context, *emptypb.Empty) (*Roles, error)

+ func (UnimplementedAdminServer) ListRoutes(context.Context, *emptypb.Empty) (*Routes, error)

+ func (UnimplementedAdminServer) PutGroup(context.Context, *Group) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) PutNetworkACL(context.Context, *NetworkACL) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) PutRole(context.Context, *Role) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) PutRoleBinding(context.Context, *RoleBinding) (*emptypb.Empty, error)

+ func (UnimplementedAdminServer) PutRoute(context.Context, *Route) (*emptypb.Empty, error)

+ type UnimplementedMeshServer struct

+ func (UnimplementedMeshServer) GetMeshGraph(context.Context, *emptypb.Empty) (*MeshGraph, error)

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

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

+ type UnimplementedNodeServer struct

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

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

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

+ func (UnimplementedNodeServer) NegotiateDataChannel(Node_NegotiateDataChannelServer) error

+ type UnimplementedPeerDiscoveryServer struct

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

+ type UnimplementedPluginServer struct

+ func (UnimplementedPluginServer) Authenticate(context.Context, *AuthenticationRequest) (*AuthenticationResponse, error)

+ func (UnimplementedPluginServer) Configure(context.Context, *PluginConfiguration) (*emptypb.Empty, error)

+ func (UnimplementedPluginServer) Emit(context.Context, *Event) (*emptypb.Empty, error)

+ func (UnimplementedPluginServer) GetInfo(context.Context, *emptypb.Empty) (*PluginInfo, error)

+ func (UnimplementedPluginServer) Store(context.Context, *RaftLogEntry) (*RaftApplyResponse, error)

+ type UnimplementedWebRTCServer struct

+ func (UnimplementedWebRTCServer) StartDataChannel(WebRTC_StartDataChannelServer) error

+ type UnsafeAdminServer interface

+ type UnsafeMeshServer interface

+ type UnsafeNodeServer interface

+ type UnsafePeerDiscoveryServer interface

+ type UnsafePluginServer interface

+ type UnsafeWebRTCServer interface

+ type WatchEvent int32

+ const WatchEvent_WATCH_EVENT_LEADER_CHANGE

+ const WatchEvent_WATCH_EVENT_NODE_JOIN

+ const WatchEvent_WATCH_EVENT_NODE_LEAVE

+ const WatchEvent_WATCH_EVENT_UNKNOWN

+ func (WatchEvent) Descriptor() protoreflect.EnumDescriptor

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

+ func (WatchEvent) Type() protoreflect.EnumType

+ func (x WatchEvent) Enum() *WatchEvent

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

+ func (x WatchEvent) String() string

+ 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 struct

+ AddressIpv4 string

+ AddressIpv6 string

+ AllowedIps []string

+ AllowedRoutes []string

+ Id string

+ PrimaryEndpoint string

+ PublicKey string

+ WireguardEndpoints []string

+ ZoneAwarenessId 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) GetAllowedRoutes() []string

+ func (x *WireGuardPeer) GetId() string

+ func (x *WireGuardPeer) GetPrimaryEndpoint() string

+ func (x *WireGuardPeer) GetPublicKey() string

+ func (x *WireGuardPeer) GetWireguardEndpoints() []string

+ func (x *WireGuardPeer) GetZoneAwarenessId() 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