v1

package
v1.0.15 Latest Latest
Warning

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

Go to latest
Published: Jan 8, 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

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.

type ConfigurationManagerServer

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.

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) 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 (Target_Status) String

func (x Target_Status) String() string

func (Target_Status) Type

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) 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

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) WatchConduit

func (UnimplementedConfigurationManagerServer) WatchFlow

func (UnimplementedConfigurationManagerServer) WatchGateway

func (UnimplementedConfigurationManagerServer) WatchStream

func (UnimplementedConfigurationManagerServer) WatchTrench

func (UnimplementedConfigurationManagerServer) WatchVip

type UnimplementedTargetRegistryServer

type UnimplementedTargetRegistryServer struct {
}

UnimplementedTargetRegistryServer must be embedded to have forward compatible implementations.

func (UnimplementedTargetRegistryServer) Register

func (UnimplementedTargetRegistryServer) Unregister

func (UnimplementedTargetRegistryServer) Watch

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

Jump to

Keyboard shortcuts

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