v1

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: May 2, 2024 License: Apache-2.0 Imports: 10 Imported by: 32

Documentation

Index

Constants

View Source 
const (
	ConfigurationManager_WatchTrench_FullMethodName    = "/nsp.v1.ConfigurationManager/WatchTrench"
	ConfigurationManager_WatchConduit_FullMethodName   = "/nsp.v1.ConfigurationManager/WatchConduit"
	ConfigurationManager_WatchStream_FullMethodName    = "/nsp.v1.ConfigurationManager/WatchStream"
	ConfigurationManager_WatchFlow_FullMethodName      = "/nsp.v1.ConfigurationManager/WatchFlow"
	ConfigurationManager_WatchVip_FullMethodName       = "/nsp.v1.ConfigurationManager/WatchVip"
	ConfigurationManager_WatchAttractor_FullMethodName = "/nsp.v1.ConfigurationManager/WatchAttractor"
	ConfigurationManager_WatchGateway_FullMethodName   = "/nsp.v1.ConfigurationManager/WatchGateway"
)
View Source 
const (
	TargetRegistry_Register_FullMethodName   = "/nsp.v1.TargetRegistry/Register"
	TargetRegistry_Unregister_FullMethodName = "/nsp.v1.TargetRegistry/Unregister"
	TargetRegistry_Watch_FullMethodName      = "/nsp.v1.TargetRegistry/Watch"
)

Variables

View Source 
var (
	Target_Status_name = map[int32]string{
		0: "ENABLED",
		1: "DISABLED",
		2: "ANY",
	}
	Target_Status_value = map[string]int32{
		"ENABLED":  0,
		"DISABLED": 1,
		"ANY":      2,
	}
)

Enum value maps for Target_Status.

View Source 
var (
	Target_Type_name = map[int32]string{
		0: "DEFAULT",
		1: "FRONTEND",
	}
	Target_Type_value = map[string]int32{
		"DEFAULT":  0,
		"FRONTEND": 1,
	}
)

Enum value maps for Target_Type.

View Source 
var ConfigurationManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nsp.v1.ConfigurationManager",
	HandlerType: (*ConfigurationManagerServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchTrench",
			Handler:       _ConfigurationManager_WatchTrench_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchConduit",
			Handler:       _ConfigurationManager_WatchConduit_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchStream",
			Handler:       _ConfigurationManager_WatchStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchFlow",
			Handler:       _ConfigurationManager_WatchFlow_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchVip",
			Handler:       _ConfigurationManager_WatchVip_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchAttractor",
			Handler:       _ConfigurationManager_WatchAttractor_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchGateway",
			Handler:       _ConfigurationManager_WatchGateway_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/nsp/v1/configurationmanager.proto",
}

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

View Source 
var File_api_nsp_v1_configurationmanager_proto protoreflect.FileDescriptor
View Source 
var File_api_nsp_v1_model_proto protoreflect.FileDescriptor
View Source 
var File_api_nsp_v1_targetregistry_proto protoreflect.FileDescriptor
View Source 
var TargetRegistry_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nsp.v1.TargetRegistry",
	HandlerType: (*TargetRegistryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _TargetRegistry_Register_Handler,
		},
		{
			MethodName: "Unregister",
			Handler:    _TargetRegistry_Unregister_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _TargetRegistry_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/nsp/v1/targetregistry.proto",
}

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

Functions

func AttractorFilter 

func AttractorFilter(filter *Attractor, comparedTo *Attractor) bool

func ConduitFilter 

func ConduitFilter(filter *Conduit, comparedTo *Conduit) bool

func FlowFilter 

func FlowFilter(filter *Flow, comparedTo *Flow) bool

func GatewayFilter 

func GatewayFilter(filter *Gateway, comparedTo *Gateway) bool

func RegisterConfigurationManagerServer 

func RegisterConfigurationManagerServer(s grpc.ServiceRegistrar, srv ConfigurationManagerServer)

func RegisterTargetRegistryServer 

func RegisterTargetRegistryServer(s grpc.ServiceRegistrar, srv TargetRegistryServer)

func StreamFilter 

func StreamFilter(filter *Stream, comparedTo *Stream) bool

func TargetFilter 

func TargetFilter(filter *Target, comparedTo *Target) bool

func TrenchFilter 

func TrenchFilter(filter *Trench, comparedTo *Trench) bool

func VipFilter 

func VipFilter(filter *Vip, comparedTo *Vip) bool

Types

type Attractor 

