aegis

package module

Go to main page

Versions in this module

v0

v0.0.10

May 7, 2026

Changes in this version

+ type Auditable interface

+ Action func() string

+ ActorID func() string

+ Attributes func() map[string]string

+ Message func() string

+ ResourceID func() string

+ ResourceType func() string

+ TenantID func() string

v0.0.9

May 6, 2026

v0.0.8

May 6, 2026

v0.0.7

May 6, 2026

v0.0.6

May 6, 2026

v0.0.5

May 6, 2026

Changes in this version

+ const MeshAuth_ExchangeToken_FullMethodName

+ const MeshAuth_RevokeToken_FullMethodName

+ var File_mesh_auth_proto protoreflect.FileDescriptor

+ var MeshAuth_ServiceDesc = grpc.ServiceDesc

+ func DefaultMeshPolicy() sctx.ContextPolicy[Metadata]

+ func NewAdmin(privateKey crypto.PrivateKey, trustedCAs *x509.CertPool) (sctx.Admin[Metadata], error)

+ func NewAdminFromKeychain(ctx context.Context, keychain Keychain, id string) (sctx.Admin[Metadata], error)

+ func RegisterMeshAuthServer(s grpc.ServiceRegistrar, srv MeshAuthServer)

+ func StreamGuardInterceptor(registry *GuardRegistry, admin sctx.Admin[Metadata], ...) grpc.StreamServerInterceptor

+ func UnaryGuardInterceptor(registry *GuardRegistry, admin sctx.Admin[Metadata], ...) grpc.UnaryServerInterceptor

+ type FileKeychain struct

+ func NewFileKeychain(dir string) *FileKeychain

+ func (fk *FileKeychain) LoadCertificate(_ context.Context, id string) (*x509.Certificate, error)

+ func (fk *FileKeychain) LoadPrivateKey(_ context.Context, id string) (crypto.PrivateKey, error)

+ func (fk *FileKeychain) LoadTrustedCAs(_ context.Context) (*x509.CertPool, error)

+ type GuardRegistry struct

+ func NewGuardRegistry() *GuardRegistry

+ func (gr *GuardRegistry) Get(method string) sctx.Guard

+ func (gr *GuardRegistry) Len() int

+ func (gr *GuardRegistry) Register(method string, guard sctx.Guard)

+ type Keychain interface

+ LoadCertificate func(ctx context.Context, id string) (*x509.Certificate, error)

+ LoadPrivateKey func(ctx context.Context, id string) (crypto.PrivateKey, error)

+ LoadTrustedCAs func(ctx context.Context) (*x509.CertPool, error)

+ type MeshAuthClient interface

+ ExchangeToken func(ctx context.Context, in *TokenExchangeRequest, opts ...grpc.CallOption) (*TokenExchangeResponse, error)

+ RevokeToken func(ctx context.Context, in *RevokeTokenRequest, opts ...grpc.CallOption) (*RevokeTokenResponse, error)

+ func NewMeshAuthClient(cc grpc.ClientConnInterface) MeshAuthClient

+ type MeshAuthServer interface

+ ExchangeToken func(context.Context, *TokenExchangeRequest) (*TokenExchangeResponse, error)

+ RevokeToken func(context.Context, *RevokeTokenRequest) (*RevokeTokenResponse, error)

+ func NewMeshAuthService(admin sctx.Admin[Metadata]) MeshAuthServer

type MeshServer

+ func (ms *MeshServer) SetAuth(admin sctx.Admin[Metadata], guards *GuardRegistry, nodeToken sctx.SignedToken)

+ type Metadata struct

+ NodeID string

+ ServiceName string

type Node

+ Admin sctx.Admin[Metadata]

+ Guards *GuardRegistry

+ func (n *Node) Guard(method string, guard sctx.Guard)

type NodeBuilder

+ func (nb *NodeBuilder) WithAdmin(admin sctx.Admin[Metadata]) *NodeBuilder

