types

package
v0.0.0-...-c1d0e24 Latest Latest
Warning

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

 Go to latest Published: Aug 3, 2021 License: BSD-3-Clause Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ForwardMethod_name = map[int32]string{
	0: "UNSET_FORWARD_METHOD",
	1: "ROUTE",
	2: "TUNNEL",
	3: "MASQ",
}
View Source 
var ForwardMethod_value = map[string]int32{
	"UNSET_FORWARD_METHOD": 0,
	"ROUTE":                1,
	"TUNNEL":               2,
	"MASQ":                 3,
}
View Source 
var Protocol_name = map[int32]string{
	0: "UNSET_PROTOCOL",
	1: "TCP",
	2: "UDP",
}
View Source 
var Protocol_value = map[string]int32{
	"UNSET_PROTOCOL": 0,
	"TCP":            1,
	"UDP":            2,
}

Functions

func RegisterMerlinServer 

func RegisterMerlinServer(s *grpc.Server, srv MerlinServer)

Types

type ForwardMethod 

type ForwardMethod int32

ForwardMethod to forward packets to real servers. 

const (
	ForwardMethod_UNSET_FORWARD_METHOD ForwardMethod = 0
	ForwardMethod_ROUTE                ForwardMethod = 1
	ForwardMethod_TUNNEL               ForwardMethod = 2
	ForwardMethod_MASQ                 ForwardMethod = 3
)

func (ForwardMethod) EnumDescriptor 

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

func (ForwardMethod) String 

func (x ForwardMethod) String() string

type ListResponse 

type ListResponse struct {
	Items                []*ListResponse_Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ListResponse) Descriptor 

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

func (*ListResponse) GetItems 

func (m *ListResponse) GetItems() []*ListResponse_Item

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset 

func (m *ListResponse) Reset()

func (*ListResponse) String 

func (m *ListResponse) String() string

func (*ListResponse) XXX_DiscardUnknown 

func (m *ListResponse) XXX_DiscardUnknown()

func (*ListResponse) XXX_Marshal 

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

func (*ListResponse) XXX_Merge 

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

func (*ListResponse) XXX_Size 

func (m *ListResponse) XXX_Size() int

func (*ListResponse) XXX_Unmarshal 

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

type ListResponse_Item 