type Attractor struct {

	// Name of the attractor
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Trench the attractor belongs to
	Trench   *Trench    `protobuf:"bytes,2,opt,name=trench,proto3" json:"trench,omitempty"`
	Vips     []*Vip     `protobuf:"bytes,3,rep,name=vips,proto3" json:"vips,omitempty"`
	Gateways []*Gateway `protobuf:"bytes,4,rep,name=gateways,proto3" json:"gateways,omitempty"`
	// contains filtered or unexported fields
}

func (*Attractor) Descriptor deprecated 

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

Deprecated: Use Attractor.ProtoReflect.Descriptor instead.

func (*Attractor) Equals 

func (a *Attractor) Equals(a2 *Attractor) bool

func (*Attractor) GetGateways 

func (x *Attractor) GetGateways() []*Gateway

func (*Attractor) GetName 

func (x *Attractor) GetName() string

func (*Attractor) GetTrench 

func (x *Attractor) GetTrench() *Trench

func (*Attractor) GetVips 

func (x *Attractor) GetVips() []*Vip

func (*Attractor) ProtoMessage 

func (*Attractor) ProtoMessage()

func (*Attractor) ProtoReflect 

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

func (*Attractor) Reset 

func (x *Attractor) Reset()

func (*Attractor) String 

func (x *Attractor) String() string

type AttractorResponse 

type AttractorResponse struct {
	Attractors []*Attractor `protobuf:"bytes,1,rep,name=attractors,proto3" json:"attractors,omitempty"`
	// contains filtered or unexported fields
}

func (*AttractorResponse) Descriptor deprecated 

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

Deprecated: Use AttractorResponse.ProtoReflect.Descriptor instead.

func (*AttractorResponse) GetAttractors 

func (x *AttractorResponse) GetAttractors() []*Attractor

func (*AttractorResponse) ProtoMessage 

func (*AttractorResponse) ProtoMessage()

func (*AttractorResponse) ProtoReflect 

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

func (*AttractorResponse) Reset 

func (x *AttractorResponse) Reset()

func (*AttractorResponse) String 

func (x *AttractorResponse) String() string

type Conduit 

type Conduit struct {

	// Name of the conduit
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Trench the conduit belongs to
	Trench *Trench `protobuf:"bytes,2,opt,name=trench,proto3" json:"trench,omitempty"`
	// The list of destination port NATs
	// If the VIP is nil then any VIP will be considered
	DestinationPortNats []*Conduit_PortNat `protobuf:"bytes,3,rep,name=destinationPortNats,proto3" json:"destinationPortNats,omitempty"`
	// contains filtered or unexported fields
}

func (*Conduit) Descriptor deprecated 

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

Deprecated: Use Conduit.ProtoReflect.Descriptor instead.

func (*Conduit) Equals 

func (c *Conduit) Equals(c2 *Conduit) bool

func (*Conduit) GetDestinationPortNats added in v0.8.0 

func (x *Conduit) GetDestinationPortNats() []*Conduit_PortNat

func (*Conduit) GetName 

func (x *Conduit) GetName() string

func (*Conduit) GetTrench 

func (x *Conduit) GetTrench() *Trench

func (*Conduit) ProtoMessage 

func (*Conduit) ProtoMessage()

func (*Conduit) ProtoReflect 

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

func (*Conduit) Reset 

func (x *Conduit) Reset()

func (*Conduit) String 

func (x *Conduit) String() string

type ConduitResponse 

type ConduitResponse struct {
	Conduits []*Conduit `protobuf:"bytes,1,rep,name=conduits,proto3" json:"conduits,omitempty"`
	// contains filtered or unexported fields
}

func (*ConduitResponse) Descriptor deprecated 

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

Deprecated: Use ConduitResponse.ProtoReflect.Descriptor instead.

func (*ConduitResponse) GetConduits 

func (x *ConduitResponse) GetConduits() []*Conduit

func (*ConduitResponse) ProtoMessage 

func (*ConduitResponse) ProtoMessage()

func (*ConduitResponse) ProtoReflect 

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

func (*ConduitResponse) Reset 

func (x *ConduitResponse) Reset()

func (*ConduitResponse) String 

func (x *ConduitResponse) String() string

type Conduit_PortNat added in v0.8.0 

