Versions in this module Expand all Collapse all v0 v0.10.0 Nov 4, 2022 Changes in this version + var ConfigurationManager_ServiceDesc = grpc.ServiceDesc + var File_api_nsp_v1_configurationmanager_proto protoreflect.FileDescriptor + var File_api_nsp_v1_model_proto protoreflect.FileDescriptor + var File_api_nsp_v1_targetregistry_proto protoreflect.FileDescriptor + var TargetRegistry_ServiceDesc = grpc.ServiceDesc + var Target_Status_name = map[int32]string + var Target_Status_value = map[string]int32 + var Target_Type_name = map[int32]string + var Target_Type_value = map[string]int32 + func AttractorFilter(filter *Attractor, comparedTo *Attractor) bool + func ConduitFilter(filter *Conduit, comparedTo *Conduit) bool + func FlowFilter(filter *Flow, comparedTo *Flow) bool + func GatewayFilter(filter *Gateway, comparedTo *Gateway) bool + func RegisterConfigurationManagerServer(s grpc.ServiceRegistrar, srv ConfigurationManagerServer) + func RegisterTargetRegistryServer(s grpc.ServiceRegistrar, srv TargetRegistryServer) + func StreamFilter(filter *Stream, comparedTo *Stream) bool + func TargetFilter(filter *Target, comparedTo *Target) bool + func TrenchFilter(filter *Trench, comparedTo *Trench) bool + func VipFilter(filter *Vip, comparedTo *Vip) bool + type Attractor struct + Gateways []*Gateway + Name string + Trench *Trench + Vips []*Vip + func (*Attractor) Descriptor() ([]byte, []int) + func (*Attractor) ProtoMessage() + func (a *Attractor) Equals(a2 *Attractor) bool + func (x *Attractor) GetGateways() []*Gateway + func (x *Attractor) GetName() string + func (x *Attractor) GetTrench() *Trench + func (x *Attractor) GetVips() []*Vip + func (x *Attractor) ProtoReflect() protoreflect.Message + func (x *Attractor) Reset() + func (x *Attractor) String() string + type AttractorResponse struct + Attractors []*Attractor + func (*AttractorResponse) Descriptor() ([]byte, []int) + func (*AttractorResponse) ProtoMessage() + func (x *AttractorResponse) GetAttractors() []*Attractor + func (x *AttractorResponse) ProtoReflect() protoreflect.Message + func (x *AttractorResponse) Reset() + func (x *AttractorResponse) String() string + type Conduit struct + DestinationPortNats []*Conduit_PortNat + Name string + Trench *Trench + func (*Conduit) Descriptor() ([]byte, []int) + func (*Conduit) ProtoMessage() + func (c *Conduit) Equals(c2 *Conduit) bool + func (x *Conduit) GetDestinationPortNats() []*Conduit_PortNat + func (x *Conduit) GetName() string + func (x *Conduit) GetTrench() *Trench + func (x *Conduit) ProtoReflect() protoreflect.Message + func (x *Conduit) Reset() + func (x *Conduit) String() string + type ConduitResponse struct + Conduits []*Conduit + func (*ConduitResponse) Descriptor() ([]byte, []int) + func (*ConduitResponse) ProtoMessage() + func (x *ConduitResponse) GetConduits() []*Conduit + func (x *ConduitResponse) ProtoReflect() protoreflect.Message + func (x *ConduitResponse) Reset() + func (x *ConduitResponse) String() string + type Conduit_PortNat struct + Port uint32 + Protocol string + TargetPort uint32 + Vips []*Vip + func PortNatDiff(set1 []*Conduit_PortNat, set2 []*Conduit_PortNat) []*Conduit_PortNat + func (*Conduit_PortNat) Descriptor() ([]byte, []int) + func (*Conduit_PortNat) ProtoMessage() + func (pn *Conduit_PortNat) GetNatName() string + func (x *Conduit_PortNat) GetPort() uint32 + func (x *Conduit_PortNat) GetProtocol() string + func (x *Conduit_PortNat) GetTargetPort() uint32 + func (x *Conduit_PortNat) GetVips() []*Vip + func (x *Conduit_PortNat) ProtoReflect() protoreflect.Message + func (x *Conduit_PortNat) Reset() + func (x *Conduit_PortNat) String() string + type ConfigurationManagerClient interface + WatchAttractor func(ctx context.Context, in *Attractor, opts ...grpc.CallOption) (ConfigurationManager_WatchAttractorClient, error) + WatchConduit func(ctx context.Context, in *Conduit, opts ...grpc.CallOption) (ConfigurationManager_WatchConduitClient, error) + WatchFlow func(ctx context.Context, in *Flow, opts ...grpc.CallOption) (ConfigurationManager_WatchFlowClient, error) + WatchGateway func(ctx context.Context, in *Gateway, opts ...grpc.CallOption) (ConfigurationManager_WatchGatewayClient, error) + WatchStream func(ctx context.Context, in *Stream, opts ...grpc.CallOption) (ConfigurationManager_WatchStreamClient, error) + WatchTrench func(ctx context.Context, in *Trench, opts ...grpc.CallOption) (ConfigurationManager_WatchTrenchClient, error) + WatchVip func(ctx context.Context, in *Vip, opts ...grpc.CallOption) (ConfigurationManager_WatchVipClient, error) + func NewConfigurationManagerClient(cc grpc.ClientConnInterface) ConfigurationManagerClient + type ConfigurationManagerServer interface + WatchAttractor func(*Attractor, ConfigurationManager_WatchAttractorServer) error + WatchConduit func(*Conduit, ConfigurationManager_WatchConduitServer) error + WatchFlow func(*Flow, ConfigurationManager_WatchFlowServer) error + WatchGateway func(*Gateway, ConfigurationManager_WatchGatewayServer) error + WatchStream func(*Stream, ConfigurationManager_WatchStreamServer) error + WatchTrench func(*Trench, ConfigurationManager_WatchTrenchServer) error + WatchVip func(*Vip, ConfigurationManager_WatchVipServer) error + type ConfigurationManager_WatchAttractorClient interface + Recv func() (*AttractorResponse, error) + type ConfigurationManager_WatchAttractorServer interface + Send func(*AttractorResponse) error + type ConfigurationManager_WatchConduitClient interface + Recv func() (*ConduitResponse, error) + type ConfigurationManager_WatchConduitServer interface + Send func(*ConduitResponse) error + type ConfigurationManager_WatchFlowClient interface + Recv func() (*FlowResponse, error) + type ConfigurationManager_WatchFlowServer interface + Send func(*FlowResponse) error + type ConfigurationManager_WatchGatewayClient interface + Recv func() (*GatewayResponse, error) + type ConfigurationManager_WatchGatewayServer interface + Send func(*GatewayResponse) error + type ConfigurationManager_WatchStreamClient interface + Recv func() (*StreamResponse, error) + type ConfigurationManager_WatchStreamServer interface + Send func(*StreamResponse) error + type ConfigurationManager_WatchTrenchClient interface + Recv func() (*TrenchResponse, error) + type ConfigurationManager_WatchTrenchServer interface + Send func(*TrenchResponse) error + type ConfigurationManager_WatchVipClient interface + Recv func() (*VipResponse, error) + type ConfigurationManager_WatchVipServer interface + Send func(*VipResponse) error + type Flow struct + ByteMatches []string + DestinationPortRanges []string + Name string + Priority int32 + Protocols []string + SourcePortRanges []string + SourceSubnets []string + Stream *Stream + Vips []*Vip + func (*Flow) Descriptor() ([]byte, []int) + func (*Flow) ProtoMessage() + func (f *Flow) DeepEquals(f2 *Flow) bool + func (f *Flow) Equals(f2 *Flow) bool + func (x *Flow) GetByteMatches() []string + func (x *Flow) GetDestinationPortRanges() []string + func (x *Flow) GetName() string + func (x *Flow) GetPriority() int32 + func (x *Flow) GetProtocols() []string + func (x *Flow) GetSourcePortRanges() []string + func (x *Flow) GetSourceSubnets() []string + func (x *Flow) GetStream() *Stream + func (x *Flow) GetVips() []*Vip + func (x *Flow) ProtoReflect() protoreflect.Message + func (x *Flow) Reset() + func (x *Flow) String() string + type FlowResponse struct + Flows []*Flow + func (*FlowResponse) Descriptor() ([]byte, []int) + func (*FlowResponse) ProtoMessage() + func (x *FlowResponse) GetFlows() []*Flow + func (x *FlowResponse) ProtoReflect() protoreflect.Message + func (x *FlowResponse) Reset() + func (x *FlowResponse) String() string + type Gateway struct + Address string + Bfd bool + BfdSpec *Gateway_BfdSpec + BgpAuth *Gateway_BgpAuth + HoldTime uint32 + IpFamily string + LocalASN uint32 + LocalPort uint32 + Name string + Protocol string + RemoteASN uint32 + RemotePort uint32 + Trench *Trench + func (*Gateway) Descriptor() ([]byte, []int) + func (*Gateway) ProtoMessage() + func (g *Gateway) Equals(g2 *Gateway) bool + func (x *Gateway) GetAddress() string + func (x *Gateway) GetBfd() bool + func (x *Gateway) GetBfdSpec() *Gateway_BfdSpec + func (x *Gateway) GetBgpAuth() *Gateway_BgpAuth + func (x *Gateway) GetHoldTime() uint32 + func (x *Gateway) GetIpFamily() string + func (x *Gateway) GetLocalASN() uint32 + func (x *Gateway) GetLocalPort() uint32 + func (x *Gateway) GetName() string + func (x *Gateway) GetProtocol() string + func (x *Gateway) GetRemoteASN() uint32 + func (x *Gateway) GetRemotePort() uint32 + func (x *Gateway) GetTrench() *Trench + func (x *Gateway) ProtoReflect() protoreflect.Message + func (x *Gateway) Reset() + func (x *Gateway) String() string + type GatewayResponse struct + Gateways []*Gateway + func (*GatewayResponse) Descriptor() ([]byte, []int) + func (*GatewayResponse) ProtoMessage() + func (x *GatewayResponse) GetGateways() []*Gateway + func (x *GatewayResponse) ProtoReflect() protoreflect.Message + func (x *GatewayResponse) Reset() + func (x *GatewayResponse) String() string + type Gateway_BfdSpec struct + MinRx uint32 + MinTx uint32 + Multiplier uint32 + func (*Gateway_BfdSpec) Descriptor() ([]byte, []int) + func (*Gateway_BfdSpec) ProtoMessage() + func (x *Gateway_BfdSpec) GetMinRx() uint32 + func (x *Gateway_BfdSpec) GetMinTx() uint32 + func (x *Gateway_BfdSpec) GetMultiplier() uint32 + func (x *Gateway_BfdSpec) ProtoReflect() protoreflect.Message + func (x *Gateway_BfdSpec) Reset() + func (x *Gateway_BfdSpec) String() string + type Gateway_BgpAuth struct + KeyName string + KeySource string + func (*Gateway_BgpAuth) Descriptor() ([]byte, []int) + func (*Gateway_BgpAuth) ProtoMessage() + func (x *Gateway_BgpAuth) GetKeyName() string + func (x *Gateway_BgpAuth) GetKeySource() string + func (x *Gateway_BgpAuth) ProtoReflect() protoreflect.Message + func (x *Gateway_BgpAuth) Reset() + func (x *Gateway_BgpAuth) String() string + type Stream struct + Conduit *Conduit + MaxTargets uint32 + Name string + func (*Stream) Descriptor() ([]byte, []int) + func (*Stream) ProtoMessage() + func (s *Stream) Equals(s2 *Stream) bool + func (x *Stream) GetConduit() *Conduit + func (x *Stream) GetMaxTargets() uint32 + func (x *Stream) GetName() string + func (x *Stream) ProtoReflect() protoreflect.Message + func (x *Stream) Reset() + func (x *Stream) String() string + type StreamResponse struct + Streams []*Stream + func (*StreamResponse) Descriptor() ([]byte, []int) + func (*StreamResponse) ProtoMessage() + func (x *StreamResponse) GetStreams() []*Stream + func (x *StreamResponse) ProtoReflect() protoreflect.Message + func (x *StreamResponse) Reset() + func (x *StreamResponse) String() string + type Target struct + Context map[string]string + Ips []string + Status Target_Status + Stream *Stream + Type Target_Type + func (*Target) Descriptor() ([]byte, []int) + func (*Target) ProtoMessage() + func (t *Target) Equals(t2 *Target) bool + func (x *Target) GetContext() map[string]string + func (x *Target) GetIps() []string + func (x *Target) GetStatus() Target_Status + func (x *Target) GetStream() *Stream + func (x *Target) GetType() Target_Type + func (x *Target) ProtoReflect() protoreflect.Message + func (x *Target) Reset() + func (x *Target) String() string + type TargetRegistryClient interface + Register func(ctx context.Context, in *Target, opts ...grpc.CallOption) (*emptypb.Empty, error) + Unregister func(ctx context.Context, in *Target, opts ...grpc.CallOption) (*emptypb.Empty, error) + Watch func(ctx context.Context, in *Target, opts ...grpc.CallOption) (TargetRegistry_WatchClient, error) + func NewTargetRegistryClient(cc grpc.ClientConnInterface) TargetRegistryClient + type TargetRegistryServer interface + Register func(context.Context, *Target) (*emptypb.Empty, error) + Unregister func(context.Context, *Target) (*emptypb.Empty, error) + Watch func(*Target, TargetRegistry_WatchServer) error + type TargetRegistry_WatchClient interface + Recv func() (*TargetResponse, error) + type TargetRegistry_WatchServer interface + Send func(*TargetResponse) error + type TargetResponse struct + Targets []*Target + func (*TargetResponse) Descriptor() ([]byte, []int) + func (*TargetResponse) ProtoMessage() + func (x *TargetResponse) GetTargets() []*Target + func (x *TargetResponse) ProtoReflect() protoreflect.Message + func (x *TargetResponse) Reset() + func (x *TargetResponse) String() string + type Target_Status int32 + const Target_ANY + const Target_DISABLED + const Target_ENABLED + func (Target_Status) Descriptor() protoreflect.EnumDescriptor + func (Target_Status) EnumDescriptor() ([]byte, []int) + func (Target_Status) Type() protoreflect.EnumType + func (x Target_Status) Enum() *Target_Status + func (x Target_Status) Number() protoreflect.EnumNumber + func (x Target_Status) String() string + type Target_Type int32 + const Target_DEFAULT + const Target_FRONTEND + func (Target_Type) Descriptor() protoreflect.EnumDescriptor + func (Target_Type) EnumDescriptor() ([]byte, []int) + func (Target_Type) Type() protoreflect.EnumType + func (x Target_Type) Enum() *Target_Type + func (x Target_Type) Number() protoreflect.EnumNumber + func (x Target_Type) String() string + type Trench struct + Name string + func (*Trench) Descriptor() ([]byte, []int) + func (*Trench) ProtoMessage() + func (t *Trench) Equals(t2 *Trench) bool + func (x *Trench) GetName() string + func (x *Trench) ProtoReflect() protoreflect.Message + func (x *Trench) Reset() + func (x *Trench) String() string + type TrenchResponse struct + Trench *Trench + func (*TrenchResponse) Descriptor() ([]byte, []int) + func (*TrenchResponse) ProtoMessage() + func (x *TrenchResponse) GetTrench() *Trench + func (x *TrenchResponse) ProtoReflect() protoreflect.Message + func (x *TrenchResponse) Reset() + func (x *TrenchResponse) String() string + type UnimplementedConfigurationManagerServer struct + func (UnimplementedConfigurationManagerServer) WatchAttractor(*Attractor, ConfigurationManager_WatchAttractorServer) error + func (UnimplementedConfigurationManagerServer) WatchConduit(*Conduit, ConfigurationManager_WatchConduitServer) error + func (UnimplementedConfigurationManagerServer) WatchFlow(*Flow, ConfigurationManager_WatchFlowServer) error + func (UnimplementedConfigurationManagerServer) WatchGateway(*Gateway, ConfigurationManager_WatchGatewayServer) error + func (UnimplementedConfigurationManagerServer) WatchStream(*Stream, ConfigurationManager_WatchStreamServer) error + func (UnimplementedConfigurationManagerServer) WatchTrench(*Trench, ConfigurationManager_WatchTrenchServer) error + func (UnimplementedConfigurationManagerServer) WatchVip(*Vip, ConfigurationManager_WatchVipServer) error + type UnimplementedTargetRegistryServer struct + func (UnimplementedTargetRegistryServer) Register(context.Context, *Target) (*emptypb.Empty, error) + func (UnimplementedTargetRegistryServer) Unregister(context.Context, *Target) (*emptypb.Empty, error) + func (UnimplementedTargetRegistryServer) Watch(*Target, TargetRegistry_WatchServer) error + type UnsafeConfigurationManagerServer interface + type UnsafeTargetRegistryServer interface + type Vip struct + Address string + Name string + Trench *Trench + func (*Vip) Descriptor() ([]byte, []int) + func (*Vip) ProtoMessage() + func (v *Vip) Equals(v2 *Vip) bool + func (x *Vip) GetAddress() string + func (x *Vip) GetName() string + func (x *Vip) GetTrench() *Trench + func (x *Vip) ProtoReflect() protoreflect.Message + func (x *Vip) Reset() + func (x *Vip) String() string + type VipResponse struct + Vips []*Vip + func (*VipResponse) Descriptor() ([]byte, []int) + func (*VipResponse) ProtoMessage() + func (vr *VipResponse) ToSlice() []string + func (x *VipResponse) GetVips() []*Vip + func (x *VipResponse) ProtoReflect() protoreflect.Message + func (x *VipResponse) Reset() + func (x *VipResponse) String() string
Go to main page