type ListResponse_Item struct {
	Service              *VirtualService `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Servers              []*RealServer   `protobuf:"bytes,2,rep,name=servers,proto3" json:"servers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ListResponse_Item) Descriptor 

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

func (*ListResponse_Item) GetServers 

func (m *ListResponse_Item) GetServers() []*RealServer

func (*ListResponse_Item) GetService 

func (m *ListResponse_Item) GetService() *VirtualService

func (*ListResponse_Item) ProtoMessage 

func (*ListResponse_Item) ProtoMessage()

func (*ListResponse_Item) Reset 

func (m *ListResponse_Item) Reset()

func (*ListResponse_Item) String 

func (m *ListResponse_Item) String() string

func (*ListResponse_Item) XXX_DiscardUnknown 

func (m *ListResponse_Item) XXX_DiscardUnknown()

func (*ListResponse_Item) XXX_Marshal 

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

func (*ListResponse_Item) XXX_Merge 

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

func (*ListResponse_Item) XXX_Size 

func (m *ListResponse_Item) XXX_Size() int

func (*ListResponse_Item) XXX_Unmarshal 

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

type MerlinClient 

type MerlinClient interface {
	CreateService(ctx context.Context, in *VirtualService, opts ...grpc.CallOption) (*empty.Empty, error)
	UpdateService(ctx context.Context, in *VirtualService, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteService(ctx context.Context, in *wrappers.StringValue, opts ...grpc.CallOption) (*empty.Empty, error)
	CreateServer(ctx context.Context, in *RealServer, opts ...grpc.CallOption) (*empty.Empty, error)
	UpdateServer(ctx context.Context, in *RealServer, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteServer(ctx context.Context, in *RealServer, opts ...grpc.CallOption) (*empty.Empty, error)
	List(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListResponse, error)
}

MerlinClient is the client API for Merlin service.

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

func NewMerlinClient 

func NewMerlinClient(cc *grpc.ClientConn) MerlinClient

type MerlinServer 

type MerlinServer interface {
	CreateService(context.Context, *VirtualService) (*empty.Empty, error)
	UpdateService(context.Context, *VirtualService) (*empty.Empty, error)
	DeleteService(context.Context, *wrappers.StringValue) (*empty.Empty, error)
	CreateServer(context.Context, *RealServer) (*empty.Empty, error)
	UpdateServer(context.Context, *RealServer) (*empty.Empty, error)
	DeleteServer(context.Context, *RealServer) (*empty.Empty, error)
	List(context.Context, *empty.Empty) (*ListResponse, error)
}

MerlinServer is the server API for Merlin service.

type Protocol 

type Protocol int32
const (
	Protocol_UNSET_PROTOCOL Protocol = 0
	Protocol_TCP            Protocol = 1
	Protocol_UDP            Protocol = 2
)

func (Protocol) EnumDescriptor 

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

func (Protocol) String 

func (x Protocol) String() string

type RealServer 

type RealServer struct {
	// ServiceID is the id of the virtual service to associate this real server with.
	// Field may be blank if from IPVS.
	ServiceID string `protobuf:"bytes,1,opt,name=serviceID,proto3" json:"serviceID,omitempty"`
	// Key is the identifying part in IPVS.
	Key *RealServer_Key `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Config is the configurable part in IPVS.
	Config *RealServer_Config `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// HealthCheck is the check done by merlin against the associated real server.
	HealthCheck          *RealServer_HealthCheck `protobuf:"bytes,4,opt,name=health_check,json=healthCheck,proto3" json:"health_check,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*RealServer) Descriptor 

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

func (*RealServer) GetConfig 

func (m *RealServer) GetConfig() *RealServer_Config

func (*RealServer) GetHealthCheck 

func (m *RealServer) GetHealthCheck() *RealServer_HealthCheck

func (*RealServer) GetKey 

func (m *RealServer) GetKey() *RealServer_Key

func (*RealServer) GetServiceID 

func (m *RealServer) GetServiceID() string

func (*RealServer) PrettyString 

func (r *RealServer) PrettyString() string

func (*RealServer) ProtoMessage 

func (*RealServer) ProtoMessage()

func (*RealServer) Reset 

func (m *RealServer) Reset()

func (*RealServer) String 

func (m *RealServer) String() string

func (*RealServer) XXX_DiscardUnknown 

func (m *RealServer) XXX_DiscardUnknown()

func (*RealServer) XXX_Marshal 

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

func (*RealServer) XXX_Merge 

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

func (*RealServer) XXX_Size 

func (m *RealServer) XXX_Size() int

func (*RealServer) XXX_Unmarshal 

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

type RealServer_Config 

type RealServer_Config struct {
	Weight               *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=weight,proto3" json:"weight,omitempty"`
	Forward              ForwardMethod         `protobuf:"varint,2,opt,name=forward,proto3,enum=types.ForwardMethod" json:"forward,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*RealServer_Config) Descriptor 

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

func (*RealServer_Config) GetForward 

func (m *RealServer_Config) GetForward() ForwardMethod

func (*RealServer_Config) GetWeight 

func (m *RealServer_Config) GetWeight() *wrappers.UInt32Value

func (*RealServer_Config) PrettyString 

func (c *RealServer_Config) PrettyString() string

func (*RealServer_Config) ProtoMessage 

func (*RealServer_Config) ProtoMessage()

func (*RealServer_Config) Reset 

func (m *RealServer_Config) Reset()

func (*RealServer_Config) String 

func (m *RealServer_Config) String() string

func (*RealServer_Config) XXX_DiscardUnknown 

func (m *RealServer_Config) XXX_DiscardUnknown()

func (*RealServer_Config) XXX_Marshal 

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

func (*RealServer_Config) XXX_Merge 

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

func (*RealServer_Config) XXX_Size 

func (m *RealServer_Config) XXX_Size() int

func (*RealServer_Config) XXX_Unmarshal 

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

type RealServer_HealthCheck 

type RealServer_HealthCheck struct {
	// Endpoint should be a valid url, expected format is <scheme>://:<port>/<path>, e.g. http://:80/health.
	// Set to an empty string to disable health check.
	Endpoint             *wrappers.StringValue `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Period               *duration.Duration    `protobuf:"bytes,2,opt,name=period,proto3" json:"period,omitempty"`
	Timeout              *duration.Duration    `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	UpThreshold          uint32                `protobuf:"varint,4,opt,name=up_threshold,json=upThreshold,proto3" json:"up_threshold,omitempty"`
	DownThreshold        uint32                `protobuf:"varint,5,opt,name=down_threshold,json=downThreshold,proto3" json:"down_threshold,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*RealServer_HealthCheck) Descriptor 

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

func (*RealServer_HealthCheck) GetDownThreshold 

func (m *RealServer_HealthCheck) GetDownThreshold() uint32

func (*RealServer_HealthCheck) GetEndpoint 

func (m *RealServer_HealthCheck) GetEndpoint() *wrappers.StringValue

func (*RealServer_HealthCheck) GetPeriod 

func (m *RealServer_HealthCheck) GetPeriod() *duration.Duration

func (*RealServer_HealthCheck) GetTimeout 

func (m *RealServer_HealthCheck) GetTimeout() *duration.Duration

func (*RealServer_HealthCheck) GetUpThreshold 

func (m *RealServer_HealthCheck) GetUpThreshold() uint32

func (*RealServer_HealthCheck) PrettyString 

func (h *RealServer_HealthCheck) PrettyString() string

func (*RealServer_HealthCheck) ProtoMessage 

func (*RealServer_HealthCheck) ProtoMessage()

func (*RealServer_HealthCheck) Reset 

func (m *RealServer_HealthCheck) Reset()

func (*RealServer_HealthCheck) String 

func (m *RealServer_HealthCheck) String() string

func (*RealServer_HealthCheck) XXX_DiscardUnknown 

func (m *RealServer_HealthCheck) XXX_DiscardUnknown()

func (*RealServer_HealthCheck) XXX_Marshal 

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

func (*RealServer_HealthCheck) XXX_Merge 

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

func (*RealServer_HealthCheck) XXX_Size 

func (m *RealServer_HealthCheck) XXX_Size() int

func (*RealServer_HealthCheck) XXX_Unmarshal 

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

type RealServer_Key 

type RealServer_Key struct {
	Ip                   string   `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port                 uint32   `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RealServer_Key) Descriptor 

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

func (*RealServer_Key) GetIp 

func (m *RealServer_Key) GetIp() string

func (*RealServer_Key) GetPort 

func (m *RealServer_Key) GetPort() uint32

func (*RealServer_Key) PrettyString 

func (k *RealServer_Key) PrettyString() string

func (*RealServer_Key) ProtoMessage 

func (*RealServer_Key) ProtoMessage()

func (*RealServer_Key) Reset 

func (m *RealServer_Key) Reset()

func (*RealServer_Key) String 

func (m *RealServer_Key) String() string

func (*RealServer_Key) XXX_DiscardUnknown 

func (m *RealServer_Key) XXX_DiscardUnknown()

func (*RealServer_Key) XXX_Marshal 

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

func (*RealServer_Key) XXX_Merge 

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

func (*RealServer_Key) XXX_Size 

func (m *RealServer_Key) XXX_Size() int

func (*RealServer_Key) XXX_Unmarshal 

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

type UnimplementedMerlinServer 

type UnimplementedMerlinServer struct {
}

UnimplementedMerlinServer can be embedded to have forward compatible implementations.

func (*UnimplementedMerlinServer) CreateServer 

func (*UnimplementedMerlinServer) CreateServer(ctx context.Context, req *RealServer) (*empty.Empty, error)

func (*UnimplementedMerlinServer) CreateService 

func (*UnimplementedMerlinServer) CreateService(ctx context.Context, req *VirtualService) (*empty.Empty, error)

func (*UnimplementedMerlinServer) DeleteServer 

func (*UnimplementedMerlinServer) DeleteServer(ctx context.Context, req *RealServer) (*empty.Empty, error)

func (*UnimplementedMerlinServer) DeleteService 

func (*UnimplementedMerlinServer) DeleteService(ctx context.Context, req *wrappers.StringValue) (*empty.Empty, error)

func (*UnimplementedMerlinServer) List 

func (*UnimplementedMerlinServer) List(ctx context.Context, req *empty.Empty) (*ListResponse, error)

func (*UnimplementedMerlinServer) UpdateServer 

func (*UnimplementedMerlinServer) UpdateServer(ctx context.Context, req *RealServer) (*empty.Empty, error)

func (*UnimplementedMerlinServer) UpdateService 

func (*UnimplementedMerlinServer) UpdateService(ctx context.Context, req *VirtualService) (*empty.Empty, error)

type VirtualService 

type VirtualService struct {
	// ID is a unique identifier of this virtual service to associate it with real servers.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Key is the identifying part in IPVS.
	Key *VirtualService_Key `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Config is the configurable part in IPVS.
	Config               *VirtualService_Config `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*VirtualService) Descriptor 

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

func (*VirtualService) GetConfig 

func (m *VirtualService) GetConfig() *VirtualService_Config

func (*VirtualService) GetId 

func (m *VirtualService) GetId() string

func (*VirtualService) GetKey 

func (m *VirtualService) GetKey() *VirtualService_Key

func (*VirtualService) PrettyString 

func (s *VirtualService) PrettyString() string

func (*VirtualService) ProtoMessage 

func (*VirtualService) ProtoMessage()

func (*VirtualService) Reset 

func (m *VirtualService) Reset()

func (*VirtualService) SortFlags 

func (s *VirtualService) SortFlags()

SortFlags of the virtual service in place.

func (*VirtualService) String 

func (m *VirtualService) String() string

func (*VirtualService) XXX_DiscardUnknown 

func (m *VirtualService) XXX_DiscardUnknown()

func (*VirtualService) XXX_Marshal 

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

func (*VirtualService) XXX_Merge 

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

func (*VirtualService) XXX_Size 

func (m *VirtualService) XXX_Size() int

func (*VirtualService) XXX_Unmarshal 

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

type VirtualService_Config 

type VirtualService_Config struct {
	Scheduler            string   `protobuf:"bytes,1,opt,name=scheduler,proto3" json:"scheduler,omitempty"`
	Flags                []string `protobuf:"bytes,2,rep,name=flags,proto3" json:"flags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VirtualService_Config) Descriptor 

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

func (*VirtualService_Config) GetFlags 

func (m *VirtualService_Config) GetFlags() []string

func (*VirtualService_Config) GetScheduler 

func (m *VirtualService_Config) GetScheduler() string

func (*VirtualService_Config) PrettyString 

func (c *VirtualService_Config) PrettyString() string

func (*VirtualService_Config) ProtoMessage 

func (*VirtualService_Config) ProtoMessage()

func (*VirtualService_Config) Reset 

func (m *VirtualService_Config) Reset()

func (*VirtualService_Config) String 

func (m *VirtualService_Config) String() string

func (*VirtualService_Config) XXX_DiscardUnknown 

func (m *VirtualService_Config) XXX_DiscardUnknown()

func (*VirtualService_Config) XXX_Marshal 

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

func (*VirtualService_Config) XXX_Merge 

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

func (*VirtualService_Config) XXX_Size 

func (m *VirtualService_Config) XXX_Size() int

func (*VirtualService_Config) XXX_Unmarshal 

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

type VirtualService_Key 

type VirtualService_Key struct {
	Ip                   string   `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port                 uint32   `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Protocol             Protocol `protobuf:"varint,3,opt,name=protocol,proto3,enum=types.Protocol" json:"protocol,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VirtualService_Key) Descriptor 

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

func (*VirtualService_Key) GetIp 

func (m *VirtualService_Key) GetIp() string

func (*VirtualService_Key) GetPort 

func (m *VirtualService_Key) GetPort() uint32

func (*VirtualService_Key) GetProtocol 

func (m *VirtualService_Key) GetProtocol() Protocol

func (*VirtualService_Key) PrettyString 

func (k *VirtualService_Key) PrettyString() string

func (*VirtualService_Key) ProtoMessage 

func (*VirtualService_Key) ProtoMessage()

func (*VirtualService_Key) Reset 

func (m *VirtualService_Key) Reset()

func (*VirtualService_Key) String 

func (m *VirtualService_Key) String() string

func (*VirtualService_Key) XXX_DiscardUnknown 

func (m *VirtualService_Key) XXX_DiscardUnknown()

func (*VirtualService_Key) XXX_Marshal 

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

func (*VirtualService_Key) XXX_Merge 

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

func (*VirtualService_Key) XXX_Size 

func (m *VirtualService_Key) XXX_Size() int

func (*VirtualService_Key) XXX_Unmarshal 

func (m *VirtualService_Key) XXX_Unmarshal(b []byte) 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.