type Conduit_PortNat struct {
	Port       uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	TargetPort uint32 `protobuf:"varint,2,opt,name=targetPort,proto3" json:"targetPort,omitempty"`
	Vips       []*Vip `protobuf:"bytes,3,rep,name=vips,proto3" json:"vips,omitempty"`
	Protocol   string `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

func PortNatDiff added in v0.8.0 

func PortNatDiff(set1 []*Conduit_PortNat, set2 []*Conduit_PortNat) []*Conduit_PortNat

Checks the differences between 2 port nat list

func (*Conduit_PortNat) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use Conduit_PortNat.ProtoReflect.Descriptor instead.

func (*Conduit_PortNat) GetNatName added in v0.8.0 

func (pn *Conduit_PortNat) GetNatName() string

func (*Conduit_PortNat) GetPort added in v0.8.0 

func (x *Conduit_PortNat) GetPort() uint32

func (*Conduit_PortNat) GetProtocol added in v0.8.0 

func (x *Conduit_PortNat) GetProtocol() string

func (*Conduit_PortNat) GetTargetPort added in v0.8.0 

func (x *Conduit_PortNat) GetTargetPort() uint32

func (*Conduit_PortNat) GetVips added in v0.8.0 

func (x *Conduit_PortNat) GetVips() []*Vip

func (*Conduit_PortNat) ProtoMessage added in v0.8.0 

func (*Conduit_PortNat) ProtoMessage()

func (*Conduit_PortNat) ProtoReflect added in v0.8.0 

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

func (*Conduit_PortNat) Reset added in v0.8.0 

func (x *Conduit_PortNat) Reset()

func (*Conduit_PortNat) String added in v0.8.0 

func (x *Conduit_PortNat) String() string

type ConfigurationManagerClient 

type ConfigurationManagerClient interface {
	WatchTrench(ctx context.Context, in *Trench, opts ...grpc.CallOption) (ConfigurationManager_WatchTrenchClient, error)
	WatchConduit(ctx context.Context, in *Conduit, opts ...grpc.CallOption) (ConfigurationManager_WatchConduitClient, error)
	WatchStream(ctx context.Context, in *Stream, opts ...grpc.CallOption) (ConfigurationManager_WatchStreamClient, error)
	WatchFlow(ctx context.Context, in *Flow, opts ...grpc.CallOption) (ConfigurationManager_WatchFlowClient, error)
	WatchVip(ctx context.Context, in *Vip, opts ...grpc.CallOption) (ConfigurationManager_WatchVipClient, error)
	WatchAttractor(ctx context.Context, in *Attractor, opts ...grpc.CallOption) (ConfigurationManager_WatchAttractorClient, error)
	WatchGateway(ctx context.Context, in *Gateway, opts ...grpc.CallOption) (ConfigurationManager_WatchGatewayClient, error)
}

ConfigurationManagerClient is the client API for ConfigurationManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewConfigurationManagerClient 

func NewConfigurationManagerClient(cc grpc.ClientConnInterface) ConfigurationManagerClient

type ConfigurationManagerServer 

type ConfigurationManagerServer interface {
	WatchTrench(*Trench, ConfigurationManager_WatchTrenchServer) error
	WatchConduit(*Conduit, ConfigurationManager_WatchConduitServer) error
	WatchStream(*Stream, ConfigurationManager_WatchStreamServer) error
	WatchFlow(*Flow, ConfigurationManager_WatchFlowServer) error
	WatchVip(*Vip, ConfigurationManager_WatchVipServer) error
	WatchAttractor(*Attractor, ConfigurationManager_WatchAttractorServer) error
	WatchGateway(*Gateway, ConfigurationManager_WatchGatewayServer) error
	// contains filtered or unexported methods
}

ConfigurationManagerServer is the server API for ConfigurationManager service. All implementations must embed UnimplementedConfigurationManagerServer for forward compatibility

type ConfigurationManager_WatchAttractorClient 

type ConfigurationManager_WatchAttractorClient interface {
	Recv() (*AttractorResponse, error)
	grpc.ClientStream
}

type ConfigurationManager_WatchAttractorServer 

type ConfigurationManager_WatchAttractorServer interface {
	Send(*AttractorResponse) error
	grpc.ServerStream
}

type ConfigurationManager_WatchConduitClient 

type ConfigurationManager_WatchConduitClient interface {
	Recv() (*ConduitResponse, error)
	grpc.ClientStream
}

type ConfigurationManager_WatchConduitServer 

type ConfigurationManager_WatchConduitServer interface {
	Send(*ConduitResponse) error
	grpc.ServerStream
}

type ConfigurationManager_WatchFlowClient 

type ConfigurationManager_WatchFlowClient interface {
	Recv() (*FlowResponse, error)
	grpc.ClientStream
}

type ConfigurationManager_WatchFlowServer 

type ConfigurationManager_WatchFlowServer interface {
	Send(*FlowResponse) error
	grpc.ServerStream
}

type ConfigurationManager_WatchGatewayClient 

type ConfigurationManager_WatchGatewayClient interface {
	Recv() (*GatewayResponse, error)
	grpc.ClientStream
}

type ConfigurationManager_WatchGatewayServer 

type ConfigurationManager_WatchGatewayServer interface {
	Send(*GatewayResponse) error
	grpc.ServerStream
}

type ConfigurationManager_WatchStreamClient 

type ConfigurationManager_WatchStreamClient interface {
	Recv() (*StreamResponse, error)
	grpc.ClientStream
}

type ConfigurationManager_WatchStreamServer 

type ConfigurationManager_WatchStreamServer interface {
	Send(*StreamResponse) error
	grpc.ServerStream
}

type ConfigurationManager_WatchTrenchClient 

type ConfigurationManager_WatchTrenchClient interface {
	Recv() (*TrenchResponse, error)
	grpc.ClientStream
}

type ConfigurationManager_WatchTrenchServer 

type ConfigurationManager_WatchTrenchServer interface {
	Send(*TrenchResponse) error
	grpc.ServerStream
}

type ConfigurationManager_WatchVipClient 

type ConfigurationManager_WatchVipClient interface {
	Recv() (*VipResponse, error)
	grpc.ClientStream
}

type ConfigurationManager_WatchVipServer 

type ConfigurationManager_WatchVipServer interface {
	Send(*VipResponse) error
	grpc.ServerStream
}

type Flow 

type Flow struct {

	// Name of the flow
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Source subnets allowed in the flow
	// e.g.: ["124.0.0.0/24", "2001::/32"]
	SourceSubnets []string `protobuf:"bytes,2,rep,name=sourceSubnets,proto3" json:"sourceSubnets,omitempty"`
	// Destination port ranges allowed in the flow
	// e.g.: ["80", "90-95"]
	DestinationPortRanges []string `protobuf:"bytes,3,rep,name=destinationPortRanges,proto3" json:"destinationPortRanges,omitempty"`
	// Source port ranges allowed in the flow
	// e.g.: ["35000-35500", "40000"]
	SourcePortRanges []string `protobuf:"bytes,4,rep,name=sourcePortRanges,proto3" json:"sourcePortRanges,omitempty"`
	// Protocols allowed
	// e.g.: ["tcp", "udp"]
	Protocols []string `protobuf:"bytes,5,rep,name=protocols,proto3" json:"protocols,omitempty"`
	// Priority of the flow
	Priority int32 `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"`
	// Stream the flow belongs to
	Stream *Stream `protobuf:"bytes,7,opt,name=stream,proto3" json:"stream,omitempty"`
	Vips   []*Vip  `protobuf:"bytes,8,rep,name=vips,proto3" json:"vips,omitempty"`
	// Bytes in L4 header
	ByteMatches []string `protobuf:"bytes,10,rep,name=byteMatches,proto3" json:"byteMatches,omitempty"`
	// contains filtered or unexported fields
}

