underlay

package
v0.0.5-alpha Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterUnderlayControllerServer 

func RegisterUnderlayControllerServer(s *grpc.Server, srv UnderlayControllerServer)

Types

type AllocateRequest 

type AllocateRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AllocateRequest) Descriptor 

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

func (*AllocateRequest) GetId 

func (m *AllocateRequest) GetId() string

func (*AllocateRequest) ProtoMessage 

func (*AllocateRequest) ProtoMessage()

func (*AllocateRequest) Reset 

func (m *AllocateRequest) Reset()

func (*AllocateRequest) String 

func (m *AllocateRequest) String() string

func (*AllocateRequest) XXX_DiscardUnknown 

func (m *AllocateRequest) XXX_DiscardUnknown()

func (*AllocateRequest) XXX_Marshal 

func (m *AllocateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AllocateRequest) XXX_Merge 

func (m *AllocateRequest) XXX_Merge(src proto.Message)

func (*AllocateRequest) XXX_Size 

func (m *AllocateRequest) XXX_Size() int

func (*AllocateRequest) XXX_Unmarshal 

func (m *AllocateRequest) XXX_Unmarshal(b []byte) error

type AllocateResponse 

type AllocateResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AllocateResponse) Descriptor 

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

func (*AllocateResponse) ProtoMessage 

func (*AllocateResponse) ProtoMessage()

func (*AllocateResponse) Reset 

func (m *AllocateResponse) Reset()

func (*AllocateResponse) String 

func (m *AllocateResponse) String() string

func (*AllocateResponse) XXX_DiscardUnknown 

func (m *AllocateResponse) XXX_DiscardUnknown()

func (*AllocateResponse) XXX_Marshal 

func (m *AllocateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AllocateResponse) XXX_Merge 

func (m *AllocateResponse) XXX_Merge(src proto.Message)

func (*AllocateResponse) XXX_Size 

func (m *AllocateResponse) XXX_Size() int

func (*AllocateResponse) XXX_Unmarshal 

func (m *AllocateResponse) XXX_Unmarshal(b []byte) error

type DiscoverRequest 