+ func (nb *NodeBuilder) WithGuard(method string, guard sctx.Guard) *NodeBuilder

+ func (nb *NodeBuilder) WithKeychain(keychain Keychain) *NodeBuilder

+ type RevokeTokenRequest struct

+ Fingerprint string

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

+ func (*RevokeTokenRequest) ProtoMessage()

+ func (x *RevokeTokenRequest) GetFingerprint() string

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

+ func (x *RevokeTokenRequest) Reset()

+ func (x *RevokeTokenRequest) String() string

+ type RevokeTokenResponse struct

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

+ func (*RevokeTokenResponse) ProtoMessage()

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

+ func (x *RevokeTokenResponse) Reset()

+ func (x *RevokeTokenResponse) String() string

+ type SecurityContext = sctx.Context[Metadata]

+ func SecurityContextFromContext(ctx context.Context) (*SecurityContext, bool)

type ServiceRegistrar

+ func MeshAuthRegistrar(admin sctx.Admin[Metadata]) ServiceRegistrar

+ type TokenExchangeRequest struct

+ Assertion []byte

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

+ func (*TokenExchangeRequest) ProtoMessage()

+ func (x *TokenExchangeRequest) GetAssertion() []byte

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

+ func (x *TokenExchangeRequest) Reset()

+ func (x *TokenExchangeRequest) String() string

+ type TokenExchangeResponse struct

+ ExpiresAt int64

+ Token string

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

+ func (*TokenExchangeResponse) ProtoMessage()

+ func (x *TokenExchangeResponse) GetExpiresAt() int64

+ func (x *TokenExchangeResponse) GetToken() string

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

+ func (x *TokenExchangeResponse) Reset()

+ func (x *TokenExchangeResponse) String() string

+ type UnimplementedMeshAuthServer struct

+ func (UnimplementedMeshAuthServer) ExchangeToken(context.Context, *TokenExchangeRequest) (*TokenExchangeResponse, error)

+ func (UnimplementedMeshAuthServer) RevokeToken(context.Context, *RevokeTokenRequest) (*RevokeTokenResponse, error)

+ type UnsafeMeshAuthServer interface

v0.0.4

Mar 19, 2026

Changes in this version

+ const MeshService_GetHealth_FullMethodName

+ const MeshService_GetNodeInfo_FullMethodName

+ const MeshService_GetTopology_FullMethodName

+ const MeshService_Ping_FullMethodName

+ const MeshService_SyncTopology_FullMethodName

+ var ErrNoCertificate = errors.New("no client certificate")

+ var ErrNoPeerInfo = errors.New("no peer info in context")

+ var ErrNoProviders = errors.New("no providers available for service")

+ var ErrNoTLSConfig = errors.New("node has no TLS configuration")

+ var ErrNoTLSInfo = errors.New("no TLS info in peer")

+ var File_mesh_proto protoreflect.FileDescriptor

+ var MeshService_ServiceDesc = grpc.ServiceDesc

+ func GenerateCertificateRequest(_ string, _ string) ([]byte, error)

+ func LoadCABundle(source CertificateSource, fileOrEnvVar string) (*x509.CertPool, error)

+ func ParseCertificateChain(pemData []byte) ([]*x509.Certificate, error)

+ func RegisterMeshServiceServer(s grpc.ServiceRegistrar, srv MeshServiceServer)

+ type Caller struct

+ Certificate *x509.Certificate

+ NodeID string

+ func CallerFromContext(ctx context.Context) (*Caller, error)

+ func MustCallerFromContext(ctx context.Context) *Caller

+ type CertificateSource string

+ const CertSourceEnv

+ const CertSourceFile

+ const CertSourceVault

+ type FunctionHealthChecker struct

+ func NewFunctionHealthChecker(name string, checkFn func(ctx context.Context) error) *FunctionHealthChecker

+ func (f *FunctionHealthChecker) Check(ctx context.Context) error