func (*Flow) DeepEquals added in v0.4.0 

func (f *Flow) DeepEquals(f2 *Flow) bool

func (*Flow) Descriptor deprecated 

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

Deprecated: Use Flow.ProtoReflect.Descriptor instead.

func (*Flow) Equals 

func (f *Flow) Equals(f2 *Flow) bool

func (*Flow) GetByteMatches added in v0.7.0 

func (x *Flow) GetByteMatches() []string

func (*Flow) GetDestinationPortRanges 

func (x *Flow) GetDestinationPortRanges() []string

func (*Flow) GetName 

func (x *Flow) GetName() string

func (*Flow) GetPriority 

func (x *Flow) GetPriority() int32

func (*Flow) GetProtocols 

func (x *Flow) GetProtocols() []string

func (*Flow) GetSourcePortRanges 

func (x *Flow) GetSourcePortRanges() []string

func (*Flow) GetSourceSubnets 

func (x *Flow) GetSourceSubnets() []string

func (*Flow) GetStream 

func (x *Flow) GetStream() *Stream

func (*Flow) GetVips 

func (x *Flow) GetVips() []*Vip

func (*Flow) ProtoMessage 

func (*Flow) ProtoMessage()

func (*Flow) ProtoReflect 

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

func (*Flow) Reset 

func (x *Flow) Reset()

func (*Flow) String 

func (x *Flow) String() string

type FlowResponse 

