Documentation
¶
Index ¶
- Variables
- func RegisterControllerServer(s grpc.ServiceRegistrar, srv ControllerServer)
- func RegisterIdentityServer(s grpc.ServiceRegistrar, srv IdentityServer)
- type ControllerClient
- type ControllerGetGSLBRequest
- func (*ControllerGetGSLBRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ControllerGetGSLBRequest) GetGSLBId() string
- func (*ControllerGetGSLBRequest) ProtoMessage()
- func (x *ControllerGetGSLBRequest) ProtoReflect() protoreflect.Message
- func (x *ControllerGetGSLBRequest) Reset()
- func (x *ControllerGetGSLBRequest) String() string
- type ControllerGetGSLBResponse
- func (*ControllerGetGSLBResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ControllerGetGSLBResponse) GetGSLB() string
- func (*ControllerGetGSLBResponse) ProtoMessage()
- func (x *ControllerGetGSLBResponse) ProtoReflect() protoreflect.Message
- func (x *ControllerGetGSLBResponse) Reset()
- func (x *ControllerGetGSLBResponse) String() string
- type ControllerServer
- type CreateGSLBRequest
- func (*CreateGSLBRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateGSLBRequest) GetHost() string
- func (x *CreateGSLBRequest) GetName() string
- func (x *CreateGSLBRequest) GetParameters() map[string]string
- func (x *CreateGSLBRequest) GetServiceName() string
- func (x *CreateGSLBRequest) GetWeight() int32
- func (*CreateGSLBRequest) ProtoMessage()
- func (x *CreateGSLBRequest) ProtoReflect() protoreflect.Message
- func (x *CreateGSLBRequest) Reset()
- func (x *CreateGSLBRequest) String() string
- type CreateGSLBResponse
- type DeleteGSLBRequest
- type DeleteGSLBResponse
- type GetPluginCapabilitiesRequest
- func (*GetPluginCapabilitiesRequest) Descriptor() ([]byte, []int)deprecated
- func (*GetPluginCapabilitiesRequest) ProtoMessage()
- func (x *GetPluginCapabilitiesRequest) ProtoReflect() protoreflect.Message
- func (x *GetPluginCapabilitiesRequest) Reset()
- func (x *GetPluginCapabilitiesRequest) String() string
- type GetPluginCapabilitiesResponse
- func (*GetPluginCapabilitiesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetPluginCapabilitiesResponse) GetCapabilities() []*PluginCapability
- func (*GetPluginCapabilitiesResponse) ProtoMessage()
- func (x *GetPluginCapabilitiesResponse) ProtoReflect() protoreflect.Message
- func (x *GetPluginCapabilitiesResponse) Reset()
- func (x *GetPluginCapabilitiesResponse) String() string
- type GetPluginInfoRequest
- type GetPluginInfoResponse
- func (*GetPluginInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetPluginInfoResponse) GetManifest() map[string]string
- func (x *GetPluginInfoResponse) GetName() string
- func (x *GetPluginInfoResponse) GetVendorVersion() string
- func (*GetPluginInfoResponse) ProtoMessage()
- func (x *GetPluginInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetPluginInfoResponse) Reset()
- func (x *GetPluginInfoResponse) String() string
- type Gslb
- type IdentityClient
- type IdentityServer
- type PluginCapability
- func (*PluginCapability) Descriptor() ([]byte, []int)deprecated
- func (x *PluginCapability) GetHealthCheck() *PluginCapability_HealthCheck
- func (x *PluginCapability) GetService() *PluginCapability_Service
- func (m *PluginCapability) GetType() isPluginCapability_Type
- func (*PluginCapability) ProtoMessage()
- func (x *PluginCapability) ProtoReflect() protoreflect.Message
- func (x *PluginCapability) Reset()
- func (x *PluginCapability) String() string
- type PluginCapability_HealthCheck
- func (*PluginCapability_HealthCheck) Descriptor() ([]byte, []int)deprecated
- func (x *PluginCapability_HealthCheck) GetType() PluginCapability_HealthCheck_Type
- func (*PluginCapability_HealthCheck) ProtoMessage()
- func (x *PluginCapability_HealthCheck) ProtoReflect() protoreflect.Message
- func (x *PluginCapability_HealthCheck) Reset()
- func (x *PluginCapability_HealthCheck) String() string
- type PluginCapability_HealthCheck_
- type PluginCapability_HealthCheck_Type
- func (PluginCapability_HealthCheck_Type) Descriptor() protoreflect.EnumDescriptor
- func (x PluginCapability_HealthCheck_Type) Enum() *PluginCapability_HealthCheck_Type
- func (PluginCapability_HealthCheck_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x PluginCapability_HealthCheck_Type) Number() protoreflect.EnumNumber
- func (x PluginCapability_HealthCheck_Type) String() string
- func (PluginCapability_HealthCheck_Type) Type() protoreflect.EnumType
- type PluginCapability_Service
- func (*PluginCapability_Service) Descriptor() ([]byte, []int)deprecated
- func (x *PluginCapability_Service) GetType() PluginCapability_Service_Type
- func (*PluginCapability_Service) ProtoMessage()
- func (x *PluginCapability_Service) ProtoReflect() protoreflect.Message
- func (x *PluginCapability_Service) Reset()
- func (x *PluginCapability_Service) String() string
- type PluginCapability_Service_
- type PluginCapability_Service_Type
- func (PluginCapability_Service_Type) Descriptor() protoreflect.EnumDescriptor
- func (x PluginCapability_Service_Type) Enum() *PluginCapability_Service_Type
- func (PluginCapability_Service_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x PluginCapability_Service_Type) Number() protoreflect.EnumNumber
- func (x PluginCapability_Service_Type) String() string
- func (PluginCapability_Service_Type) Type() protoreflect.EnumType
- type ProbeRequest
- type ProbeResponse
- type UnimplementedControllerServer
- func (UnimplementedControllerServer) ControllerGetGSLB(context.Context, *ControllerGetGSLBRequest) (*ControllerGetGSLBResponse, error)
- func (UnimplementedControllerServer) CreateGSLB(context.Context, *CreateGSLBRequest) (*CreateGSLBResponse, error)
- func (UnimplementedControllerServer) DeleteGSLB(context.Context, *DeleteGSLBRequest) (*DeleteGSLBResponse, error)
- type UnimplementedIdentityServer
- func (UnimplementedIdentityServer) GetPluginCapabilities(context.Context, *GetPluginCapabilitiesRequest) (*GetPluginCapabilitiesResponse, error)
- func (UnimplementedIdentityServer) GetPluginInfo(context.Context, *GetPluginInfoRequest) (*GetPluginInfoResponse, error)
- func (UnimplementedIdentityServer) Probe(context.Context, *ProbeRequest) (*ProbeResponse, error)
- type UnsafeControllerServer
- type UnsafeIdentityServer
Constants ¶
This section is empty.
Variables ¶
var ( PluginCapability_Service_Type_name = map[int32]string{ 0: "UNKNOWN", 1: "CONTROLLER_SERVICE", } PluginCapability_Service_Type_value = map[string]int32{ "UNKNOWN": 0, "CONTROLLER_SERVICE": 1, } )
Enum value maps for PluginCapability_Service_Type.
var ( PluginCapability_HealthCheck_Type_name = map[int32]string{ 0: "UNKNOWN", 1: "HTTP", 2: "TCP", } PluginCapability_HealthCheck_Type_value = map[string]int32{ "UNKNOWN": 0, "HTTP": 1, "TCP": 2, } )
Enum value maps for PluginCapability_HealthCheck_Type.
var Controller_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gslbi.v1.Controller", HandlerType: (*ControllerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateGSLB", Handler: _Controller_CreateGSLB_Handler, }, { MethodName: "DeleteGSLB", Handler: _Controller_DeleteGSLB_Handler, }, { MethodName: "ControllerGetGSLB", Handler: _Controller_ControllerGetGSLB_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "gslbi/gslbi.proto", }
Controller_ServiceDesc is the grpc.ServiceDesc for Controller service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_gslbi_gslbi_proto protoreflect.FileDescriptor
var Identity_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gslbi.v1.Identity", HandlerType: (*IdentityServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetPluginInfo", Handler: _Identity_GetPluginInfo_Handler, }, { MethodName: "GetPluginCapabilities", Handler: _Identity_GetPluginCapabilities_Handler, }, { MethodName: "Probe", Handler: _Identity_Probe_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "gslbi/gslbi.proto", }
Identity_ServiceDesc is the grpc.ServiceDesc for Identity service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterControllerServer ¶
func RegisterControllerServer(s grpc.ServiceRegistrar, srv ControllerServer)
func RegisterIdentityServer ¶
func RegisterIdentityServer(s grpc.ServiceRegistrar, srv IdentityServer)
Types ¶
type ControllerClient ¶
type ControllerClient interface { CreateGSLB(ctx context.Context, in *CreateGSLBRequest, opts ...grpc.CallOption) (*CreateGSLBResponse, error) DeleteGSLB(ctx context.Context, in *DeleteGSLBRequest, opts ...grpc.CallOption) (*DeleteGSLBResponse, error) ControllerGetGSLB(ctx context.Context, in *ControllerGetGSLBRequest, opts ...grpc.CallOption) (*ControllerGetGSLBResponse, error) }
ControllerClient is the client API for Controller service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewControllerClient ¶
func NewControllerClient(cc grpc.ClientConnInterface) ControllerClient
type ControllerGetGSLBRequest ¶
type ControllerGetGSLBRequest struct { // The ID of the GSLB to fetch current GSLB information for. // This field is REQUIRED. GSLBId string `protobuf:"bytes,1,opt,name=GSLB_id,json=GSLBId,proto3" json:"GSLB_id,omitempty"` // contains filtered or unexported fields }
func (*ControllerGetGSLBRequest) Descriptor
deprecated
func (*ControllerGetGSLBRequest) Descriptor() ([]byte, []int)
Deprecated: Use ControllerGetGSLBRequest.ProtoReflect.Descriptor instead.
func (*ControllerGetGSLBRequest) GetGSLBId ¶
func (x *ControllerGetGSLBRequest) GetGSLBId() string
func (*ControllerGetGSLBRequest) ProtoMessage ¶
func (*ControllerGetGSLBRequest) ProtoMessage()
func (*ControllerGetGSLBRequest) ProtoReflect ¶
func (x *ControllerGetGSLBRequest) ProtoReflect() protoreflect.Message
func (*ControllerGetGSLBRequest) Reset ¶
func (x *ControllerGetGSLBRequest) Reset()
func (*ControllerGetGSLBRequest) String ¶
func (x *ControllerGetGSLBRequest) String() string
type ControllerGetGSLBResponse ¶
type ControllerGetGSLBResponse struct { // This field is REQUIRED GSLB string `protobuf:"bytes,1,opt,name=GSLB,proto3" json:"GSLB,omitempty"` // contains filtered or unexported fields }
func (*ControllerGetGSLBResponse) Descriptor
deprecated
func (*ControllerGetGSLBResponse) Descriptor() ([]byte, []int)
Deprecated: Use ControllerGetGSLBResponse.ProtoReflect.Descriptor instead.
func (*ControllerGetGSLBResponse) GetGSLB ¶
func (x *ControllerGetGSLBResponse) GetGSLB() string
func (*ControllerGetGSLBResponse) ProtoMessage ¶
func (*ControllerGetGSLBResponse) ProtoMessage()
func (*ControllerGetGSLBResponse) ProtoReflect ¶
func (x *ControllerGetGSLBResponse) ProtoReflect() protoreflect.Message
func (*ControllerGetGSLBResponse) Reset ¶
func (x *ControllerGetGSLBResponse) Reset()
func (*ControllerGetGSLBResponse) String ¶
func (x *ControllerGetGSLBResponse) String() string
type ControllerServer ¶
type ControllerServer interface { CreateGSLB(context.Context, *CreateGSLBRequest) (*CreateGSLBResponse, error) DeleteGSLB(context.Context, *DeleteGSLBRequest) (*DeleteGSLBResponse, error) ControllerGetGSLB(context.Context, *ControllerGetGSLBRequest) (*ControllerGetGSLBResponse, error) // contains filtered or unexported methods }
ControllerServer is the server API for Controller service. All implementations must embed UnimplementedControllerServer for forward compatibility
type CreateGSLBRequest ¶
type CreateGSLBRequest struct { // The name for the gslb. // This field is REQUIRED. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The name for the service. // This field is REQUIRED. ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // The host address of backend service. Can be IPv4 or DNS Domain // This field is REQUIRED. Host string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"` // Weight Weight int32 `protobuf:"varint,4,opt,name=weight,proto3" json:"weight,omitempty"` // Plugin specific parameters passed in as opaque key-value pairs. // This field is OPTIONAL. The Plugin is responsible for parsing and // validating these parameters. COs will treat these as opaque. Parameters map[string]string `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CreateGSLBRequest) Descriptor
deprecated
func (*CreateGSLBRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateGSLBRequest.ProtoReflect.Descriptor instead.
func (*CreateGSLBRequest) GetHost ¶
func (x *CreateGSLBRequest) GetHost() string
func (*CreateGSLBRequest) GetName ¶
func (x *CreateGSLBRequest) GetName() string
func (*CreateGSLBRequest) GetParameters ¶
func (x *CreateGSLBRequest) GetParameters() map[string]string
func (*CreateGSLBRequest) GetServiceName ¶
func (x *CreateGSLBRequest) GetServiceName() string
func (*CreateGSLBRequest) GetWeight ¶
func (x *CreateGSLBRequest) GetWeight() int32
func (*CreateGSLBRequest) ProtoMessage ¶
func (*CreateGSLBRequest) ProtoMessage()
func (*CreateGSLBRequest) ProtoReflect ¶
func (x *CreateGSLBRequest) ProtoReflect() protoreflect.Message
func (*CreateGSLBRequest) Reset ¶
func (x *CreateGSLBRequest) Reset()
func (*CreateGSLBRequest) String ¶
func (x *CreateGSLBRequest) String() string
type CreateGSLBResponse ¶
type CreateGSLBResponse struct { // gslb ID // This field is REQUIRED. Gslb *Gslb `protobuf:"bytes,1,opt,name=gslb,proto3" json:"gslb,omitempty"` // contains filtered or unexported fields }
func (*CreateGSLBResponse) Descriptor
deprecated
func (*CreateGSLBResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateGSLBResponse.ProtoReflect.Descriptor instead.
func (*CreateGSLBResponse) GetGslb ¶
func (x *CreateGSLBResponse) GetGslb() *Gslb
func (*CreateGSLBResponse) ProtoMessage ¶
func (*CreateGSLBResponse) ProtoMessage()
func (*CreateGSLBResponse) ProtoReflect ¶
func (x *CreateGSLBResponse) ProtoReflect() protoreflect.Message
func (*CreateGSLBResponse) Reset ¶
func (x *CreateGSLBResponse) Reset()
func (*CreateGSLBResponse) String ¶
func (x *CreateGSLBResponse) String() string
type DeleteGSLBRequest ¶
type DeleteGSLBRequest struct { // The ID of the GSLB to be created. // This field is REQUIRED. GslbId string `protobuf:"bytes,1,opt,name=gslb_id,json=gslbId,proto3" json:"gslb_id,omitempty"` // contains filtered or unexported fields }
func (*DeleteGSLBRequest) Descriptor
deprecated
func (*DeleteGSLBRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteGSLBRequest.ProtoReflect.Descriptor instead.
func (*DeleteGSLBRequest) GetGslbId ¶
func (x *DeleteGSLBRequest) GetGslbId() string
func (*DeleteGSLBRequest) ProtoMessage ¶
func (*DeleteGSLBRequest) ProtoMessage()
func (*DeleteGSLBRequest) ProtoReflect ¶
func (x *DeleteGSLBRequest) ProtoReflect() protoreflect.Message
func (*DeleteGSLBRequest) Reset ¶
func (x *DeleteGSLBRequest) Reset()
func (*DeleteGSLBRequest) String ¶
func (x *DeleteGSLBRequest) String() string
type DeleteGSLBResponse ¶
type DeleteGSLBResponse struct {
// contains filtered or unexported fields
}
func (*DeleteGSLBResponse) Descriptor
deprecated
func (*DeleteGSLBResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteGSLBResponse.ProtoReflect.Descriptor instead.
func (*DeleteGSLBResponse) ProtoMessage ¶
func (*DeleteGSLBResponse) ProtoMessage()
func (*DeleteGSLBResponse) ProtoReflect ¶
func (x *DeleteGSLBResponse) ProtoReflect() protoreflect.Message
func (*DeleteGSLBResponse) Reset ¶
func (x *DeleteGSLBResponse) Reset()
func (*DeleteGSLBResponse) String ¶
func (x *DeleteGSLBResponse) String() string
type GetPluginCapabilitiesRequest ¶
type GetPluginCapabilitiesRequest struct {
// contains filtered or unexported fields
}
func (*GetPluginCapabilitiesRequest) Descriptor
deprecated
func (*GetPluginCapabilitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPluginCapabilitiesRequest.ProtoReflect.Descriptor instead.
func (*GetPluginCapabilitiesRequest) ProtoMessage ¶
func (*GetPluginCapabilitiesRequest) ProtoMessage()
func (*GetPluginCapabilitiesRequest) ProtoReflect ¶
func (x *GetPluginCapabilitiesRequest) ProtoReflect() protoreflect.Message
func (*GetPluginCapabilitiesRequest) Reset ¶
func (x *GetPluginCapabilitiesRequest) Reset()
func (*GetPluginCapabilitiesRequest) String ¶
func (x *GetPluginCapabilitiesRequest) String() string
type GetPluginCapabilitiesResponse ¶
type GetPluginCapabilitiesResponse struct { // All the capabilities that the controller service supports. This // field is OPTIONAL. Capabilities []*PluginCapability `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"` // contains filtered or unexported fields }
func (*GetPluginCapabilitiesResponse) Descriptor
deprecated
func (*GetPluginCapabilitiesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetPluginCapabilitiesResponse.ProtoReflect.Descriptor instead.
func (*GetPluginCapabilitiesResponse) GetCapabilities ¶
func (x *GetPluginCapabilitiesResponse) GetCapabilities() []*PluginCapability
func (*GetPluginCapabilitiesResponse) ProtoMessage ¶
func (*GetPluginCapabilitiesResponse) ProtoMessage()
func (*GetPluginCapabilitiesResponse) ProtoReflect ¶
func (x *GetPluginCapabilitiesResponse) ProtoReflect() protoreflect.Message
func (*GetPluginCapabilitiesResponse) Reset ¶
func (x *GetPluginCapabilitiesResponse) Reset()
func (*GetPluginCapabilitiesResponse) String ¶
func (x *GetPluginCapabilitiesResponse) String() string
type GetPluginInfoRequest ¶
type GetPluginInfoRequest struct {
// contains filtered or unexported fields
}
func (*GetPluginInfoRequest) Descriptor
deprecated
func (*GetPluginInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPluginInfoRequest.ProtoReflect.Descriptor instead.
func (*GetPluginInfoRequest) ProtoMessage ¶
func (*GetPluginInfoRequest) ProtoMessage()
func (*GetPluginInfoRequest) ProtoReflect ¶
func (x *GetPluginInfoRequest) ProtoReflect() protoreflect.Message
func (*GetPluginInfoRequest) Reset ¶
func (x *GetPluginInfoRequest) Reset()
func (*GetPluginInfoRequest) String ¶
func (x *GetPluginInfoRequest) String() string
type GetPluginInfoResponse ¶
type GetPluginInfoResponse struct { // This field is REQUIRED. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // This field is REQUIRED. Value of this field is opaque to the CO. VendorVersion string `protobuf:"bytes,2,opt,name=vendor_version,json=vendorVersion,proto3" json:"vendor_version,omitempty"` // This field is OPTIONAL. Values are opaque to the CO. Manifest map[string]string `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetPluginInfoResponse) Descriptor
deprecated
func (*GetPluginInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetPluginInfoResponse.ProtoReflect.Descriptor instead.
func (*GetPluginInfoResponse) GetManifest ¶
func (x *GetPluginInfoResponse) GetManifest() map[string]string
func (*GetPluginInfoResponse) GetName ¶
func (x *GetPluginInfoResponse) GetName() string
func (*GetPluginInfoResponse) GetVendorVersion ¶
func (x *GetPluginInfoResponse) GetVendorVersion() string
func (*GetPluginInfoResponse) ProtoMessage ¶
func (*GetPluginInfoResponse) ProtoMessage()
func (*GetPluginInfoResponse) ProtoReflect ¶
func (x *GetPluginInfoResponse) ProtoReflect() protoreflect.Message
func (*GetPluginInfoResponse) Reset ¶
func (x *GetPluginInfoResponse) Reset()
func (*GetPluginInfoResponse) String ¶
func (x *GetPluginInfoResponse) String() string
type Gslb ¶
type Gslb struct { // The identifier for this gslb, generated by the plugin. // This field is REQUIRED. // This field MUST contain enough information to uniquely identify // this specific volume vs all other volumes supported by this plugin. // This field SHALL be used by the CO in subsequent calls to refer to // this volume. // The SP is NOT responsible for global uniqueness of gslb_id across // multiple SPs. GslbId string `protobuf:"bytes,2,opt,name=gslb_id,json=gslbId,proto3" json:"gslb_id,omitempty"` // contains filtered or unexported fields }
Information about a specific gslb.
func (*Gslb) Descriptor
deprecated
func (*Gslb) ProtoMessage ¶
func (*Gslb) ProtoMessage()
func (*Gslb) ProtoReflect ¶
func (x *Gslb) ProtoReflect() protoreflect.Message
type IdentityClient ¶
type IdentityClient interface { GetPluginInfo(ctx context.Context, in *GetPluginInfoRequest, opts ...grpc.CallOption) (*GetPluginInfoResponse, error) GetPluginCapabilities(ctx context.Context, in *GetPluginCapabilitiesRequest, opts ...grpc.CallOption) (*GetPluginCapabilitiesResponse, error) Probe(ctx context.Context, in *ProbeRequest, opts ...grpc.CallOption) (*ProbeResponse, error) }
IdentityClient is the client API for Identity service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewIdentityClient ¶
func NewIdentityClient(cc grpc.ClientConnInterface) IdentityClient
type IdentityServer ¶
type IdentityServer interface { GetPluginInfo(context.Context, *GetPluginInfoRequest) (*GetPluginInfoResponse, error) GetPluginCapabilities(context.Context, *GetPluginCapabilitiesRequest) (*GetPluginCapabilitiesResponse, error) Probe(context.Context, *ProbeRequest) (*ProbeResponse, error) // contains filtered or unexported methods }
IdentityServer is the server API for Identity service. All implementations must embed UnimplementedIdentityServer for forward compatibility
type PluginCapability ¶
type PluginCapability struct { // Types that are assignable to Type: // *PluginCapability_Service_ // *PluginCapability_HealthCheck_ Type isPluginCapability_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
Specifies a capability of the plugin.
func (*PluginCapability) Descriptor
deprecated
func (*PluginCapability) Descriptor() ([]byte, []int)
Deprecated: Use PluginCapability.ProtoReflect.Descriptor instead.
func (*PluginCapability) GetHealthCheck ¶
func (x *PluginCapability) GetHealthCheck() *PluginCapability_HealthCheck
func (*PluginCapability) GetService ¶
func (x *PluginCapability) GetService() *PluginCapability_Service
func (*PluginCapability) GetType ¶
func (m *PluginCapability) GetType() isPluginCapability_Type
func (*PluginCapability) ProtoMessage ¶
func (*PluginCapability) ProtoMessage()
func (*PluginCapability) ProtoReflect ¶
func (x *PluginCapability) ProtoReflect() protoreflect.Message
func (*PluginCapability) Reset ¶
func (x *PluginCapability) Reset()
func (*PluginCapability) String ¶
func (x *PluginCapability) String() string
type PluginCapability_HealthCheck ¶
type PluginCapability_HealthCheck struct { Type PluginCapability_HealthCheck_Type `protobuf:"varint,1,opt,name=type,proto3,enum=gslbi.v1.PluginCapability_HealthCheck_Type" json:"type,omitempty"` // contains filtered or unexported fields }
func (*PluginCapability_HealthCheck) Descriptor
deprecated
func (*PluginCapability_HealthCheck) Descriptor() ([]byte, []int)
Deprecated: Use PluginCapability_HealthCheck.ProtoReflect.Descriptor instead.
func (*PluginCapability_HealthCheck) GetType ¶
func (x *PluginCapability_HealthCheck) GetType() PluginCapability_HealthCheck_Type
func (*PluginCapability_HealthCheck) ProtoMessage ¶
func (*PluginCapability_HealthCheck) ProtoMessage()
func (*PluginCapability_HealthCheck) ProtoReflect ¶
func (x *PluginCapability_HealthCheck) ProtoReflect() protoreflect.Message
func (*PluginCapability_HealthCheck) Reset ¶
func (x *PluginCapability_HealthCheck) Reset()
func (*PluginCapability_HealthCheck) String ¶
func (x *PluginCapability_HealthCheck) String() string
type PluginCapability_HealthCheck_ ¶
type PluginCapability_HealthCheck_ struct {
HealthCheck *PluginCapability_HealthCheck `protobuf:"bytes,2,opt,name=health_check,json=healthCheck,proto3,oneof"`
}
type PluginCapability_HealthCheck_Type ¶
type PluginCapability_HealthCheck_Type int32
const ( PluginCapability_HealthCheck_UNKNOWN PluginCapability_HealthCheck_Type = 0 // HTTP indicates that driver support http healthchecks PluginCapability_HealthCheck_HTTP PluginCapability_HealthCheck_Type = 1 // TCP indicates tthat driver support tcp healthchecks PluginCapability_HealthCheck_TCP PluginCapability_HealthCheck_Type = 2 )
func (PluginCapability_HealthCheck_Type) Descriptor ¶
func (PluginCapability_HealthCheck_Type) Descriptor() protoreflect.EnumDescriptor
func (PluginCapability_HealthCheck_Type) Enum ¶
func (x PluginCapability_HealthCheck_Type) Enum() *PluginCapability_HealthCheck_Type
func (PluginCapability_HealthCheck_Type) EnumDescriptor
deprecated
func (PluginCapability_HealthCheck_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use PluginCapability_HealthCheck_Type.Descriptor instead.
func (PluginCapability_HealthCheck_Type) Number ¶
func (x PluginCapability_HealthCheck_Type) Number() protoreflect.EnumNumber
func (PluginCapability_HealthCheck_Type) String ¶
func (x PluginCapability_HealthCheck_Type) String() string
func (PluginCapability_HealthCheck_Type) Type ¶
func (PluginCapability_HealthCheck_Type) Type() protoreflect.EnumType
type PluginCapability_Service ¶
type PluginCapability_Service struct { Type PluginCapability_Service_Type `protobuf:"varint,1,opt,name=type,proto3,enum=gslbi.v1.PluginCapability_Service_Type" json:"type,omitempty"` // contains filtered or unexported fields }
func (*PluginCapability_Service) Descriptor
deprecated
func (*PluginCapability_Service) Descriptor() ([]byte, []int)
Deprecated: Use PluginCapability_Service.ProtoReflect.Descriptor instead.
func (*PluginCapability_Service) GetType ¶
func (x *PluginCapability_Service) GetType() PluginCapability_Service_Type
func (*PluginCapability_Service) ProtoMessage ¶
func (*PluginCapability_Service) ProtoMessage()
func (*PluginCapability_Service) ProtoReflect ¶
func (x *PluginCapability_Service) ProtoReflect() protoreflect.Message
func (*PluginCapability_Service) Reset ¶
func (x *PluginCapability_Service) Reset()
func (*PluginCapability_Service) String ¶
func (x *PluginCapability_Service) String() string
type PluginCapability_Service_ ¶
type PluginCapability_Service_ struct { // Service that the plugin supports. Service *PluginCapability_Service `protobuf:"bytes,1,opt,name=service,proto3,oneof"` }
type PluginCapability_Service_Type ¶
type PluginCapability_Service_Type int32
const ( PluginCapability_Service_UNKNOWN PluginCapability_Service_Type = 0 // CONTROLLER_SERVICE indicates that the Plugin provides RPCs for // the ControllerService. Plugins SHOULD provide this capability. // In rare cases certain plugins MAY wish to omit the // ControllerService entirely from their implementation, but such // SHOULD NOT be the common case. // The presence of this capability determines whether the CO will // attempt to invoke the REQUIRED ControllerService RPCs, as well // as specific RPCs as indicated by ControllerGetCapabilities. PluginCapability_Service_CONTROLLER_SERVICE PluginCapability_Service_Type = 1 )
func (PluginCapability_Service_Type) Descriptor ¶
func (PluginCapability_Service_Type) Descriptor() protoreflect.EnumDescriptor
func (PluginCapability_Service_Type) Enum ¶
func (x PluginCapability_Service_Type) Enum() *PluginCapability_Service_Type
func (PluginCapability_Service_Type) EnumDescriptor
deprecated
func (PluginCapability_Service_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use PluginCapability_Service_Type.Descriptor instead.
func (PluginCapability_Service_Type) Number ¶
func (x PluginCapability_Service_Type) Number() protoreflect.EnumNumber
func (PluginCapability_Service_Type) String ¶
func (x PluginCapability_Service_Type) String() string
func (PluginCapability_Service_Type) Type ¶
func (PluginCapability_Service_Type) Type() protoreflect.EnumType
type ProbeRequest ¶
type ProbeRequest struct {
// contains filtered or unexported fields
}
func (*ProbeRequest) Descriptor
deprecated
func (*ProbeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProbeRequest.ProtoReflect.Descriptor instead.
func (*ProbeRequest) ProtoMessage ¶
func (*ProbeRequest) ProtoMessage()
func (*ProbeRequest) ProtoReflect ¶
func (x *ProbeRequest) ProtoReflect() protoreflect.Message
func (*ProbeRequest) Reset ¶
func (x *ProbeRequest) Reset()
func (*ProbeRequest) String ¶
func (x *ProbeRequest) String() string
type ProbeResponse ¶
type ProbeResponse struct { // Readiness allows a plugin to report its initialization status back // to the CO. Initialization for some plugins MAY be time consuming // and it is important for a CO to distinguish between the following // cases: // // 1) The plugin is in an unhealthy state and MAY need restarting. In // this case a gRPC error code SHALL be returned. // 2) The plugin is still initializing, but is otherwise perfectly // healthy. In this case a successful response SHALL be returned // with a readiness value of `false`. Calls to the plugin's // Controller and/or Node services MAY fail due to an incomplete // initialization state. // 3) The plugin has finished initializing and is ready to service // calls to its Controller and/or Node services. A successful // response is returned with a readiness value of `true`. // // This field is OPTIONAL. If not present, the caller SHALL assume // that the plugin is in a ready state and is accepting calls to its // Controller and/or Node services (according to the plugin's reported // capabilities). Ready *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=ready,proto3" json:"ready,omitempty"` // contains filtered or unexported fields }
func (*ProbeResponse) Descriptor
deprecated
func (*ProbeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProbeResponse.ProtoReflect.Descriptor instead.
func (*ProbeResponse) GetReady ¶
func (x *ProbeResponse) GetReady() *wrapperspb.BoolValue
func (*ProbeResponse) ProtoMessage ¶
func (*ProbeResponse) ProtoMessage()
func (*ProbeResponse) ProtoReflect ¶
func (x *ProbeResponse) ProtoReflect() protoreflect.Message
func (*ProbeResponse) Reset ¶
func (x *ProbeResponse) Reset()
func (*ProbeResponse) String ¶
func (x *ProbeResponse) String() string
type UnimplementedControllerServer ¶
type UnimplementedControllerServer struct { }
UnimplementedControllerServer must be embedded to have forward compatible implementations.
func (UnimplementedControllerServer) ControllerGetGSLB ¶
func (UnimplementedControllerServer) ControllerGetGSLB(context.Context, *ControllerGetGSLBRequest) (*ControllerGetGSLBResponse, error)
func (UnimplementedControllerServer) CreateGSLB ¶
func (UnimplementedControllerServer) CreateGSLB(context.Context, *CreateGSLBRequest) (*CreateGSLBResponse, error)
func (UnimplementedControllerServer) DeleteGSLB ¶
func (UnimplementedControllerServer) DeleteGSLB(context.Context, *DeleteGSLBRequest) (*DeleteGSLBResponse, error)
type UnimplementedIdentityServer ¶
type UnimplementedIdentityServer struct { }
UnimplementedIdentityServer must be embedded to have forward compatible implementations.
func (UnimplementedIdentityServer) GetPluginCapabilities ¶
func (UnimplementedIdentityServer) GetPluginCapabilities(context.Context, *GetPluginCapabilitiesRequest) (*GetPluginCapabilitiesResponse, error)
func (UnimplementedIdentityServer) GetPluginInfo ¶
func (UnimplementedIdentityServer) GetPluginInfo(context.Context, *GetPluginInfoRequest) (*GetPluginInfoResponse, error)
func (UnimplementedIdentityServer) Probe ¶
func (UnimplementedIdentityServer) Probe(context.Context, *ProbeRequest) (*ProbeResponse, error)
type UnsafeControllerServer ¶
type UnsafeControllerServer interface {
// contains filtered or unexported methods
}
UnsafeControllerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControllerServer will result in compilation errors.
type UnsafeIdentityServer ¶
type UnsafeIdentityServer interface {
// contains filtered or unexported methods
}
UnsafeIdentityServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IdentityServer will result in compilation errors.