+ func (f *FunctionHealthChecker) Name() string

+ type GetTopologyRequest struct

+ SenderId string

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

+ func (*GetTopologyRequest) ProtoMessage()

+ func (x *GetTopologyRequest) GetSenderId() string

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

+ func (x *GetTopologyRequest) Reset()

+ func (x *GetTopologyRequest) String() string

+ type GetTopologyResponse struct

+ Nodes []*TopologyNode

+ Version int64

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

+ func (*GetTopologyResponse) ProtoMessage()

+ func (x *GetTopologyResponse) GetNodes() []*TopologyNode

+ func (x *GetTopologyResponse) GetVersion() int64

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

+ func (x *GetTopologyResponse) Reset()

+ func (x *GetTopologyResponse) String() string

+ type HealthChecker interface

+ Check func(ctx context.Context) error

+ Name func() string

+ type HealthInfo struct

+ Error string

+ LastChecked time.Time

+ Message string

+ Status HealthStatus

+ func NewHealthInfo() *HealthInfo

+ func (h *HealthInfo) Get() (HealthStatus, time.Time, string, string)

+ func (h *HealthInfo) IsHealthy() bool

+ func (h *HealthInfo) String() string

+ func (h *HealthInfo) Update(status HealthStatus, message string, err error)

+ type HealthRequest struct

+ SenderId string

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

+ func (*HealthRequest) ProtoMessage()

+ func (x *HealthRequest) GetSenderId() string

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

+ func (x *HealthRequest) Reset()

+ func (x *HealthRequest) String() string

+ type HealthResponse struct

+ Error string

+ LastChecked int64

+ Message string

+ NodeId string

+ Status string

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

+ func (*HealthResponse) ProtoMessage()

+ func (x *HealthResponse) GetError() string

+ func (x *HealthResponse) GetLastChecked() int64

+ func (x *HealthResponse) GetMessage() string

+ func (x *HealthResponse) GetNodeId() string

+ func (x *HealthResponse) GetStatus() string

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

+ func (x *HealthResponse) Reset()

+ func (x *HealthResponse) String() string

+ type HealthStatus string

+ const HealthStatusHealthy

+ const HealthStatusUnhealthy

+ const HealthStatusUnknown

+ type MeshServer struct

+ func NewMeshServer(node *Node) *MeshServer

+ func (ms *MeshServer) GetHealth(ctx context.Context, req *HealthRequest) (*HealthResponse, error)

+ func (ms *MeshServer) GetNodeInfo(ctx context.Context, req *NodeInfoRequest) (*NodeInfoResponse, error)

+ func (ms *MeshServer) GetTopology(ctx context.Context, req *GetTopologyRequest) (*GetTopologyResponse, error)

+ func (ms *MeshServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, error)

+ func (ms *MeshServer) RegisterService(r ServiceRegistrar)

+ func (ms *MeshServer) SetTLSConfig(tlsConfig *TLSConfig)

+ func (ms *MeshServer) Start() error

+ func (ms *MeshServer) Stop()

+ func (ms *MeshServer) SyncTopology(ctx context.Context, req *TopologySyncRequest) (*TopologySyncResponse, error)

+ type MeshServiceClient interface

+ GetHealth func(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)

+ GetNodeInfo func(ctx context.Context, in *NodeInfoRequest, opts ...grpc.CallOption) (*NodeInfoResponse, error)

+ GetTopology func(ctx context.Context, in *GetTopologyRequest, opts ...grpc.CallOption) (*GetTopologyResponse, error)

+ Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)

+ SyncTopology func(ctx context.Context, in *TopologySyncRequest, opts ...grpc.CallOption) (*TopologySyncResponse, error)

+ func NewMeshServiceClient(cc grpc.ClientConnInterface) MeshServiceClient

+ type MeshServiceServer interface

+ GetHealth func(context.Context, *HealthRequest) (*HealthResponse, error)