type DiscoverRequest struct {
	Rules                []*PolicyRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	PeerNodes            []string      `protobuf:"bytes,2,rep,name=peerNodes,proto3" json:"peerNodes,omitempty"`
	EligibleNodes        []string      `protobuf:"bytes,3,rep,name=eligibleNodes,proto3" json:"eligibleNodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*DiscoverRequest) Descriptor 

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

func (*DiscoverRequest) GetEligibleNodes 

func (m *DiscoverRequest) GetEligibleNodes() []string

func (*DiscoverRequest) GetPeerNodes 

func (m *DiscoverRequest) GetPeerNodes() []string

func (*DiscoverRequest) GetRules 

func (m *DiscoverRequest) GetRules() []*PolicyRule

func (*DiscoverRequest) ProtoMessage 

func (*DiscoverRequest) ProtoMessage()

func (*DiscoverRequest) Reset 

func (m *DiscoverRequest) Reset()

func (*DiscoverRequest) String 

func (m *DiscoverRequest) String() string

func (*DiscoverRequest) XXX_DiscardUnknown 

func (m *DiscoverRequest) XXX_DiscardUnknown()

func (*DiscoverRequest) XXX_Marshal 

func (m *DiscoverRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverRequest) XXX_Merge 

func (m *DiscoverRequest) XXX_Merge(src proto.Message)

func (*DiscoverRequest) XXX_Size 

func (m *DiscoverRequest) XXX_Size() int

func (*DiscoverRequest) XXX_Unmarshal 

func (m *DiscoverRequest) XXX_Unmarshal(b []byte) error

type DiscoverResponse 

type DiscoverResponse struct {
	Offers               []*Offer `protobuf:"bytes,1,rep,name=offers,proto3" json:"offers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiscoverResponse) Descriptor 

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

func (*DiscoverResponse) GetOffers 

func (m *DiscoverResponse) GetOffers() []*Offer

func (*DiscoverResponse) ProtoMessage 

func (*DiscoverResponse) ProtoMessage()

func (*DiscoverResponse) Reset 

func (m *DiscoverResponse) Reset()

func (*DiscoverResponse) String 

func (m *DiscoverResponse) String() string

func (*DiscoverResponse) XXX_DiscardUnknown 

func (m *DiscoverResponse) XXX_DiscardUnknown()

func (*DiscoverResponse) XXX_Marshal 

func (m *DiscoverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverResponse) XXX_Merge 

func (m *DiscoverResponse) XXX_Merge(src proto.Message)

func (*DiscoverResponse) XXX_Size 

func (m *DiscoverResponse) XXX_Size() int

func (*DiscoverResponse) XXX_Unmarshal 

func (m *DiscoverResponse) XXX_Unmarshal(b []byte) error

type MitigateRequest 

type MitigateRequest struct {
	Id                   []string      `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
	Src                  *NodeRef      `protobuf:"bytes,2,opt,name=src,proto3" json:"src,omitempty"`
	Peer                 *NodeRef      `protobuf:"bytes,3,opt,name=peer,proto3" json:"peer,omitempty"`
	Rules                []*PolicyRule `protobuf:"bytes,4,rep,name=rules,proto3" json:"rules,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*MitigateRequest) Descriptor 

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

func (*MitigateRequest) GetId 

func (m *MitigateRequest) GetId() []string

func (*MitigateRequest) GetPeer 

func (m *MitigateRequest) GetPeer() *NodeRef

func (*MitigateRequest) GetRules 

func (m *MitigateRequest) GetRules() []*PolicyRule

func (*MitigateRequest) GetSrc 

func (m *MitigateRequest) GetSrc() *NodeRef

func (*MitigateRequest) ProtoMessage 

func (*MitigateRequest) ProtoMessage()

func (*MitigateRequest) Reset 

func (m *MitigateRequest) Reset()

func (*MitigateRequest) String 

func (m *MitigateRequest) String() string

func (*MitigateRequest) XXX_DiscardUnknown 

func (m *MitigateRequest) XXX_DiscardUnknown()

func (*MitigateRequest) XXX_Marshal 

func (m *MitigateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MitigateRequest) XXX_Merge 

func (m *MitigateRequest) XXX_Merge(src proto.Message)

func (*MitigateRequest) XXX_Size 

func (m *MitigateRequest) XXX_Size() int

func (*MitigateRequest) XXX_Unmarshal 

func (m *MitigateRequest) XXX_Unmarshal(b []byte) error

type MitigateResponse 

type MitigateResponse struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MitigateResponse) Descriptor 

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

func (*MitigateResponse) GetId 

func (m *MitigateResponse) GetId() string

func (*MitigateResponse) ProtoMessage 

func (*MitigateResponse) ProtoMessage()

func (*MitigateResponse) Reset 

func (m *MitigateResponse) Reset()

func (*MitigateResponse) String 

func (m *MitigateResponse) String() string

func (*MitigateResponse) XXX_DiscardUnknown 

func (m *MitigateResponse) XXX_DiscardUnknown()

func (*MitigateResponse) XXX_Marshal 

func (m *MitigateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MitigateResponse) XXX_Merge 

func (m *MitigateResponse) XXX_Merge(src proto.Message)

func (*MitigateResponse) XXX_Size 

func (m *MitigateResponse) XXX_Size() int

func (*MitigateResponse) XXX_Unmarshal 

func (m *MitigateResponse) XXX_Unmarshal(b []byte) error

type NodeRef 

type NodeRef struct {
	Cluster              string   `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeRef) Descriptor 

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

func (*NodeRef) GetCluster 

func (m *NodeRef) GetCluster() string

func (*NodeRef) GetName 

func (m *NodeRef) GetName() string

func (*NodeRef) ProtoMessage 

func (*NodeRef) ProtoMessage()

func (*NodeRef) Reset 

func (m *NodeRef) Reset()

func (*NodeRef) String 

func (m *NodeRef) String() string

func (*NodeRef) XXX_DiscardUnknown 

func (m *NodeRef) XXX_DiscardUnknown()

func (*NodeRef) XXX_Marshal 

func (m *NodeRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeRef) XXX_Merge 

func (m *NodeRef) XXX_Merge(src proto.Message)

func (*NodeRef) XXX_Size 

func (m *NodeRef) XXX_Size() int

func (*NodeRef) XXX_Unmarshal 

func (m *NodeRef) XXX_Unmarshal(b []byte) error

type Offer 

type Offer struct {
	Id                   string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Node                 *NodeRef               `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	Cost                 int64                  `protobuf:"varint,3,opt,name=cost,proto3" json:"cost,omitempty"`
	Expires              *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires,proto3" json:"expires,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*Offer) Descriptor 

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

func (*Offer) GetCost 

func (m *Offer) GetCost() int64

func (*Offer) GetExpires 

func (m *Offer) GetExpires() *timestamppb.Timestamp

func (*Offer) GetId 

func (m *Offer) GetId() string

func (*Offer) GetNode 

func (m *Offer) GetNode() *NodeRef

func (*Offer) ProtoMessage 

func (*Offer) ProtoMessage()

func (*Offer) Reset 

func (m *Offer) Reset()

func (*Offer) String 

func (m *Offer) String() string

func (*Offer) XXX_DiscardUnknown 

func (m *Offer) XXX_DiscardUnknown()

func (*Offer) XXX_Marshal 

func (m *Offer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Offer) XXX_Merge 

func (m *Offer) XXX_Merge(src proto.Message)

func (*Offer) XXX_Size 

func (m *Offer) XXX_Size() int

func (*Offer) XXX_Unmarshal 

func (m *Offer) XXX_Unmarshal(b []byte) error

type PolicyRule 

type PolicyRule struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PolicyRule) Descriptor 

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

func (*PolicyRule) ProtoMessage 

func (*PolicyRule) ProtoMessage()