type FlowResponse struct {
	Flows []*Flow `protobuf:"bytes,1,rep,name=flows,proto3" json:"flows,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowResponse) Descriptor deprecated 

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

Deprecated: Use FlowResponse.ProtoReflect.Descriptor instead.

func (*FlowResponse) GetFlows 

func (x *FlowResponse) GetFlows() []*Flow

func (*FlowResponse) ProtoMessage 

func (*FlowResponse) ProtoMessage()

func (*FlowResponse) ProtoReflect 

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

func (*FlowResponse) Reset 

func (x *FlowResponse) Reset()

func (*FlowResponse) String 

func (x *FlowResponse) String() string

type Gateway 

type Gateway struct {

	// Name of the vip
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// address of the gateway
	// e.g.: 124.0.0.0/24 or 2001::/32
	Address    string           `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	IpFamily   string           `protobuf:"bytes,3,opt,name=ipFamily,proto3" json:"ipFamily,omitempty"`
	Protocol   string           `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	RemoteASN  uint32           `protobuf:"varint,5,opt,name=remoteASN,proto3" json:"remoteASN,omitempty"`
	LocalASN   uint32           `protobuf:"varint,6,opt,name=localASN,proto3" json:"localASN,omitempty"`
	RemotePort uint32           `protobuf:"varint,7,opt,name=remotePort,proto3" json:"remotePort,omitempty"`
	LocalPort  uint32           `protobuf:"varint,8,opt,name=localPort,proto3" json:"localPort,omitempty"`
	HoldTime   uint32           `protobuf:"varint,9,opt,name=holdTime,proto3" json:"holdTime,omitempty"`
	Bfd        bool             `protobuf:"varint,10,opt,name=bfd,proto3" json:"bfd,omitempty"`
	BfdSpec    *Gateway_BfdSpec `protobuf:"bytes,11,opt,name=bfdSpec,proto3" json:"bfdSpec,omitempty"`
	// Trench the gateway belongs to
	Trench  *Trench          `protobuf:"bytes,12,opt,name=trench,proto3" json:"trench,omitempty"`
	BgpAuth *Gateway_BgpAuth `protobuf:"bytes,13,opt,name=bgpAuth,proto3" json:"bgpAuth,omitempty"`
	// contains filtered or unexported fields
}

func (*Gateway) Descriptor deprecated 

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

Deprecated: Use Gateway.ProtoReflect.Descriptor instead.

func (*Gateway) Equals 

func (g *Gateway) Equals(g2 *Gateway) bool

func (*Gateway) GetAddress 

func (x *Gateway) GetAddress() string

func (*Gateway) GetBfd 

func (x *Gateway) GetBfd() bool

func (*Gateway) GetBfdSpec 

func (x *Gateway) GetBfdSpec() *Gateway_BfdSpec

func (*Gateway) GetBgpAuth added in v0.9.0 

func (x *Gateway) GetBgpAuth() *Gateway_BgpAuth

func (*Gateway) GetHoldTime 

func (x *Gateway) GetHoldTime() uint32

func (*Gateway) GetIpFamily 

func (x *Gateway) GetIpFamily() string

func (*Gateway) GetLocalASN 

func (x *Gateway) GetLocalASN() uint32

func (*Gateway) GetLocalPort 

func (x *Gateway) GetLocalPort() uint32

func (*Gateway) GetName 

func (x *Gateway) GetName() string

func (*Gateway) GetProtocol 

func (x *Gateway) GetProtocol() string

func (*Gateway) GetRemoteASN 

func (x *Gateway) GetRemoteASN() uint32

func (*Gateway) GetRemotePort 

func (x *Gateway) GetRemotePort() uint32

func (*Gateway) GetTrench 

func (x *Gateway) GetTrench() *Trench

func (*Gateway) ProtoMessage 

func (*Gateway) ProtoMessage()

func (*Gateway) ProtoReflect 

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

func (*Gateway) Reset 

func (x *Gateway) Reset()

func (*Gateway) String 

func (x *Gateway) String() string

type GatewayResponse 

type GatewayResponse struct {
	Gateways []*Gateway `protobuf:"bytes,1,rep,name=gateways,proto3" json:"gateways,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewayResponse) Descriptor deprecated 

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

Deprecated: Use GatewayResponse.ProtoReflect.Descriptor instead.

func (*GatewayResponse) GetGateways 

func (x *GatewayResponse) GetGateways() []*Gateway

func (*GatewayResponse) ProtoMessage 

func (*GatewayResponse) ProtoMessage()

func (*GatewayResponse) ProtoReflect 

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

func (*GatewayResponse) Reset 

func (x *GatewayResponse) Reset()

func (*GatewayResponse) String 

func (x *GatewayResponse) String() string

type Gateway_BfdSpec 

type Gateway_BfdSpec struct {
	MinTx      uint32 `protobuf:"varint,1,opt,name=MinTx,proto3" json:"MinTx,omitempty"`
	MinRx      uint32 `protobuf:"varint,2,opt,name=MinRx,proto3" json:"MinRx,omitempty"`
	Multiplier uint32 `protobuf:"varint,3,opt,name=Multiplier,proto3" json:"Multiplier,omitempty"`
	// contains filtered or unexported fields
}

func (*Gateway_BfdSpec) Descriptor deprecated 

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

Deprecated: Use Gateway_BfdSpec.ProtoReflect.Descriptor instead.

func (*Gateway_BfdSpec) GetMinRx 

func (x *Gateway_BfdSpec) GetMinRx() uint32

func (*Gateway_BfdSpec) GetMinTx 

func (x *Gateway_BfdSpec) GetMinTx() uint32

func (*Gateway_BfdSpec) GetMultiplier 

func (x *Gateway_BfdSpec) GetMultiplier() uint32

func (*Gateway_BfdSpec) ProtoMessage 

func (*Gateway_BfdSpec) ProtoMessage()

func (*Gateway_BfdSpec) ProtoReflect 

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

func (*Gateway_BfdSpec) Reset 

func (x *Gateway_BfdSpec) Reset()

func (*Gateway_BfdSpec) String 

func (x *Gateway_BfdSpec) String() string

type Gateway_BgpAuth added in v0.9.0 

type Gateway_BgpAuth struct {
	KeyName   string `protobuf:"bytes,1,opt,name=keyName,proto3" json:"keyName,omitempty"`
	KeySource string `protobuf:"bytes,2,opt,name=keySource,proto3" json:"keySource,omitempty"`
	// contains filtered or unexported fields
}

func (*Gateway_BgpAuth) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Gateway_BgpAuth.ProtoReflect.Descriptor instead.

func (*Gateway_BgpAuth) GetKeyName added in v0.9.0 

func (x *Gateway_BgpAuth) GetKeyName() string

func (*Gateway_BgpAuth) GetKeySource added in v0.9.0 

func (x *Gateway_BgpAuth) GetKeySource() string

func (*Gateway_BgpAuth) ProtoMessage added in v0.9.0 

func (*Gateway_BgpAuth) ProtoMessage()

func (*Gateway_BgpAuth) ProtoReflect added in v0.9.0 

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

func (*Gateway_BgpAuth) Reset added in v0.9.0 

func (x *Gateway_BgpAuth) Reset()

func (*Gateway_BgpAuth) String added in v0.9.0 

func (x *Gateway_BgpAuth) String() string

type Stream 

type Stream struct {

	// Name of the stream
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Conduit the stream belongs to
	Conduit *Conduit `protobuf:"bytes,2,opt,name=conduit,proto3" json:"conduit,omitempty"`
	// Max number of targets the stream supports
	MaxTargets uint32 `protobuf:"varint,3,opt,name=maxTargets,proto3" json:"maxTargets,omitempty"`
	// contains filtered or unexported fields
}

func (*Stream) Descriptor deprecated 

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) Equals 