+ GetNodeInfo func(context.Context, *NodeInfoRequest) (*NodeInfoResponse, error)

+ GetTopology func(context.Context, *GetTopologyRequest) (*GetTopologyResponse, error)

+ Ping func(context.Context, *PingRequest) (*PingResponse, error)

+ SyncTopology func(context.Context, *TopologySyncRequest) (*TopologySyncResponse, error)

+ type Node struct

+ Address string

+ Health *HealthInfo

+ ID string

+ MeshServer *MeshServer

+ Name string

+ PeerManager *PeerManager

+ Services []ServiceInfo

+ TLSConfig *TLSConfig

+ Topology *Topology

+ Type NodeType

+ func NewNode(id, name string, nodeType NodeType, address string) *Node

+ func NewSecureNode(id, name string, nodeType NodeType, address, certDir string) (*Node, error)

+ func (n *Node) AddPeer(info PeerInfo) error

+ func (n *Node) CheckHealth(ctx context.Context, checker HealthChecker) error

+ func (n *Node) EnableTLS(certDir string) error

+ func (n *Node) GetAllPeers() []*Peer

+ func (n *Node) GetHealth() (HealthStatus, string)

+ func (n *Node) GetMeshNodes() []NodeInfo

+ func (n *Node) GetPeer(peerID string) (*Peer, bool)

+ func (n *Node) GetPeerHealth(ctx context.Context, peerID string) (*HealthResponse, error)

+ func (n *Node) GetPeerNodeInfo(ctx context.Context, peerID string) (*NodeInfoResponse, error)

+ func (n *Node) GetTopologyVersion() int64

+ func (n *Node) IsHealthy() bool

+ func (n *Node) MarshalJSON() ([]byte, error)

+ func (n *Node) PingPeer(ctx context.Context, peerID string) (*PingResponse, error)

+ func (n *Node) RemovePeer(peerID string) error

+ func (n *Node) SetHealth(status HealthStatus, message string, err error)

+ func (n *Node) Shutdown() error

+ func (n *Node) StartServer() error

+ func (n *Node) StopServer()

+ func (n *Node) String() string

+ func (n *Node) SyncTopology(ctx context.Context, peerID string) error

+ func (n *Node) SyncTopologyWithAllPeers(ctx context.Context) error

+ func (n *Node) UnmarshalJSON(data []byte) error

+ func (n *Node) Validate() error

+ type NodeBuilder struct

+ func NewNodeBuilder() *NodeBuilder

+ func (nb *NodeBuilder) Build() (*Node, error)

+ func (nb *NodeBuilder) WithAddress(address string) *NodeBuilder

+ func (nb *NodeBuilder) WithCertDir(certDir string) *NodeBuilder

+ func (nb *NodeBuilder) WithID(id string) *NodeBuilder

+ func (nb *NodeBuilder) WithName(name string) *NodeBuilder

+ func (nb *NodeBuilder) WithServiceRegistration(r ServiceRegistrar) *NodeBuilder

+ func (nb *NodeBuilder) WithServices(services ...ServiceInfo) *NodeBuilder

+ func (nb *NodeBuilder) WithTLSOptions(opts *TLSOptions) *NodeBuilder

+ func (nb *NodeBuilder) WithType(nodeType NodeType) *NodeBuilder

+ type NodeInfo struct

+ Address string

+ ID string

+ JoinedAt time.Time

+ Name string

+ Services []ServiceInfo

+ Type NodeType

+ UpdatedAt time.Time

+ type NodeInfoRequest struct

+ SenderId string

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

+ func (*NodeInfoRequest) ProtoMessage()

+ func (x *NodeInfoRequest) GetSenderId() string

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

+ func (x *NodeInfoRequest) Reset()

+ func (x *NodeInfoRequest) String() string

+ type NodeInfoResponse struct

+ Address string

+ Health *HealthResponse

+ Id string

+ Name string

+ Type string

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