func (*PolicyRule) Reset 

func (m *PolicyRule) Reset()

func (*PolicyRule) String 

func (m *PolicyRule) String() string

func (*PolicyRule) XXX_DiscardUnknown 

func (m *PolicyRule) XXX_DiscardUnknown()

func (*PolicyRule) XXX_Marshal 

func (m *PolicyRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PolicyRule) XXX_Merge 

func (m *PolicyRule) XXX_Merge(src proto.Message)

func (*PolicyRule) XXX_Size 

func (m *PolicyRule) XXX_Size() int

func (*PolicyRule) XXX_Unmarshal 

func (m *PolicyRule) XXX_Unmarshal(b []byte) error

type ReleaseRequest 

type ReleaseRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReleaseRequest) Descriptor 

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

func (*ReleaseRequest) GetId 

func (m *ReleaseRequest) GetId() string

func (*ReleaseRequest) ProtoMessage 

func (*ReleaseRequest) ProtoMessage()

func (*ReleaseRequest) Reset 

func (m *ReleaseRequest) Reset()

func (*ReleaseRequest) String 

func (m *ReleaseRequest) String() string

func (*ReleaseRequest) XXX_DiscardUnknown 

func (m *ReleaseRequest) XXX_DiscardUnknown()

func (*ReleaseRequest) XXX_Marshal 

func (m *ReleaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReleaseRequest) XXX_Merge 

func (m *ReleaseRequest) XXX_Merge(src proto.Message)

func (*ReleaseRequest) XXX_Size 

func (m *ReleaseRequest) XXX_Size() int

func (*ReleaseRequest) XXX_Unmarshal 

func (m *ReleaseRequest) XXX_Unmarshal(b []byte) error

type Target 

type Target struct {
	Cluster              string   `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ApiVersion           string   `protobuf:"bytes,3,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	Kind                 string   `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	Name                 string   `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Target) Descriptor 

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

func (*Target) GetApiVersion 

func (m *Target) GetApiVersion() string

func (*Target) GetCluster 

func (m *Target) GetCluster() string

func (*Target) GetKind 

func (m *Target) GetKind() string

func (*Target) GetName 

func (m *Target) GetName() string

func (*Target) GetNamespace 

func (m *Target) GetNamespace() string

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) Reset 

func (m *Target) Reset()

func (*Target) String 

func (m *Target) String() string

func (*Target) XXX_DiscardUnknown 

func (m *Target) XXX_DiscardUnknown()

func (*Target) XXX_Marshal 

func (m *Target) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Target) XXX_Merge 

func (m *Target) XXX_Merge(src proto.Message)

func (*Target) XXX_Size 

func (m *Target) XXX_Size() int

func (*Target) XXX_Unmarshal 

func (m *Target) XXX_Unmarshal(b []byte) error

type UnderlayControllerClient 

type UnderlayControllerClient interface {
	Discover(ctx context.Context, in *DiscoverRequest, opts ...grpc.CallOption) (*DiscoverResponse, error)
	Allocate(ctx context.Context, in *AllocateRequest, opts ...grpc.CallOption) (*AllocateResponse, error)
	Release(ctx context.Context, in *ReleaseRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Mitigate(ctx context.Context, in *MitigateRequest, opts ...grpc.CallOption) (*MitigateResponse, error)
}

UnderlayControllerClient is the client API for UnderlayController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUnderlayControllerClient 

func NewUnderlayControllerClient(cc *grpc.ClientConn) UnderlayControllerClient

type UnderlayControllerServer 

type UnderlayControllerServer interface {
	Discover(context.Context, *DiscoverRequest) (*DiscoverResponse, error)
	Allocate(context.Context, *AllocateRequest) (*AllocateResponse, error)
	Release(context.Context, *ReleaseRequest) (*emptypb.Empty, error)
	Mitigate(context.Context, *MitigateRequest) (*MitigateResponse, error)
}

UnderlayControllerServer is the server API for UnderlayController service.

type UnimplementedUnderlayControllerServer 

type UnimplementedUnderlayControllerServer struct {
}

UnimplementedUnderlayControllerServer can be embedded to have forward compatible implementations.

func (*UnimplementedUnderlayControllerServer) Allocate 

func (*UnimplementedUnderlayControllerServer) Allocate(ctx context.Context, req *AllocateRequest) (*AllocateResponse, error)

func (*UnimplementedUnderlayControllerServer) Discover 

func (*UnimplementedUnderlayControllerServer) Discover(ctx context.Context, req *DiscoverRequest) (*DiscoverResponse, error)

func (*UnimplementedUnderlayControllerServer) Mitigate 

func (*UnimplementedUnderlayControllerServer) Mitigate(ctx context.Context, req *MitigateRequest) (*MitigateResponse, error)

func (*UnimplementedUnderlayControllerServer) Release 

func (*UnimplementedUnderlayControllerServer) Release(ctx context.Context, req *ReleaseRequest) (*emptypb.Empty, error)

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.