func (s *Stream) Equals(s2 *Stream) bool

func (*Stream) GetConduit 

func (x *Stream) GetConduit() *Conduit

func (*Stream) GetMaxTargets added in v0.9.0 

func (x *Stream) GetMaxTargets() uint32

func (*Stream) GetName 

func (x *Stream) GetName() string

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

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

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) String 

func (x *Stream) String() string

type StreamResponse 

type StreamResponse struct {
	Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamResponse) Descriptor deprecated 

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

Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.

func (*StreamResponse) GetStreams 

func (x *StreamResponse) GetStreams() []*Stream

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) ProtoReflect 

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

func (*StreamResponse) Reset 

func (x *StreamResponse) Reset()

func (*StreamResponse) String 

func (x *StreamResponse) String() string

type Target 

type Target struct {
	Ips     []string          `protobuf:"bytes,1,rep,name=ips,proto3" json:"ips,omitempty"`
	Context map[string]string `` /* 155-byte string literal not displayed */
	Status  Target_Status     `protobuf:"varint,3,opt,name=status,proto3,enum=nsp.v1.Target_Status" json:"status,omitempty"`
	Type    Target_Type       `protobuf:"varint,4,opt,name=type,proto3,enum=nsp.v1.Target_Type" json:"type,omitempty"`
	Stream  *Stream           `protobuf:"bytes,5,opt,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

func (*Target) Descriptor deprecated 

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

Deprecated: Use Target.ProtoReflect.Descriptor instead.

func (*Target) Equals 

func (t *Target) Equals(t2 *Target) bool

func (*Target) GetContext 

func (x *Target) GetContext() map[string]string

func (*Target) GetIps 

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

func (*Target) GetStatus 

func (x *Target) GetStatus() Target_Status

func (*Target) GetStream 

func (x *Target) GetStream() *Stream

func (*Target) GetType 

func (x *Target) GetType() Target_Type

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) ProtoReflect 

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

func (*Target) Reset 

func (x *Target) Reset()

func (*Target) String 

func (x *Target) String() string

type TargetRegistryClient 

type TargetRegistryClient interface {
	Register(ctx context.Context, in *Target, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Unregister(ctx context.Context, in *Target, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Watch(ctx context.Context, in *Target, opts ...grpc.CallOption) (TargetRegistry_WatchClient, error)
}

TargetRegistryClient is the client API for TargetRegistry service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTargetRegistryClient 

func NewTargetRegistryClient(cc grpc.ClientConnInterface) TargetRegistryClient

type TargetRegistryServer 

type TargetRegistryServer interface {
	Register(context.Context, *Target) (*emptypb.Empty, error)
	Unregister(context.Context, *Target) (*emptypb.Empty, error)
	Watch(*Target, TargetRegistry_WatchServer) error
	// contains filtered or unexported methods
}

TargetRegistryServer is the server API for TargetRegistry service. All implementations must embed UnimplementedTargetRegistryServer for forward compatibility

type TargetRegistry_WatchClient 

type TargetRegistry_WatchClient interface {
	Recv() (*TargetResponse, error)
	grpc.ClientStream
}

type TargetRegistry_WatchServer 

type TargetRegistry_WatchServer interface {
	Send(*TargetResponse) error
	grpc.ServerStream
}

type TargetResponse 

type TargetResponse struct {
	Targets []*Target `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

func (*TargetResponse) Descriptor deprecated 

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

Deprecated: Use TargetResponse.ProtoReflect.Descriptor instead.

func (*TargetResponse) GetTargets 

func (x *TargetResponse) GetTargets() []*Target

func (*TargetResponse) ProtoMessage 

func (*TargetResponse) ProtoMessage()

func (*TargetResponse) ProtoReflect 

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

func (*TargetResponse) Reset 

func (x *TargetResponse) Reset()

func (*TargetResponse) String 

func (x *TargetResponse) String() string

type Target_Status 

type Target_Status int32
const (
	Target_ENABLED  Target_Status = 0
	Target_DISABLED Target_Status = 1
	Target_ANY      Target_Status = 2
)

func (Target_Status) Descriptor 

func (Target_Status) Descriptor() protoreflect.EnumDescriptor

func (Target_Status) Enum 

func (x Target_Status) Enum() *Target_Status

func (Target_Status) EnumDescriptor deprecated 

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

Deprecated: Use Target_Status.Descriptor instead.

func (Target_Status) Number 

func (x Target_Status) Number() protoreflect.EnumNumber

func (Target_Status) String 

func (x Target_Status) String() string

func (Target_Status) Type 

func (Target_Status) Type() protoreflect.EnumType

type Target_Type 

type Target_Type int32
const (
	Target_DEFAULT  Target_Type = 0
	Target_FRONTEND Target_Type = 1
)

func (Target_Type) Descriptor 

func (Target_Type) Descriptor() protoreflect.EnumDescriptor

func (Target_Type) Enum 

func (x Target_Type) Enum() *Target_Type

func (Target_Type) EnumDescriptor deprecated 

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

Deprecated: Use Target_Type.Descriptor instead.

func (Target_Type) Number 

func (x Target_Type) Number() protoreflect.EnumNumber

func (Target_Type) String 

func (x Target_Type) String() string

func (Target_Type) Type 

func (Target_Type) Type() protoreflect.EnumType

type Trench 

type Trench struct {

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

func (*Trench) Descriptor deprecated 

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

Deprecated: Use Trench.ProtoReflect.Descriptor instead.

func (*Trench) Equals 

func (t *Trench) Equals(t2 *Trench) bool

func (*Trench) GetName 

func (x *Trench) GetName() string

func (*Trench) ProtoMessage 

func (*Trench) ProtoMessage()

func (*Trench) ProtoReflect 

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

func (*Trench) Reset 

func (x *Trench) Reset()

func (*Trench) String 

func (x *Trench) String() string

type TrenchResponse 

type TrenchResponse struct {
	Trench *Trench `protobuf:"bytes,1,opt,name=trench,proto3" json:"trench,omitempty"`
	// contains filtered or unexported fields
}

func (*TrenchResponse) Descriptor deprecated 

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

Deprecated: Use TrenchResponse.ProtoReflect.Descriptor instead.

func (*TrenchResponse) GetTrench 

func (x *TrenchResponse) GetTrench() *Trench

func (*TrenchResponse) ProtoMessage 

func (*TrenchResponse) ProtoMessage()

func (*TrenchResponse) ProtoReflect 

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

func (*TrenchResponse) Reset 

func (x *TrenchResponse) Reset()

func (*TrenchResponse) String 

func (x *TrenchResponse) String() string

type UnimplementedConfigurationManagerServer 

type UnimplementedConfigurationManagerServer struct {
}

UnimplementedConfigurationManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedConfigurationManagerServer) WatchAttractor 

func (UnimplementedConfigurationManagerServer) WatchAttractor(*Attractor, ConfigurationManager_WatchAttractorServer) error

func (UnimplementedConfigurationManagerServer) WatchConduit 

func (UnimplementedConfigurationManagerServer) WatchConduit(*Conduit, ConfigurationManager_WatchConduitServer) error

func (UnimplementedConfigurationManagerServer) WatchFlow 

func (UnimplementedConfigurationManagerServer) WatchFlow(*Flow, ConfigurationManager_WatchFlowServer) error

func (UnimplementedConfigurationManagerServer) WatchGateway 

func (UnimplementedConfigurationManagerServer) WatchGateway(*Gateway, ConfigurationManager_WatchGatewayServer) error

func (UnimplementedConfigurationManagerServer) WatchStream 

func (UnimplementedConfigurationManagerServer) WatchStream(*Stream, ConfigurationManager_WatchStreamServer) error

func (UnimplementedConfigurationManagerServer) WatchTrench 

func (UnimplementedConfigurationManagerServer) WatchTrench(*Trench, ConfigurationManager_WatchTrenchServer) error

func (UnimplementedConfigurationManagerServer) WatchVip 

func (UnimplementedConfigurationManagerServer) WatchVip(*Vip, ConfigurationManager_WatchVipServer) error

type UnimplementedTargetRegistryServer 

type UnimplementedTargetRegistryServer struct {
}

UnimplementedTargetRegistryServer must be embedded to have forward compatible implementations.

func (UnimplementedTargetRegistryServer) Register 

func (UnimplementedTargetRegistryServer) Register(context.Context, *Target) (*emptypb.Empty, error)

func (UnimplementedTargetRegistryServer) Unregister 

func (UnimplementedTargetRegistryServer) Unregister(context.Context, *Target) (*emptypb.Empty, error)

func (UnimplementedTargetRegistryServer) Watch 

func (UnimplementedTargetRegistryServer) Watch(*Target, TargetRegistry_WatchServer) error

type UnsafeConfigurationManagerServer added in v0.8.0 

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

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

type UnsafeTargetRegistryServer added in v0.8.0 

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

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

type Vip 

type Vip struct {

	// Name of the vip
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// vip address
	// e.g.: 124.0.0.0/24 or 2001::/32
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// Trench the vip belongs to
	Trench *Trench `protobuf:"bytes,3,opt,name=trench,proto3" json:"trench,omitempty"`
	// contains filtered or unexported fields
}

func (*Vip) Descriptor deprecated 

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

Deprecated: Use Vip.ProtoReflect.Descriptor instead.

func (*Vip) Equals 

func (v *Vip) Equals(v2 *Vip) bool

func (*Vip) GetAddress 

func (x *Vip) GetAddress() string

func (*Vip) GetName 

func (x *Vip) GetName() string

func (*Vip) GetTrench 

func (x *Vip) GetTrench() *Trench

func (*Vip) ProtoMessage 

func (*Vip) ProtoMessage()

func (*Vip) ProtoReflect 

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

func (*Vip) Reset 

func (x *Vip) Reset()

func (*Vip) String 

func (x *Vip) String() string

type VipResponse 

type VipResponse struct {
	Vips []*Vip `protobuf:"bytes,1,rep,name=vips,proto3" json:"vips,omitempty"`
	// contains filtered or unexported fields
}

func (*VipResponse) Descriptor deprecated 

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

Deprecated: Use VipResponse.ProtoReflect.Descriptor instead.

func (*VipResponse) GetVips 

func (x *VipResponse) GetVips() []*Vip

func (*VipResponse) ProtoMessage 

func (*VipResponse) ProtoMessage()

func (*VipResponse) ProtoReflect 

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

func (*VipResponse) Reset 

func (x *VipResponse) Reset()

func (*VipResponse) String 

func (x *VipResponse) String() string

func (*VipResponse) ToSlice 

func (vr *VipResponse) ToSlice() []string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.