+ func (*NodeInfoResponse) ProtoMessage()

+ func (x *NodeInfoResponse) GetAddress() string

+ func (x *NodeInfoResponse) GetHealth() *HealthResponse

+ func (x *NodeInfoResponse) GetId() string

+ func (x *NodeInfoResponse) GetName() string

+ func (x *NodeInfoResponse) GetType() string

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

+ func (x *NodeInfoResponse) Reset()

+ func (x *NodeInfoResponse) String() string

+ type NodeType string

+ const NodeTypeGeneric

+ type Peer struct

+ Client MeshServiceClient

+ Conn *grpc.ClientConn

+ Info PeerInfo

+ type PeerInfo struct

+ Address string

+ ID string

+ Type NodeType

+ type PeerManager struct

+ func NewPeerManager(nodeID string) *PeerManager

+ func (pm *PeerManager) AddPeer(info PeerInfo) error

+ func (pm *PeerManager) Close() error

+ func (pm *PeerManager) Count() int

+ func (pm *PeerManager) GetAllPeers() []*Peer

+ func (pm *PeerManager) GetPeer(peerID string) (*Peer, bool)

+ func (pm *PeerManager) GetPeerHealth(ctx context.Context, peerID string) (*HealthResponse, error)

+ func (pm *PeerManager) GetPeerNodeInfo(ctx context.Context, peerID string) (*NodeInfoResponse, error)

+ func (pm *PeerManager) GetPeersByType(nodeType NodeType) []*Peer

+ func (pm *PeerManager) IsConnected(peerID string) bool

+ func (pm *PeerManager) PingPeer(ctx context.Context, peerID string) (*PingResponse, error)

+ func (pm *PeerManager) RemovePeer(peerID string) error

+ func (pm *PeerManager) SetTLSConfig(tlsConfig *TLSConfig)

+ func (pm *PeerManager) SyncTopology(ctx context.Context, peerID string, version int64) (*TopologySyncResponse, error)

+ type PingHealthChecker struct

+ func NewPingHealthChecker(name string) *PingHealthChecker

+ func (p *PingHealthChecker) Check(ctx context.Context) error

+ func (p *PingHealthChecker) Name() string

+ type PingRequest struct

+ SenderId string

+ Timestamp int64

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

+ func (*PingRequest) ProtoMessage()

+ func (x *PingRequest) GetSenderId() string

+ func (x *PingRequest) GetTimestamp() int64

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

+ func (x *PingRequest) Reset()

+ func (x *PingRequest) String() string

+ type PingResponse struct

+ ReceiverId string

+ Success bool

+ Timestamp int64

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

+ func (*PingResponse) ProtoMessage()

+ func (x *PingResponse) GetReceiverId() string

+ func (x *PingResponse) GetSuccess() bool

+ func (x *PingResponse) GetTimestamp() int64

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

+ func (x *PingResponse) Reset()

+ func (x *PingResponse) String() string

+ type Service struct

+ Name string

+ Version string

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

+ func (*Service) ProtoMessage()

+ func (x *Service) GetName() string

+ func (x *Service) GetVersion() string

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

+ func (x *Service) Reset()

+ func (x *Service) String() string

+ type ServiceClient struct

+ func NewServiceClient[T any](pool *ServiceClientPool, name, version string, ...) *ServiceClient[T]

+ func (sc *ServiceClient[T]) Get(ctx context.Context) (T, error)

+ type ServiceClientPool struct

+ func NewServiceClientPool(node *Node) *ServiceClientPool

+ func (p *ServiceClientPool) Close() error

+ func (p *ServiceClientPool) GetConn(ctx context.Context, name, version string) (*grpc.ClientConn, error)

+ type ServiceInfo struct

+ Name string

+ Version string

+ type ServiceRegistrar func(*grpc.Server)

+ type TLSConfig struct

+ CertPool *x509.CertPool

+ Certificate tls.Certificate

+ ServerName string

