v1

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2022 License: Apache-2.0 Imports: 9 Imported by: 32

Documentation

Index

Constants

This section is empty.

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

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.Server, srv ConfigurationManagerServer)

func RegisterTargetRegistryServer 

func RegisterTargetRegistryServer(s *grpc.Server, 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"`
	// 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) 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 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://godoc.org/google.golang.org/grpc#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
}

ConfigurationManagerServer is the server API for ConfigurationManager service.

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"`
	// 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) 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"`
	// 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) 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 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"`
	// 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) 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://godoc.org/google.golang.org/grpc#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
}

TargetRegistryServer is the server API for TargetRegistry service.

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 can 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 can 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 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.