types

package
v0.0.4-dev.0...-067a624 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GetVersionCapability     = iota
	SetVersionCapability     = iota
	GetClusterSizeCapability = iota
	SetClusterSizeCapability = iota
	EtcdBackupCapability     = iota
)
View Source 
const (
	// StringType is the type for string flag
	StringType = "string"
	// BoolType is the type for bool flag. It should be used if the bool value should be false if missing
	BoolType = "bool"
	// BoolPointerType flag should be used if the bool value can be nil
	BoolPointerType = "boolPtr"
	// IntType is the type for int flag
	IntType = "int"
	// IntPointerType flag should be used if the int value can be nil
	IntPointerType = "intPtr"
	// StringSliceType is the type for stringSlice flag
	StringSliceType = "stringSlice"
)

Variables

This section is empty.

Functions

func GetCtx 

func GetCtx(ctx context.Context) context.Context

func RegisterDriverServer 

func RegisterDriverServer(s *grpc.Server, srv DriverServer)

Types

type Capabilities 

type Capabilities struct {
	Capabilities         map[int64]bool `` /* 167-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Capabilities) AddCapability 

func (c *Capabilities) AddCapability(cap int64)

func (*Capabilities) Descriptor 

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

func (*Capabilities) GetCapabilities 

func (m *Capabilities) GetCapabilities() map[int64]bool

func (*Capabilities) HasEtcdBackupCapability 

func (c *Capabilities) HasEtcdBackupCapability() bool

func (*Capabilities) HasGetClusterSizeCapability 

func (c *Capabilities) HasGetClusterSizeCapability() bool

func (*Capabilities) HasGetVersionCapability 

func (c *Capabilities) HasGetVersionCapability() bool

func (*Capabilities) HasSetClusterSizeCapability 

func (c *Capabilities) HasSetClusterSizeCapability() bool

func (*Capabilities) HasSetVersionCapability 

func (c *Capabilities) HasSetVersionCapability() bool

func (*Capabilities) ProtoMessage 

func (*Capabilities) ProtoMessage()

func (*Capabilities) Reset 

func (m *Capabilities) Reset()

func (*Capabilities) String 

func (m *Capabilities) String() string

func (*Capabilities) XXX_DiscardUnknown 

func (m *Capabilities) XXX_DiscardUnknown()

func (*Capabilities) XXX_Marshal 

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

func (*Capabilities) XXX_Merge 

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

func (*Capabilities) XXX_Size 

func (m *Capabilities) XXX_Size() int

func (*Capabilities) XXX_Unmarshal 

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

type CloseableDriver 

type CloseableDriver interface {
	Driver
	Close() error
}

func NewClient 

func NewClient(driverName string, addr string) (CloseableDriver, error)

NewClient creates a grpc client for a driver plugin

type ClusterInfo 

type ClusterInfo struct {
	Version              string            `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	ServiceAccountToken  string            `protobuf:"bytes,2,opt,name=service_account_token,json=serviceAccountToken,proto3" json:"service_account_token,omitempty"`
	Endpoint             string            `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Username             string            `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Password             string            `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	RootCaCertificate    string            `protobuf:"bytes,6,opt,name=root_ca_certificate,json=rootCaCertificate,proto3" json:"root_ca_certificate,omitempty"`
	ClientCertificate    string            `protobuf:"bytes,7,opt,name=client_certificate,json=clientCertificate,proto3" json:"client_certificate,omitempty"`
	ClientKey            string            `protobuf:"bytes,8,opt,name=client_key,json=clientKey,proto3" json:"client_key,omitempty"`
	NodeCount            int64             `protobuf:"varint,9,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`
	Metadata             map[string]string `` /* 158-byte string literal not displayed */
	Status               string            `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"`
	CreateError          string            `protobuf:"bytes,12,opt,name=create_error,json=createError,proto3" json:"create_error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ClusterInfo) Descriptor 

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

func (*ClusterInfo) GetClientCertificate 

func (m *ClusterInfo) GetClientCertificate() string

func (*ClusterInfo) GetClientKey 

func (m *ClusterInfo) GetClientKey() string

func (*ClusterInfo) GetCreateError 

func (m *ClusterInfo) GetCreateError() string

func (*ClusterInfo) GetEndpoint 

func (m *ClusterInfo) GetEndpoint() string

func (*ClusterInfo) GetMetadata 

func (m *ClusterInfo) GetMetadata() map[string]string

func (*ClusterInfo) GetNodeCount 

func (m *ClusterInfo) GetNodeCount() int64

func (*ClusterInfo) GetPassword 

func (m *ClusterInfo) GetPassword() string

func (*ClusterInfo) GetRootCaCertificate 

func (m *ClusterInfo) GetRootCaCertificate() string

func (*ClusterInfo) GetServiceAccountToken 

func (m *ClusterInfo) GetServiceAccountToken() string

func (*ClusterInfo) GetStatus 

func (m *ClusterInfo) GetStatus() string

func (*ClusterInfo) GetUsername 

func (m *ClusterInfo) GetUsername() string

func (*ClusterInfo) GetVersion 

func (m *ClusterInfo) GetVersion() string

func (*ClusterInfo) ProtoMessage 

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) Reset 

func (m *ClusterInfo) Reset()

func (*ClusterInfo) String 

func (m *ClusterInfo) String() string

func (*ClusterInfo) XXX_DiscardUnknown 

func (m *ClusterInfo) XXX_DiscardUnknown()

func (*ClusterInfo) XXX_Marshal 

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

func (*ClusterInfo) XXX_Merge 

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

func (*ClusterInfo) XXX_Size 

func (m *ClusterInfo) XXX_Size() int

func (*ClusterInfo) XXX_Unmarshal 

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

type CreateRequest 

type CreateRequest struct {
	DriverOptions        *DriverOptions `protobuf:"bytes,1,opt,name=driver_options,json=driverOptions,proto3" json:"driver_options,omitempty"`
	ClusterInfo          *ClusterInfo   `protobuf:"bytes,2,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetClusterInfo 

func (m *CreateRequest) GetClusterInfo() *ClusterInfo

func (*CreateRequest) GetDriverOptions 

func (m *CreateRequest) GetDriverOptions() *DriverOptions

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

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

func (*CreateRequest) XXX_Merge 

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

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

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

type Default 

type Default struct {
	DefaultBool          bool         `protobuf:"varint,1,opt,name=defaultBool,proto3" json:"defaultBool,omitempty"`
	DefaultString        string       `protobuf:"bytes,2,opt,name=defaultString,proto3" json:"defaultString,omitempty"`
	DefaultStringSlice   *StringSlice `protobuf:"bytes,3,opt,name=defaultStringSlice,proto3" json:"defaultStringSlice,omitempty"`
	DefaultInt           int64        `protobuf:"varint,4,opt,name=defaultInt,proto3" json:"defaultInt,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Default) Descriptor 

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

func (*Default) GetDefaultBool 

func (m *Default) GetDefaultBool() bool

func (*Default) GetDefaultInt 

func (m *Default) GetDefaultInt() int64

func (*Default) GetDefaultString 

func (m *Default) GetDefaultString() string

func (*Default) GetDefaultStringSlice 

func (m *Default) GetDefaultStringSlice() *StringSlice

func (*Default) ProtoMessage 

func (*Default) ProtoMessage()

func (*Default) Reset 

func (m *Default) Reset()

func (*Default) String 

func (m *Default) String() string

func (*Default) XXX_DiscardUnknown 

func (m *Default) XXX_DiscardUnknown()

func (*Default) XXX_Marshal 

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

func (*Default) XXX_Merge 

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

func (*Default) XXX_Size 

func (m *Default) XXX_Size() int

func (*Default) XXX_Unmarshal 

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

type Driver 

type Driver interface {
	// GetDriverCreateOptions returns cli flags that are used in create
	GetDriverCreateOptions(ctx context.Context) (*DriverFlags, error)

	// GetDriverUpdateOptions returns cli flags that are used in update
	GetDriverUpdateOptions(ctx context.Context) (*DriverFlags, error)

	// Create creates the cluster. clusterInfo is only set when we are retrying a failed or interrupted create
	Create(ctx context.Context, opts *DriverOptions, clusterInfo *ClusterInfo) (*ClusterInfo, error)

	// Update updates the cluster
	Update(ctx context.Context, clusterInfo *ClusterInfo, opts *DriverOptions) (*ClusterInfo, error)

	// PostCheck does post action after provisioning
	PostCheck(ctx context.Context, clusterInfo *ClusterInfo) (*ClusterInfo, error)

	// Remove removes the cluster
	Remove(ctx context.Context, clusterInfo *ClusterInfo) error

	GetVersion(ctx context.Context, clusterInfo *ClusterInfo) (*KubernetesVersion, error)
	SetVersion(ctx context.Context, clusterInfo *ClusterInfo, version *KubernetesVersion) error
	GetClusterSize(ctx context.Context, clusterInfo *ClusterInfo) (*NodeCount, error)
	SetClusterSize(ctx context.Context, clusterInfo *ClusterInfo, count *NodeCount) error

	// Get driver capabilities
	GetCapabilities(ctx context.Context) (*Capabilities, error)

	// Remove legacy service account token
	RemoveLegacyServiceAccount(ctx context.Context, clusterInfo *ClusterInfo) error

	ETCDSave(ctx context.Context, clusterInfo *ClusterInfo, opts *DriverOptions, snapshotName string) error
	ETCDRestore(ctx context.Context, clusterInfo *ClusterInfo, opts *DriverOptions, snapshotName string) (*ClusterInfo, error)
	ETCDRemoveSnapshot(ctx context.Context, clusterInfo *ClusterInfo, opts *DriverOptions, snapshotName string) error

	GetK8SCapabilities(ctx context.Context, opts *DriverOptions) (*K8SCapabilities, error)
}

Driver defines the interface that each driver plugin should implement

type DriverClient 

type DriverClient interface {
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*ClusterInfo, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*ClusterInfo, error)
	PostCheck(ctx context.Context, in *ClusterInfo, opts ...grpc.CallOption) (*ClusterInfo, error)
	Remove(ctx context.Context, in *ClusterInfo, opts ...grpc.CallOption) (*Empty, error)
	GetDriverCreateOptions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DriverFlags, error)
	GetDriverUpdateOptions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DriverFlags, error)
	GetVersion(ctx context.Context, in *ClusterInfo, opts ...grpc.CallOption) (*KubernetesVersion, error)
	SetVersion(ctx context.Context, in *SetVersionRequest, opts ...grpc.CallOption) (*Empty, error)
	GetNodeCount(ctx context.Context, in *ClusterInfo, opts ...grpc.CallOption) (*NodeCount, error)
	SetNodeCount(ctx context.Context, in *SetNodeCountRequest, opts ...grpc.CallOption) (*Empty, error)
	GetCapabilities(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Capabilities, error)
	ETCDSave(ctx context.Context, in *SaveETCDSnapshotRequest, opts ...grpc.CallOption) (*Empty, error)
	ETCDRestore(ctx context.Context, in *RestoreETCDSnapshotRequest, opts ...grpc.CallOption) (*ClusterInfo, error)
	ETCDRemoveSnapshot(ctx context.Context, in *RemoveETCDSnapshotRequest, opts ...grpc.CallOption) (*Empty, error)
	GetK8SCapabilities(ctx context.Context, in *DriverOptions, opts ...grpc.CallOption) (*K8SCapabilities, error)
	RemoveLegacyServiceAccount(ctx context.Context, in *ClusterInfo, opts ...grpc.CallOption) (*Empty, error)
}

DriverClient is the client API for Driver service.

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

func NewDriverClient 

func NewDriverClient(cc *grpc.ClientConn) DriverClient

type DriverFlags 

type DriverFlags struct {
	Options              map[string]*Flag `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DriverFlags) Descriptor 

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

func (*DriverFlags) GetOptions 

func (m *DriverFlags) GetOptions() map[string]*Flag

func (*DriverFlags) ProtoMessage 

func (*DriverFlags) ProtoMessage()

func (*DriverFlags) Reset 

func (m *DriverFlags) Reset()

func (*DriverFlags) String 

func (m *DriverFlags) String() string

func (*DriverFlags) XXX_DiscardUnknown 

func (m *DriverFlags) XXX_DiscardUnknown()

func (*DriverFlags) XXX_Marshal 

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

func (*DriverFlags) XXX_Merge 

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

func (*DriverFlags) XXX_Size 

func (m *DriverFlags) XXX_Size() int

func (*DriverFlags) XXX_Unmarshal 

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

type DriverOptions 

type DriverOptions struct {
	BoolOptions          map[string]bool         `` /* 183-byte string literal not displayed */
	StringOptions        map[string]string       `` /* 188-byte string literal not displayed */
	IntOptions           map[string]int64        `` /* 180-byte string literal not displayed */
	StringSliceOptions   map[string]*StringSlice `` /* 205-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*DriverOptions) Descriptor 

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

func (*DriverOptions) GetBoolOptions 

func (m *DriverOptions) GetBoolOptions() map[string]bool

func (*DriverOptions) GetIntOptions 

func (m *DriverOptions) GetIntOptions() map[string]int64

func (*DriverOptions) GetStringOptions 

func (m *DriverOptions) GetStringOptions() map[string]string

func (*DriverOptions) GetStringSliceOptions 

func (m *DriverOptions) GetStringSliceOptions() map[string]*StringSlice

func (*DriverOptions) ProtoMessage 

func (*DriverOptions) ProtoMessage()

func (*DriverOptions) Reset 

func (m *DriverOptions) Reset()

func (*DriverOptions) String 

func (m *DriverOptions) String() string

func (*DriverOptions) XXX_DiscardUnknown 

func (m *DriverOptions) XXX_DiscardUnknown()

func (*DriverOptions) XXX_Marshal 

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

func (*DriverOptions) XXX_Merge 

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

func (*DriverOptions) XXX_Size 

func (m *DriverOptions) XXX_Size() int

func (*DriverOptions) XXX_Unmarshal 

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

type DriverServer 

type DriverServer interface {
	Create(context.Context, *CreateRequest) (*ClusterInfo, error)
	Update(context.Context, *UpdateRequest) (*ClusterInfo, error)
	PostCheck(context.Context, *ClusterInfo) (*ClusterInfo, error)
	Remove(context.Context, *ClusterInfo) (*Empty, error)
	GetDriverCreateOptions(context.Context, *Empty) (*DriverFlags, error)
	GetDriverUpdateOptions(context.Context, *Empty) (*DriverFlags, error)
	GetVersion(context.Context, *ClusterInfo) (*KubernetesVersion, error)
	SetVersion(context.Context, *SetVersionRequest) (*Empty, error)
	GetNodeCount(context.Context, *ClusterInfo) (*NodeCount, error)
	SetNodeCount(context.Context, *SetNodeCountRequest) (*Empty, error)
	GetCapabilities(context.Context, *Empty) (*Capabilities, error)
	ETCDSave(context.Context, *SaveETCDSnapshotRequest) (*Empty, error)
	ETCDRestore(context.Context, *RestoreETCDSnapshotRequest) (*ClusterInfo, error)
	ETCDRemoveSnapshot(context.Context, *RemoveETCDSnapshotRequest) (*Empty, error)
	GetK8SCapabilities(context.Context, *DriverOptions) (*K8SCapabilities, error)
	RemoveLegacyServiceAccount(context.Context, *ClusterInfo) (*Empty, error)
}

DriverServer is the server API for Driver service.

type Empty 

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

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type Flag 

type Flag struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Usage                string   `protobuf:"bytes,2,opt,name=usage,proto3" json:"usage,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Default              *Default `protobuf:"bytes,4,opt,name=default,proto3" json:"default,omitempty"`
	Password             bool     `protobuf:"varint,5,opt,name=password,proto3" json:"password,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Flag) Descriptor 

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

func (*Flag) GetDefault 

func (m *Flag) GetDefault() *Default

func (*Flag) GetPassword 

func (m *Flag) GetPassword() bool

func (*Flag) GetType 

func (m *Flag) GetType() string

func (*Flag) GetUsage 

func (m *Flag) GetUsage() string

func (*Flag) GetValue 

func (m *Flag) GetValue() string

func (*Flag) ProtoMessage 

func (*Flag) ProtoMessage()

func (*Flag) Reset 

func (m *Flag) Reset()

func (*Flag) String 

func (m *Flag) String() string

func (*Flag) XXX_DiscardUnknown 

func (m *Flag) XXX_DiscardUnknown()

func (*Flag) XXX_Marshal 

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

func (*Flag) XXX_Merge 

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

func (*Flag) XXX_Size 

func (m *Flag) XXX_Size() int

func (*Flag) XXX_Unmarshal 

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

type GrpcServer 

type GrpcServer struct {
	// contains filtered or unexported fields
}

GrpcServer defines the server struct

func NewServer 

func NewServer(driver Driver, addr chan string) *GrpcServer

NewServer creates a grpc server for a specific plugin

func (*GrpcServer) Create 

func (s *GrpcServer) Create(ctx context.Context, create *CreateRequest) (*ClusterInfo, error)

Create implements grpc method

func (*GrpcServer) ETCDRemoveSnapshot 

func (s *GrpcServer) ETCDRemoveSnapshot(ctx context.Context, request *RemoveETCDSnapshotRequest) (*Empty, error)

func (*GrpcServer) ETCDRestore 

func (s *GrpcServer) ETCDRestore(ctx context.Context, request *RestoreETCDSnapshotRequest) (*ClusterInfo, error)

func (*GrpcServer) ETCDSave 

func (s *GrpcServer) ETCDSave(ctx context.Context, request *SaveETCDSnapshotRequest) (*Empty, error)

func (*GrpcServer) GetCapabilities 

func (s *GrpcServer) GetCapabilities(ctx context.Context, in *Empty) (*Capabilities, error)

func (*GrpcServer) GetDriverCreateOptions 

func (s *GrpcServer) GetDriverCreateOptions(ctx context.Context, in *Empty) (*DriverFlags, error)

GetDriverCreateOptions implements grpc method

func (*GrpcServer) GetDriverUpdateOptions 

func (s *GrpcServer) GetDriverUpdateOptions(ctx context.Context, in *Empty) (*DriverFlags, error)

GetDriverUpdateOptions implements grpc method

func (*GrpcServer) GetK8SCapabilities 

func (s *GrpcServer) GetK8SCapabilities(ctx context.Context, opts *DriverOptions) (*K8SCapabilities, error)

func (*GrpcServer) GetNodeCount 

func (s *GrpcServer) GetNodeCount(ctx context.Context, clusterInfo *ClusterInfo) (*NodeCount, error)

func (*GrpcServer) GetVersion 

func (s *GrpcServer) GetVersion(ctx context.Context, clusterInfo *ClusterInfo) (*KubernetesVersion, error)

func (*GrpcServer) PostCheck 

func (s *GrpcServer) PostCheck(ctx context.Context, clusterInfo *ClusterInfo) (*ClusterInfo, error)

func (*GrpcServer) Remove 

func (s *GrpcServer) Remove(ctx context.Context, clusterInfo *ClusterInfo) (*Empty, error)

Remove implements grpc method

func (*GrpcServer) RemoveLegacyServiceAccount 

func (s *GrpcServer) RemoveLegacyServiceAccount(ctx context.Context, clusterInfo *ClusterInfo) (*Empty, error)

func (*GrpcServer) Serve 

func (s *GrpcServer) Serve(listenAddr string, errChan chan error)

Serve serves a grpc server. Sends errors to the error channel if they occur

func (*GrpcServer) ServeOrDie 

func (s *GrpcServer) ServeOrDie(listenAddr string)

ServeOrDie serves a grpc server or kills the process

func (*GrpcServer) SetNodeCount 

func (s *GrpcServer) SetNodeCount(ctx context.Context, request *SetNodeCountRequest) (*Empty, error)

func (*GrpcServer) SetVersion 

func (s *GrpcServer) SetVersion(ctx context.Context, request *SetVersionRequest) (*Empty, error)

func (*GrpcServer) Stop 

func (s *GrpcServer) Stop()

func (*GrpcServer) Update 

func (s *GrpcServer) Update(ctx context.Context, update *UpdateRequest) (*ClusterInfo, error)

Update implements grpc method

type IngressCapabilities 

type IngressCapabilities struct {
	IngressProvider      string   `protobuf:"bytes,1,opt,name=IngressProvider,proto3" json:"IngressProvider,omitempty"`
	CustomDefaultBackend bool     `protobuf:"varint,2,opt,name=CustomDefaultBackend,proto3" json:"CustomDefaultBackend,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IngressCapabilities) Descriptor 

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

func (*IngressCapabilities) GetCustomDefaultBackend 

func (m *IngressCapabilities) GetCustomDefaultBackend() bool

func (*IngressCapabilities) GetIngressProvider 

func (m *IngressCapabilities) GetIngressProvider() string

func (*IngressCapabilities) ProtoMessage 

func (*IngressCapabilities) ProtoMessage()

func (*IngressCapabilities) Reset 

func (m *IngressCapabilities) Reset()

func (*IngressCapabilities) String 

func (m *IngressCapabilities) String() string

func (*IngressCapabilities) XXX_DiscardUnknown 

func (m *IngressCapabilities) XXX_DiscardUnknown()

func (*IngressCapabilities) XXX_Marshal 

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

func (*IngressCapabilities) XXX_Merge 

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

func (*IngressCapabilities) XXX_Size 

func (m *IngressCapabilities) XXX_Size() int

func (*IngressCapabilities) XXX_Unmarshal 

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

type K8SCapabilities 

type K8SCapabilities struct {
	L4LoadBalancer           *LoadBalancerCapabilities `protobuf:"bytes,1,opt,name=L4LoadBalancer,proto3" json:"L4LoadBalancer,omitempty"`
	IngressControllers       []*IngressCapabilities    `protobuf:"bytes,2,rep,name=IngressControllers,proto3" json:"IngressControllers,omitempty"`
	NodePoolScalingSupported bool                      `protobuf:"varint,3,opt,name=NodePoolScalingSupported,proto3" json:"NodePoolScalingSupported,omitempty"`
	NodePortRange            string                    `protobuf:"bytes,4,opt,name=NodePortRange,proto3" json:"NodePortRange,omitempty"`
	XXX_NoUnkeyedLiteral     struct{}                  `json:"-"`
	XXX_unrecognized         []byte                    `json:"-"`
	XXX_sizecache            int32                     `json:"-"`
}

func (*K8SCapabilities) Descriptor 

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

func (*K8SCapabilities) GetIngressControllers 

func (m *K8SCapabilities) GetIngressControllers() []*IngressCapabilities

func (*K8SCapabilities) GetL4LoadBalancer 

func (m *K8SCapabilities) GetL4LoadBalancer() *LoadBalancerCapabilities

func (*K8SCapabilities) GetNodePoolScalingSupported 

func (m *K8SCapabilities) GetNodePoolScalingSupported() bool

func (*K8SCapabilities) GetNodePortRange 

func (m *K8SCapabilities) GetNodePortRange() string

func (*K8SCapabilities) ProtoMessage 

func (*K8SCapabilities) ProtoMessage()

func (*K8SCapabilities) Reset 

func (m *K8SCapabilities) Reset()

func (*K8SCapabilities) String 

func (m *K8SCapabilities) String() string

func (*K8SCapabilities) XXX_DiscardUnknown 

func (m *K8SCapabilities) XXX_DiscardUnknown()

func (*K8SCapabilities) XXX_Marshal 

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

func (*K8SCapabilities) XXX_Merge 

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

func (*K8SCapabilities) XXX_Size 

func (m *K8SCapabilities) XXX_Size() int

func (*K8SCapabilities) XXX_Unmarshal 

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

type KubernetesVersion 

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

func (*KubernetesVersion) Descriptor 

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

func (*KubernetesVersion) GetVersion 

func (m *KubernetesVersion) GetVersion() string

func (*KubernetesVersion) ProtoMessage 

func (*KubernetesVersion) ProtoMessage()

func (*KubernetesVersion) Reset 

func (m *KubernetesVersion) Reset()

func (*KubernetesVersion) String 

func (m *KubernetesVersion) String() string

func (*KubernetesVersion) XXX_DiscardUnknown 

func (m *KubernetesVersion) XXX_DiscardUnknown()

func (*KubernetesVersion) XXX_Marshal 

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

func (*KubernetesVersion) XXX_Merge 

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

func (*KubernetesVersion) XXX_Size 

func (m *KubernetesVersion) XXX_Size() int

func (*KubernetesVersion) XXX_Unmarshal 

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

type LoadBalancerCapabilities 

type LoadBalancerCapabilities struct {
	Enabled              bool     `protobuf:"varint,1,opt,name=Enabled,proto3" json:"Enabled,omitempty"`
	Provider             string   `protobuf:"bytes,2,opt,name=Provider,proto3" json:"Provider,omitempty"`
	ProtocolsSupported   []string `protobuf:"bytes,3,rep,name=ProtocolsSupported,proto3" json:"ProtocolsSupported,omitempty"`
	HealthCheckSupported bool     `protobuf:"varint,4,opt,name=HealthCheckSupported,proto3" json:"HealthCheckSupported,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadBalancerCapabilities) Descriptor 

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

func (*LoadBalancerCapabilities) GetEnabled 

func (m *LoadBalancerCapabilities) GetEnabled() bool

func (*LoadBalancerCapabilities) GetHealthCheckSupported 

func (m *LoadBalancerCapabilities) GetHealthCheckSupported() bool

func (*LoadBalancerCapabilities) GetProtocolsSupported 

func (m *LoadBalancerCapabilities) GetProtocolsSupported() []string

func (*LoadBalancerCapabilities) GetProvider 

func (m *LoadBalancerCapabilities) GetProvider() string

func (*LoadBalancerCapabilities) ProtoMessage 

func (*LoadBalancerCapabilities) ProtoMessage()

func (*LoadBalancerCapabilities) Reset 

func (m *LoadBalancerCapabilities) Reset()

func (*LoadBalancerCapabilities) String 

func (m *LoadBalancerCapabilities) String() string

func (*LoadBalancerCapabilities) XXX_DiscardUnknown 

func (m *LoadBalancerCapabilities) XXX_DiscardUnknown()

func (*LoadBalancerCapabilities) XXX_Marshal 

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

func (*LoadBalancerCapabilities) XXX_Merge 

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

func (*LoadBalancerCapabilities) XXX_Size 

func (m *LoadBalancerCapabilities) XXX_Size() int

func (*LoadBalancerCapabilities) XXX_Unmarshal 

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

type NodeCount 

type NodeCount struct {
	Count                int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeCount) Descriptor 

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

func (*NodeCount) GetCount 

func (m *NodeCount) GetCount() int64

func (*NodeCount) ProtoMessage 

func (*NodeCount) ProtoMessage()

func (*NodeCount) Reset 

func (m *NodeCount) Reset()

func (*NodeCount) String 

func (m *NodeCount) String() string

func (*NodeCount) XXX_DiscardUnknown 

func (m *NodeCount) XXX_DiscardUnknown()

func (*NodeCount) XXX_Marshal 

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

func (*NodeCount) XXX_Merge 

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

func (*NodeCount) XXX_Size 

func (m *NodeCount) XXX_Size() int

func (*NodeCount) XXX_Unmarshal 

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

type RemoveETCDSnapshotRequest 

type RemoveETCDSnapshotRequest struct {
	Info                 *ClusterInfo   `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	DriverOptions        *DriverOptions `protobuf:"bytes,2,opt,name=driver_options,json=driverOptions,proto3" json:"driver_options,omitempty"`
	SnapshotName         string         `protobuf:"bytes,3,opt,name=SnapshotName,proto3" json:"SnapshotName,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RemoveETCDSnapshotRequest) Descriptor 

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

func (*RemoveETCDSnapshotRequest) GetDriverOptions 

func (m *RemoveETCDSnapshotRequest) GetDriverOptions() *DriverOptions

func (*RemoveETCDSnapshotRequest) GetInfo 

func (m *RemoveETCDSnapshotRequest) GetInfo() *ClusterInfo

func (*RemoveETCDSnapshotRequest) GetSnapshotName 

func (m *RemoveETCDSnapshotRequest) GetSnapshotName() string

func (*RemoveETCDSnapshotRequest) ProtoMessage 

func (*RemoveETCDSnapshotRequest) ProtoMessage()

func (*RemoveETCDSnapshotRequest) Reset 

func (m *RemoveETCDSnapshotRequest) Reset()

func (*RemoveETCDSnapshotRequest) String 

func (m *RemoveETCDSnapshotRequest) String() string

func (*RemoveETCDSnapshotRequest) XXX_DiscardUnknown 

func (m *RemoveETCDSnapshotRequest) XXX_DiscardUnknown()

func (*RemoveETCDSnapshotRequest) XXX_Marshal 

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

func (*RemoveETCDSnapshotRequest) XXX_Merge 

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

func (*RemoveETCDSnapshotRequest) XXX_Size 

func (m *RemoveETCDSnapshotRequest) XXX_Size() int

func (*RemoveETCDSnapshotRequest) XXX_Unmarshal 

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

type RestoreETCDSnapshotRequest 

type RestoreETCDSnapshotRequest struct {
	Info                 *ClusterInfo   `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	DriverOptions        *DriverOptions `protobuf:"bytes,2,opt,name=driver_options,json=driverOptions,proto3" json:"driver_options,omitempty"`
	SnapshotName         string         `protobuf:"bytes,3,opt,name=SnapshotName,proto3" json:"SnapshotName,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RestoreETCDSnapshotRequest) Descriptor 

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

func (*RestoreETCDSnapshotRequest) GetDriverOptions 

func (m *RestoreETCDSnapshotRequest) GetDriverOptions() *DriverOptions

func (*RestoreETCDSnapshotRequest) GetInfo 

func (m *RestoreETCDSnapshotRequest) GetInfo() *ClusterInfo

func (*RestoreETCDSnapshotRequest) GetSnapshotName 

func (m *RestoreETCDSnapshotRequest) GetSnapshotName() string

func (*RestoreETCDSnapshotRequest) ProtoMessage 

func (*RestoreETCDSnapshotRequest) ProtoMessage()

func (*RestoreETCDSnapshotRequest) Reset 

func (m *RestoreETCDSnapshotRequest) Reset()

func (*RestoreETCDSnapshotRequest) String 

func (m *RestoreETCDSnapshotRequest) String() string

func (*RestoreETCDSnapshotRequest) XXX_DiscardUnknown 

func (m *RestoreETCDSnapshotRequest) XXX_DiscardUnknown()

func (*RestoreETCDSnapshotRequest) XXX_Marshal 

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

func (*RestoreETCDSnapshotRequest) XXX_Merge 

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

func (*RestoreETCDSnapshotRequest) XXX_Size 

func (m *RestoreETCDSnapshotRequest) XXX_Size() int

func (*RestoreETCDSnapshotRequest) XXX_Unmarshal 

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

type SaveETCDSnapshotRequest 

type SaveETCDSnapshotRequest struct {
	Info                 *ClusterInfo   `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	DriverOptions        *DriverOptions `protobuf:"bytes,2,opt,name=driver_options,json=driverOptions,proto3" json:"driver_options,omitempty"`
	SnapshotName         string         `protobuf:"bytes,3,opt,name=SnapshotName,proto3" json:"SnapshotName,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*SaveETCDSnapshotRequest) Descriptor 

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

func (*SaveETCDSnapshotRequest) GetDriverOptions 

func (m *SaveETCDSnapshotRequest) GetDriverOptions() *DriverOptions

func (*SaveETCDSnapshotRequest) GetInfo 

func (m *SaveETCDSnapshotRequest) GetInfo() *ClusterInfo

func (*SaveETCDSnapshotRequest) GetSnapshotName 

func (m *SaveETCDSnapshotRequest) GetSnapshotName() string

func (*SaveETCDSnapshotRequest) ProtoMessage 

func (*SaveETCDSnapshotRequest) ProtoMessage()

func (*SaveETCDSnapshotRequest) Reset 

func (m *SaveETCDSnapshotRequest) Reset()

func (*SaveETCDSnapshotRequest) String 

func (m *SaveETCDSnapshotRequest) String() string

func (*SaveETCDSnapshotRequest) XXX_DiscardUnknown 

func (m *SaveETCDSnapshotRequest) XXX_DiscardUnknown()

func (*SaveETCDSnapshotRequest) XXX_Marshal 

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

func (*SaveETCDSnapshotRequest) XXX_Merge 

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

func (*SaveETCDSnapshotRequest) XXX_Size 

func (m *SaveETCDSnapshotRequest) XXX_Size() int

func (*SaveETCDSnapshotRequest) XXX_Unmarshal 

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

type SetNodeCountRequest 

type SetNodeCountRequest struct {
	Info                 *ClusterInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Count                *NodeCount   `protobuf:"bytes,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*SetNodeCountRequest) Descriptor 

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

func (*SetNodeCountRequest) GetCount 

func (m *SetNodeCountRequest) GetCount() *NodeCount

func (*SetNodeCountRequest) GetInfo 

func (m *SetNodeCountRequest) GetInfo() *ClusterInfo

func (*SetNodeCountRequest) ProtoMessage 

func (*SetNodeCountRequest) ProtoMessage()

func (*SetNodeCountRequest) Reset 

func (m *SetNodeCountRequest) Reset()

func (*SetNodeCountRequest) String 

func (m *SetNodeCountRequest) String() string

func (*SetNodeCountRequest) XXX_DiscardUnknown 

func (m *SetNodeCountRequest) XXX_DiscardUnknown()

func (*SetNodeCountRequest) XXX_Marshal 

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

func (*SetNodeCountRequest) XXX_Merge 

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

func (*SetNodeCountRequest) XXX_Size 

func (m *SetNodeCountRequest) XXX_Size() int

func (*SetNodeCountRequest) XXX_Unmarshal 

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

type SetVersionRequest 

type SetVersionRequest struct {
	Info                 *ClusterInfo       `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Version              *KubernetesVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*SetVersionRequest) Descriptor 

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

func (*SetVersionRequest) GetInfo 

func (m *SetVersionRequest) GetInfo() *ClusterInfo

func (*SetVersionRequest) GetVersion 

func (m *SetVersionRequest) GetVersion() *KubernetesVersion

func (*SetVersionRequest) ProtoMessage 

func (*SetVersionRequest) ProtoMessage()

func (*SetVersionRequest) Reset 

func (m *SetVersionRequest) Reset()

func (*SetVersionRequest) String 

func (m *SetVersionRequest) String() string

func (*SetVersionRequest) XXX_DiscardUnknown 

func (m *SetVersionRequest) XXX_DiscardUnknown()

func (*SetVersionRequest) XXX_Marshal 

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

func (*SetVersionRequest) XXX_Merge 

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

func (*SetVersionRequest) XXX_Size 

func (m *SetVersionRequest) XXX_Size() int

func (*SetVersionRequest) XXX_Unmarshal 

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

type StringSlice 

type StringSlice struct {
	Value                []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StringSlice) Descriptor 

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

func (*StringSlice) GetValue 

func (m *StringSlice) GetValue() []string

func (*StringSlice) ProtoMessage 

func (*StringSlice) ProtoMessage()

func (*StringSlice) Reset 

func (m *StringSlice) Reset()

func (*StringSlice) String 

func (m *StringSlice) String() string

func (*StringSlice) XXX_DiscardUnknown 

func (m *StringSlice) XXX_DiscardUnknown()

func (*StringSlice) XXX_Marshal 

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

func (*StringSlice) XXX_Merge 

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

func (*StringSlice) XXX_Size 

func (m *StringSlice) XXX_Size() int

func (*StringSlice) XXX_Unmarshal 

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

type UnimplementedClusterSizeAccess 

type UnimplementedClusterSizeAccess struct {
}

func (*UnimplementedClusterSizeAccess) GetClusterSize 

func (u *UnimplementedClusterSizeAccess) GetClusterSize(ctx context.Context, info *ClusterInfo) (*NodeCount, error)

func (*UnimplementedClusterSizeAccess) SetClusterSize 

func (u *UnimplementedClusterSizeAccess) SetClusterSize(ctx context.Context, info *ClusterInfo, count *NodeCount) error

type UnimplementedVersionAccess 

type UnimplementedVersionAccess struct {
}

func (*UnimplementedVersionAccess) GetVersion 

func (u *UnimplementedVersionAccess) GetVersion(ctx context.Context, info *ClusterInfo) (*KubernetesVersion, error)

func (*UnimplementedVersionAccess) SetVersion 

func (u *UnimplementedVersionAccess) SetVersion(ctx context.Context, info *ClusterInfo, version *KubernetesVersion) error

type UpdateRequest 

type UpdateRequest struct {
	ClusterInfo          *ClusterInfo   `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
	DriverOptions        *DriverOptions `protobuf:"bytes,2,opt,name=driver_options,json=driverOptions,proto3" json:"driver_options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*UpdateRequest) Descriptor 

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

func (*UpdateRequest) GetClusterInfo 

func (m *UpdateRequest) GetClusterInfo() *ClusterInfo

func (*UpdateRequest) GetDriverOptions 

func (m *UpdateRequest) GetDriverOptions() *DriverOptions

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) Reset 

func (m *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (m *UpdateRequest) String() string

func (*UpdateRequest) XXX_DiscardUnknown 

func (m *UpdateRequest) XXX_DiscardUnknown()

func (*UpdateRequest) XXX_Marshal 

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

func (*UpdateRequest) XXX_Merge 

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

func (*UpdateRequest) XXX_Size 

func (m *UpdateRequest) XXX_Size() int

func (*UpdateRequest) XXX_Unmarshal 

func (m *UpdateRequest) 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.