+ func LoadOrGenerateTLS(nodeID string, certDir string) (*TLSConfig, error)

+ func LoadTLSConfig(opts *TLSOptions) (*TLSConfig, error)

+ func (tc *TLSConfig) GetClientTLSConfig(serverName string) *tls.Config

+ func (tc *TLSConfig) GetServerTLSConfig() *tls.Config

+ type TLSOptions struct

+ AllowExpired bool

+ CAEnvVar string

+ CAFile string

+ CertEnvVar string

+ CertFile string

+ KeyEnvVar string

+ KeyFile string

+ RequiredSANs []string

+ Source CertificateSource

+ VaultPath string

+ VaultRole string

+ VerifyChain bool

+ func DefaultTLSOptions(nodeID string, certDir string) *TLSOptions

+ type Topology struct

+ Nodes map[string]NodeInfo

+ UpdatedAt time.Time

+ Version int64

+ func NewTopology() *Topology

+ func (t *Topology) AddNode(info NodeInfo) error

+ func (t *Topology) Clone() *Topology

+ func (t *Topology) GetAllNodes() []NodeInfo

+ func (t *Topology) GetNode(nodeID string) (NodeInfo, bool)

+ func (t *Topology) GetNodesByService(name string) []NodeInfo

+ func (t *Topology) GetServiceProviders(name, version string) []NodeInfo

+ func (t *Topology) GetVersion() int64

+ func (t *Topology) Merge(other *Topology) bool

+ func (t *Topology) NodeCount() int

+ func (t *Topology) RemoveNode(nodeID string) error

+ func (t *Topology) UpdateNode(info NodeInfo) error

+ type TopologyNode struct

+ Address string

+ Id string

+ JoinedAt int64

+ Name string

+ Services []*Service

+ Type string

+ UpdatedAt int64

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

+ func (*TopologyNode) ProtoMessage()

+ func (x *TopologyNode) GetAddress() string

+ func (x *TopologyNode) GetId() string

+ func (x *TopologyNode) GetJoinedAt() int64

+ func (x *TopologyNode) GetName() string

+ func (x *TopologyNode) GetServices() []*Service

+ func (x *TopologyNode) GetType() string

+ func (x *TopologyNode) GetUpdatedAt() int64

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

+ func (x *TopologyNode) Reset()

+ func (x *TopologyNode) String() string

+ type TopologySyncRequest struct

+ SenderId string

+ Version int64

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

+ func (*TopologySyncRequest) ProtoMessage()

+ func (x *TopologySyncRequest) GetSenderId() string

+ func (x *TopologySyncRequest) GetVersion() int64

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

+ func (x *TopologySyncRequest) Reset()

+ func (x *TopologySyncRequest) String() string

+ type TopologySyncResponse struct

+ Nodes []*TopologyNode

+ UpdatedAt int64

+ Version int64

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

+ func (*TopologySyncResponse) ProtoMessage()

+ func (x *TopologySyncResponse) GetNodes() []*TopologyNode

+ func (x *TopologySyncResponse) GetUpdatedAt() int64

+ func (x *TopologySyncResponse) GetVersion() int64

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

+ func (x *TopologySyncResponse) Reset()

+ func (x *TopologySyncResponse) String() string

+ type UnimplementedMeshServiceServer struct

+ func (UnimplementedMeshServiceServer) GetHealth(context.Context, *HealthRequest) (*HealthResponse, error)

+ func (UnimplementedMeshServiceServer) GetNodeInfo(context.Context, *NodeInfoRequest) (*NodeInfoResponse, error)

+ func (UnimplementedMeshServiceServer) GetTopology(context.Context, *GetTopologyRequest) (*GetTopologyResponse, error)

+ func (UnimplementedMeshServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

+ func (UnimplementedMeshServiceServer) SyncTopology(context.Context, *TopologySyncRequest) (*TopologySyncResponse, error)

+ type UnsafeMeshServiceServer interface

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