Documentation ¶
Index ¶
- Variables
- func RegisterClusterManagerServer(s *grpc.Server, srv ClusterManagerServer)
- type ClusterConfig
- func (*ClusterConfig) Descriptor() ([]byte, []int)
- func (this *ClusterConfig) Equal(that interface{}) bool
- func (m *ClusterConfig) GetAutoUpdateEnabled() bool
- func (m *ClusterConfig) GetPassthroughEnabled() bool
- func (this *ClusterConfig) GoString() string
- func (m *ClusterConfig) Marshal() (dAtA []byte, err error)
- func (m *ClusterConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *ClusterConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClusterConfig) ProtoMessage()
- func (m *ClusterConfig) Reset()
- func (m *ClusterConfig) Size() (n int)
- func (this *ClusterConfig) String() string
- func (m *ClusterConfig) Unmarshal(dAtA []byte) error
- func (m *ClusterConfig) XXX_DiscardUnknown()
- func (m *ClusterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterConfig) XXX_Merge(src proto.Message)
- func (m *ClusterConfig) XXX_Size() int
- func (m *ClusterConfig) XXX_Unmarshal(b []byte) error
- type ClusterConfigUpdate
- func (*ClusterConfigUpdate) Descriptor() ([]byte, []int)
- func (this *ClusterConfigUpdate) Equal(that interface{}) bool
- func (m *ClusterConfigUpdate) GetAutoUpdateEnabled() *types.BoolValue
- func (m *ClusterConfigUpdate) GetPassthroughEnabled() *types.BoolValue
- func (this *ClusterConfigUpdate) GoString() string
- func (m *ClusterConfigUpdate) Marshal() (dAtA []byte, err error)
- func (m *ClusterConfigUpdate) MarshalTo(dAtA []byte) (int, error)
- func (m *ClusterConfigUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClusterConfigUpdate) ProtoMessage()
- func (m *ClusterConfigUpdate) Reset()
- func (m *ClusterConfigUpdate) Size() (n int)
- func (this *ClusterConfigUpdate) String() string
- func (m *ClusterConfigUpdate) Unmarshal(dAtA []byte) error
- func (m *ClusterConfigUpdate) XXX_DiscardUnknown()
- func (m *ClusterConfigUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterConfigUpdate) XXX_Merge(src proto.Message)
- func (m *ClusterConfigUpdate) XXX_Size() int
- func (m *ClusterConfigUpdate) XXX_Unmarshal(b []byte) error
- type ClusterInfo
- func (*ClusterInfo) Descriptor() ([]byte, []int)
- func (this *ClusterInfo) Equal(that interface{}) bool
- func (m *ClusterInfo) GetClusterName() string
- func (m *ClusterInfo) GetClusterUID() string
- func (m *ClusterInfo) GetClusterVersion() string
- func (m *ClusterInfo) GetConfig() *ClusterConfig
- func (m *ClusterInfo) GetID() *uuidpb.UUID
- func (m *ClusterInfo) GetLastHeartbeatNs() int64
- func (m *ClusterInfo) GetNumInstrumentedNodes() int32
- func (m *ClusterInfo) GetNumNodes() int32
- func (m *ClusterInfo) GetStatus() ClusterStatus
- func (m *ClusterInfo) GetVizierVersion() string
- func (this *ClusterInfo) GoString() string
- func (m *ClusterInfo) Marshal() (dAtA []byte, err error)
- func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *ClusterInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClusterInfo) ProtoMessage()
- func (m *ClusterInfo) Reset()
- func (m *ClusterInfo) Size() (n int)
- func (this *ClusterInfo) String() string
- func (m *ClusterInfo) Unmarshal(dAtA []byte) error
- func (m *ClusterInfo) XXX_DiscardUnknown()
- func (m *ClusterInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterInfo) XXX_Merge(src proto.Message)
- func (m *ClusterInfo) XXX_Size() int
- func (m *ClusterInfo) XXX_Unmarshal(b []byte) error
- type ClusterManagerClient
- type ClusterManagerServer
- type ClusterStatus
- type GetClusterConnectionRequest
- func (*GetClusterConnectionRequest) Descriptor() ([]byte, []int)
- func (this *GetClusterConnectionRequest) Equal(that interface{}) bool
- func (m *GetClusterConnectionRequest) GetID() *uuidpb.UUID
- func (this *GetClusterConnectionRequest) GoString() string
- func (m *GetClusterConnectionRequest) Marshal() (dAtA []byte, err error)
- func (m *GetClusterConnectionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetClusterConnectionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetClusterConnectionRequest) ProtoMessage()
- func (m *GetClusterConnectionRequest) Reset()
- func (m *GetClusterConnectionRequest) Size() (n int)
- func (this *GetClusterConnectionRequest) String() string
- func (m *GetClusterConnectionRequest) Unmarshal(dAtA []byte) error
- func (m *GetClusterConnectionRequest) XXX_DiscardUnknown()
- func (m *GetClusterConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetClusterConnectionRequest) XXX_Merge(src proto.Message)
- func (m *GetClusterConnectionRequest) XXX_Size() int
- func (m *GetClusterConnectionRequest) XXX_Unmarshal(b []byte) error
- type GetClusterConnectionResponse
- func (*GetClusterConnectionResponse) Descriptor() ([]byte, []int)
- func (this *GetClusterConnectionResponse) Equal(that interface{}) bool
- func (m *GetClusterConnectionResponse) GetIPAddress() string
- func (m *GetClusterConnectionResponse) GetToken() string
- func (this *GetClusterConnectionResponse) GoString() string
- func (m *GetClusterConnectionResponse) Marshal() (dAtA []byte, err error)
- func (m *GetClusterConnectionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetClusterConnectionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetClusterConnectionResponse) ProtoMessage()
- func (m *GetClusterConnectionResponse) Reset()
- func (m *GetClusterConnectionResponse) Size() (n int)
- func (this *GetClusterConnectionResponse) String() string
- func (m *GetClusterConnectionResponse) Unmarshal(dAtA []byte) error
- func (m *GetClusterConnectionResponse) XXX_DiscardUnknown()
- func (m *GetClusterConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetClusterConnectionResponse) XXX_Merge(src proto.Message)
- func (m *GetClusterConnectionResponse) XXX_Size() int
- func (m *GetClusterConnectionResponse) XXX_Unmarshal(b []byte) error
- type GetClusterRequest
- func (*GetClusterRequest) Descriptor() ([]byte, []int)
- func (this *GetClusterRequest) Equal(that interface{}) bool
- func (m *GetClusterRequest) GetID() *uuidpb.UUID
- func (this *GetClusterRequest) GoString() string
- func (m *GetClusterRequest) Marshal() (dAtA []byte, err error)
- func (m *GetClusterRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetClusterRequest) ProtoMessage()
- func (m *GetClusterRequest) Reset()
- func (m *GetClusterRequest) Size() (n int)
- func (this *GetClusterRequest) String() string
- func (m *GetClusterRequest) Unmarshal(dAtA []byte) error
- func (m *GetClusterRequest) XXX_DiscardUnknown()
- func (m *GetClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetClusterRequest) XXX_Merge(src proto.Message)
- func (m *GetClusterRequest) XXX_Size() int
- func (m *GetClusterRequest) XXX_Unmarshal(b []byte) error
- type GetClusterResponse
- func (*GetClusterResponse) Descriptor() ([]byte, []int)
- func (this *GetClusterResponse) Equal(that interface{}) bool
- func (m *GetClusterResponse) GetClusters() []*ClusterInfo
- func (this *GetClusterResponse) GoString() string
- func (m *GetClusterResponse) Marshal() (dAtA []byte, err error)
- func (m *GetClusterResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetClusterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetClusterResponse) ProtoMessage()
- func (m *GetClusterResponse) Reset()
- func (m *GetClusterResponse) Size() (n int)
- func (this *GetClusterResponse) String() string
- func (m *GetClusterResponse) Unmarshal(dAtA []byte) error
- func (m *GetClusterResponse) XXX_DiscardUnknown()
- func (m *GetClusterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetClusterResponse) XXX_Merge(src proto.Message)
- func (m *GetClusterResponse) XXX_Size() int
- func (m *GetClusterResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedClusterManagerServer
- func (*UnimplementedClusterManagerServer) GetCluster(ctx context.Context, req *GetClusterRequest) (*GetClusterResponse, error)
- func (*UnimplementedClusterManagerServer) GetClusterConnection(ctx context.Context, req *GetClusterConnectionRequest) (*GetClusterConnectionResponse, error)
- func (*UnimplementedClusterManagerServer) UpdateClusterConfig(ctx context.Context, req *UpdateClusterConfigRequest) (*UpdateClusterConfigResponse, error)
- type UpdateClusterConfigRequest
- func (*UpdateClusterConfigRequest) Descriptor() ([]byte, []int)
- func (this *UpdateClusterConfigRequest) Equal(that interface{}) bool
- func (m *UpdateClusterConfigRequest) GetConfigUpdate() *ClusterConfigUpdate
- func (m *UpdateClusterConfigRequest) GetID() *uuidpb.UUID
- func (this *UpdateClusterConfigRequest) GoString() string
- func (m *UpdateClusterConfigRequest) Marshal() (dAtA []byte, err error)
- func (m *UpdateClusterConfigRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateClusterConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateClusterConfigRequest) ProtoMessage()
- func (m *UpdateClusterConfigRequest) Reset()
- func (m *UpdateClusterConfigRequest) Size() (n int)
- func (this *UpdateClusterConfigRequest) String() string
- func (m *UpdateClusterConfigRequest) Unmarshal(dAtA []byte) error
- func (m *UpdateClusterConfigRequest) XXX_DiscardUnknown()
- func (m *UpdateClusterConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateClusterConfigRequest) XXX_Merge(src proto.Message)
- func (m *UpdateClusterConfigRequest) XXX_Size() int
- func (m *UpdateClusterConfigRequest) XXX_Unmarshal(b []byte) error
- type UpdateClusterConfigResponse
- func (*UpdateClusterConfigResponse) Descriptor() ([]byte, []int)
- func (this *UpdateClusterConfigResponse) Equal(that interface{}) bool
- func (this *UpdateClusterConfigResponse) GoString() string
- func (m *UpdateClusterConfigResponse) Marshal() (dAtA []byte, err error)
- func (m *UpdateClusterConfigResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateClusterConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateClusterConfigResponse) ProtoMessage()
- func (m *UpdateClusterConfigResponse) Reset()
- func (m *UpdateClusterConfigResponse) Size() (n int)
- func (this *UpdateClusterConfigResponse) String() string
- func (m *UpdateClusterConfigResponse) Unmarshal(dAtA []byte) error
- func (m *UpdateClusterConfigResponse) XXX_DiscardUnknown()
- func (m *UpdateClusterConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateClusterConfigResponse) XXX_Merge(src proto.Message)
- func (m *UpdateClusterConfigResponse) XXX_Size() int
- func (m *UpdateClusterConfigResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthCloudapi = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCloudapi = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupCloudapi = fmt.Errorf("proto: unexpected end of group") )
View Source
var ClusterStatus_name = map[int32]string{
0: "CS_UNKNOWN",
1: "CS_HEALTHY",
2: "CS_UNHEALTHY",
3: "CS_DISCONNECTED",
4: "CS_UPDATING",
5: "CS_CONNECTED",
6: "CS_UPDATE_FAILED",
}
View Source
var ClusterStatus_value = map[string]int32{
"CS_UNKNOWN": 0,
"CS_HEALTHY": 1,
"CS_UNHEALTHY": 2,
"CS_DISCONNECTED": 3,
"CS_UPDATING": 4,
"CS_CONNECTED": 5,
"CS_UPDATE_FAILED": 6,
}
Functions ¶
func RegisterClusterManagerServer ¶
func RegisterClusterManagerServer(s *grpc.Server, srv ClusterManagerServer)
Types ¶
type ClusterConfig ¶
type ClusterConfig struct { PassthroughEnabled bool `protobuf:"varint,1,opt,name=passthrough_enabled,json=passthroughEnabled,proto3" json:"passthrough_enabled,omitempty"` AutoUpdateEnabled bool `protobuf:"varint,2,opt,name=auto_update_enabled,json=autoUpdateEnabled,proto3" json:"auto_update_enabled,omitempty"` }
func (*ClusterConfig) Descriptor ¶
func (*ClusterConfig) Descriptor() ([]byte, []int)
func (*ClusterConfig) Equal ¶
func (this *ClusterConfig) Equal(that interface{}) bool
func (*ClusterConfig) GetAutoUpdateEnabled ¶
func (m *ClusterConfig) GetAutoUpdateEnabled() bool
func (*ClusterConfig) GetPassthroughEnabled ¶
func (m *ClusterConfig) GetPassthroughEnabled() bool
func (*ClusterConfig) GoString ¶
func (this *ClusterConfig) GoString() string
func (*ClusterConfig) Marshal ¶
func (m *ClusterConfig) Marshal() (dAtA []byte, err error)
func (*ClusterConfig) MarshalToSizedBuffer ¶
func (m *ClusterConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClusterConfig) ProtoMessage ¶
func (*ClusterConfig) ProtoMessage()
func (*ClusterConfig) Reset ¶
func (m *ClusterConfig) Reset()
func (*ClusterConfig) Size ¶
func (m *ClusterConfig) Size() (n int)
func (*ClusterConfig) String ¶
func (this *ClusterConfig) String() string
func (*ClusterConfig) Unmarshal ¶
func (m *ClusterConfig) Unmarshal(dAtA []byte) error
func (*ClusterConfig) XXX_DiscardUnknown ¶
func (m *ClusterConfig) XXX_DiscardUnknown()
func (*ClusterConfig) XXX_Marshal ¶
func (m *ClusterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterConfig) XXX_Merge ¶
func (m *ClusterConfig) XXX_Merge(src proto.Message)
func (*ClusterConfig) XXX_Size ¶
func (m *ClusterConfig) XXX_Size() int
func (*ClusterConfig) XXX_Unmarshal ¶
func (m *ClusterConfig) XXX_Unmarshal(b []byte) error
type ClusterConfigUpdate ¶
type ClusterConfigUpdate struct { PassthroughEnabled *types.BoolValue `protobuf:"bytes,1,opt,name=passthrough_enabled,json=passthroughEnabled,proto3" json:"passthrough_enabled,omitempty"` AutoUpdateEnabled *types.BoolValue `protobuf:"bytes,2,opt,name=auto_update_enabled,json=autoUpdateEnabled,proto3" json:"auto_update_enabled,omitempty"` }
func (*ClusterConfigUpdate) Descriptor ¶
func (*ClusterConfigUpdate) Descriptor() ([]byte, []int)
func (*ClusterConfigUpdate) Equal ¶
func (this *ClusterConfigUpdate) Equal(that interface{}) bool
func (*ClusterConfigUpdate) GetAutoUpdateEnabled ¶
func (m *ClusterConfigUpdate) GetAutoUpdateEnabled() *types.BoolValue
func (*ClusterConfigUpdate) GetPassthroughEnabled ¶
func (m *ClusterConfigUpdate) GetPassthroughEnabled() *types.BoolValue
func (*ClusterConfigUpdate) GoString ¶
func (this *ClusterConfigUpdate) GoString() string
func (*ClusterConfigUpdate) Marshal ¶
func (m *ClusterConfigUpdate) Marshal() (dAtA []byte, err error)
func (*ClusterConfigUpdate) MarshalTo ¶
func (m *ClusterConfigUpdate) MarshalTo(dAtA []byte) (int, error)
func (*ClusterConfigUpdate) MarshalToSizedBuffer ¶
func (m *ClusterConfigUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClusterConfigUpdate) ProtoMessage ¶
func (*ClusterConfigUpdate) ProtoMessage()
func (*ClusterConfigUpdate) Reset ¶
func (m *ClusterConfigUpdate) Reset()
func (*ClusterConfigUpdate) Size ¶
func (m *ClusterConfigUpdate) Size() (n int)
func (*ClusterConfigUpdate) String ¶
func (this *ClusterConfigUpdate) String() string
func (*ClusterConfigUpdate) Unmarshal ¶
func (m *ClusterConfigUpdate) Unmarshal(dAtA []byte) error
func (*ClusterConfigUpdate) XXX_DiscardUnknown ¶
func (m *ClusterConfigUpdate) XXX_DiscardUnknown()
func (*ClusterConfigUpdate) XXX_Marshal ¶
func (m *ClusterConfigUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterConfigUpdate) XXX_Merge ¶
func (m *ClusterConfigUpdate) XXX_Merge(src proto.Message)
func (*ClusterConfigUpdate) XXX_Size ¶
func (m *ClusterConfigUpdate) XXX_Size() int
func (*ClusterConfigUpdate) XXX_Unmarshal ¶
func (m *ClusterConfigUpdate) XXX_Unmarshal(b []byte) error
type ClusterInfo ¶
type ClusterInfo struct { ID *uuidpb.UUID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Status ClusterStatus `protobuf:"varint,2,opt,name=status,proto3,enum=pl.public.cloudapi.ClusterStatus" json:"status,omitempty"` LastHeartbeatNs int64 `protobuf:"varint,3,opt,name=lastHeartbeatNs,proto3" json:"lastHeartbeatNs,omitempty"` Config *ClusterConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"` ClusterUID string `protobuf:"bytes,5,opt,name=cluster_uid,json=clusterUid,proto3" json:"cluster_uid,omitempty"` ClusterName string `protobuf:"bytes,6,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` ClusterVersion string `protobuf:"bytes,7,opt,name=cluster_version,json=clusterVersion,proto3" json:"cluster_version,omitempty"` VizierVersion string `protobuf:"bytes,8,opt,name=vizier_version,json=vizierVersion,proto3" json:"vizier_version,omitempty"` NumNodes int32 `protobuf:"varint,9,opt,name=num_nodes,json=numNodes,proto3" json:"num_nodes,omitempty"` NumInstrumentedNodes int32 `protobuf:"varint,10,opt,name=num_instrumented_nodes,json=numInstrumentedNodes,proto3" json:"num_instrumented_nodes,omitempty"` }
func (*ClusterInfo) Descriptor ¶
func (*ClusterInfo) Descriptor() ([]byte, []int)
func (*ClusterInfo) Equal ¶
func (this *ClusterInfo) Equal(that interface{}) bool
func (*ClusterInfo) GetClusterName ¶
func (m *ClusterInfo) GetClusterName() string
func (*ClusterInfo) GetClusterUID ¶
func (m *ClusterInfo) GetClusterUID() string
func (*ClusterInfo) GetClusterVersion ¶
func (m *ClusterInfo) GetClusterVersion() string
func (*ClusterInfo) GetConfig ¶
func (m *ClusterInfo) GetConfig() *ClusterConfig
func (*ClusterInfo) GetID ¶
func (m *ClusterInfo) GetID() *uuidpb.UUID
func (*ClusterInfo) GetLastHeartbeatNs ¶
func (m *ClusterInfo) GetLastHeartbeatNs() int64
func (*ClusterInfo) GetNumInstrumentedNodes ¶
func (m *ClusterInfo) GetNumInstrumentedNodes() int32
func (*ClusterInfo) GetNumNodes ¶
func (m *ClusterInfo) GetNumNodes() int32
func (*ClusterInfo) GetStatus ¶
func (m *ClusterInfo) GetStatus() ClusterStatus
func (*ClusterInfo) GetVizierVersion ¶
func (m *ClusterInfo) GetVizierVersion() string
func (*ClusterInfo) GoString ¶
func (this *ClusterInfo) GoString() string
func (*ClusterInfo) Marshal ¶
func (m *ClusterInfo) Marshal() (dAtA []byte, err error)
func (*ClusterInfo) MarshalToSizedBuffer ¶
func (m *ClusterInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClusterInfo) ProtoMessage ¶
func (*ClusterInfo) ProtoMessage()
func (*ClusterInfo) Reset ¶
func (m *ClusterInfo) Reset()
func (*ClusterInfo) Size ¶
func (m *ClusterInfo) Size() (n int)
func (*ClusterInfo) String ¶
func (this *ClusterInfo) String() string
func (*ClusterInfo) Unmarshal ¶
func (m *ClusterInfo) Unmarshal(dAtA []byte) error
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 ClusterManagerClient ¶
type ClusterManagerClient interface { GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*GetClusterResponse, error) UpdateClusterConfig(ctx context.Context, in *UpdateClusterConfigRequest, opts ...grpc.CallOption) (*UpdateClusterConfigResponse, error) GetClusterConnection(ctx context.Context, in *GetClusterConnectionRequest, opts ...grpc.CallOption) (*GetClusterConnectionResponse, error) }
ClusterManagerClient is the client API for ClusterManager service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewClusterManagerClient ¶
func NewClusterManagerClient(cc *grpc.ClientConn) ClusterManagerClient
type ClusterManagerServer ¶
type ClusterManagerServer interface { GetCluster(context.Context, *GetClusterRequest) (*GetClusterResponse, error) UpdateClusterConfig(context.Context, *UpdateClusterConfigRequest) (*UpdateClusterConfigResponse, error) GetClusterConnection(context.Context, *GetClusterConnectionRequest) (*GetClusterConnectionResponse, error) }
ClusterManagerServer is the server API for ClusterManager service.
type ClusterStatus ¶
type ClusterStatus int32
const ( CS_UNKNOWN ClusterStatus = 0 CS_HEALTHY ClusterStatus = 1 CS_UNHEALTHY ClusterStatus = 2 CS_DISCONNECTED ClusterStatus = 3 CS_UPDATING ClusterStatus = 4 CS_CONNECTED ClusterStatus = 5 CS_UPDATE_FAILED ClusterStatus = 6 )
func (ClusterStatus) EnumDescriptor ¶
func (ClusterStatus) EnumDescriptor() ([]byte, []int)
func (ClusterStatus) String ¶
func (x ClusterStatus) String() string
type GetClusterConnectionRequest ¶
type GetClusterConnectionRequest struct {
ID *uuidpb.UUID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*GetClusterConnectionRequest) Descriptor ¶
func (*GetClusterConnectionRequest) Descriptor() ([]byte, []int)
func (*GetClusterConnectionRequest) Equal ¶
func (this *GetClusterConnectionRequest) Equal(that interface{}) bool
func (*GetClusterConnectionRequest) GetID ¶
func (m *GetClusterConnectionRequest) GetID() *uuidpb.UUID
func (*GetClusterConnectionRequest) GoString ¶
func (this *GetClusterConnectionRequest) GoString() string
func (*GetClusterConnectionRequest) Marshal ¶
func (m *GetClusterConnectionRequest) Marshal() (dAtA []byte, err error)
func (*GetClusterConnectionRequest) MarshalTo ¶
func (m *GetClusterConnectionRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetClusterConnectionRequest) MarshalToSizedBuffer ¶
func (m *GetClusterConnectionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetClusterConnectionRequest) ProtoMessage ¶
func (*GetClusterConnectionRequest) ProtoMessage()
func (*GetClusterConnectionRequest) Reset ¶
func (m *GetClusterConnectionRequest) Reset()
func (*GetClusterConnectionRequest) Size ¶
func (m *GetClusterConnectionRequest) Size() (n int)
func (*GetClusterConnectionRequest) String ¶
func (this *GetClusterConnectionRequest) String() string
func (*GetClusterConnectionRequest) Unmarshal ¶
func (m *GetClusterConnectionRequest) Unmarshal(dAtA []byte) error
func (*GetClusterConnectionRequest) XXX_DiscardUnknown ¶
func (m *GetClusterConnectionRequest) XXX_DiscardUnknown()
func (*GetClusterConnectionRequest) XXX_Marshal ¶
func (m *GetClusterConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetClusterConnectionRequest) XXX_Merge ¶
func (m *GetClusterConnectionRequest) XXX_Merge(src proto.Message)
func (*GetClusterConnectionRequest) XXX_Size ¶
func (m *GetClusterConnectionRequest) XXX_Size() int
func (*GetClusterConnectionRequest) XXX_Unmarshal ¶
func (m *GetClusterConnectionRequest) XXX_Unmarshal(b []byte) error
type GetClusterConnectionResponse ¶
type GetClusterConnectionResponse struct { IPAddress string `protobuf:"bytes,1,opt,name=ipAddress,proto3" json:"ipAddress,omitempty"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` }
func (*GetClusterConnectionResponse) Descriptor ¶
func (*GetClusterConnectionResponse) Descriptor() ([]byte, []int)
func (*GetClusterConnectionResponse) Equal ¶
func (this *GetClusterConnectionResponse) Equal(that interface{}) bool
func (*GetClusterConnectionResponse) GetIPAddress ¶
func (m *GetClusterConnectionResponse) GetIPAddress() string
func (*GetClusterConnectionResponse) GetToken ¶
func (m *GetClusterConnectionResponse) GetToken() string
func (*GetClusterConnectionResponse) GoString ¶
func (this *GetClusterConnectionResponse) GoString() string
func (*GetClusterConnectionResponse) Marshal ¶
func (m *GetClusterConnectionResponse) Marshal() (dAtA []byte, err error)
func (*GetClusterConnectionResponse) MarshalTo ¶
func (m *GetClusterConnectionResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetClusterConnectionResponse) MarshalToSizedBuffer ¶
func (m *GetClusterConnectionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetClusterConnectionResponse) ProtoMessage ¶
func (*GetClusterConnectionResponse) ProtoMessage()
func (*GetClusterConnectionResponse) Reset ¶
func (m *GetClusterConnectionResponse) Reset()
func (*GetClusterConnectionResponse) Size ¶
func (m *GetClusterConnectionResponse) Size() (n int)
func (*GetClusterConnectionResponse) String ¶
func (this *GetClusterConnectionResponse) String() string
func (*GetClusterConnectionResponse) Unmarshal ¶
func (m *GetClusterConnectionResponse) Unmarshal(dAtA []byte) error
func (*GetClusterConnectionResponse) XXX_DiscardUnknown ¶
func (m *GetClusterConnectionResponse) XXX_DiscardUnknown()
func (*GetClusterConnectionResponse) XXX_Marshal ¶
func (m *GetClusterConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetClusterConnectionResponse) XXX_Merge ¶
func (m *GetClusterConnectionResponse) XXX_Merge(src proto.Message)
func (*GetClusterConnectionResponse) XXX_Size ¶
func (m *GetClusterConnectionResponse) XXX_Size() int
func (*GetClusterConnectionResponse) XXX_Unmarshal ¶
func (m *GetClusterConnectionResponse) XXX_Unmarshal(b []byte) error
type GetClusterRequest ¶
type GetClusterRequest struct {
ID *uuidpb.UUID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*GetClusterRequest) Descriptor ¶
func (*GetClusterRequest) Descriptor() ([]byte, []int)
func (*GetClusterRequest) Equal ¶
func (this *GetClusterRequest) Equal(that interface{}) bool
func (*GetClusterRequest) GetID ¶
func (m *GetClusterRequest) GetID() *uuidpb.UUID
func (*GetClusterRequest) GoString ¶
func (this *GetClusterRequest) GoString() string
func (*GetClusterRequest) Marshal ¶
func (m *GetClusterRequest) Marshal() (dAtA []byte, err error)
func (*GetClusterRequest) MarshalTo ¶
func (m *GetClusterRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetClusterRequest) MarshalToSizedBuffer ¶
func (m *GetClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetClusterRequest) ProtoMessage ¶
func (*GetClusterRequest) ProtoMessage()
func (*GetClusterRequest) Reset ¶
func (m *GetClusterRequest) Reset()
func (*GetClusterRequest) Size ¶
func (m *GetClusterRequest) Size() (n int)
func (*GetClusterRequest) String ¶
func (this *GetClusterRequest) String() string
func (*GetClusterRequest) Unmarshal ¶
func (m *GetClusterRequest) Unmarshal(dAtA []byte) error
func (*GetClusterRequest) XXX_DiscardUnknown ¶
func (m *GetClusterRequest) XXX_DiscardUnknown()
func (*GetClusterRequest) XXX_Marshal ¶
func (m *GetClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetClusterRequest) XXX_Merge ¶
func (m *GetClusterRequest) XXX_Merge(src proto.Message)
func (*GetClusterRequest) XXX_Size ¶
func (m *GetClusterRequest) XXX_Size() int
func (*GetClusterRequest) XXX_Unmarshal ¶
func (m *GetClusterRequest) XXX_Unmarshal(b []byte) error
type GetClusterResponse ¶
type GetClusterResponse struct {
Clusters []*ClusterInfo `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
}
func (*GetClusterResponse) Descriptor ¶
func (*GetClusterResponse) Descriptor() ([]byte, []int)
func (*GetClusterResponse) Equal ¶
func (this *GetClusterResponse) Equal(that interface{}) bool
func (*GetClusterResponse) GetClusters ¶
func (m *GetClusterResponse) GetClusters() []*ClusterInfo
func (*GetClusterResponse) GoString ¶
func (this *GetClusterResponse) GoString() string
func (*GetClusterResponse) Marshal ¶
func (m *GetClusterResponse) Marshal() (dAtA []byte, err error)
func (*GetClusterResponse) MarshalTo ¶
func (m *GetClusterResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetClusterResponse) MarshalToSizedBuffer ¶
func (m *GetClusterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetClusterResponse) ProtoMessage ¶
func (*GetClusterResponse) ProtoMessage()
func (*GetClusterResponse) Reset ¶
func (m *GetClusterResponse) Reset()
func (*GetClusterResponse) Size ¶
func (m *GetClusterResponse) Size() (n int)
func (*GetClusterResponse) String ¶
func (this *GetClusterResponse) String() string
func (*GetClusterResponse) Unmarshal ¶
func (m *GetClusterResponse) Unmarshal(dAtA []byte) error
func (*GetClusterResponse) XXX_DiscardUnknown ¶
func (m *GetClusterResponse) XXX_DiscardUnknown()
func (*GetClusterResponse) XXX_Marshal ¶
func (m *GetClusterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetClusterResponse) XXX_Merge ¶
func (m *GetClusterResponse) XXX_Merge(src proto.Message)
func (*GetClusterResponse) XXX_Size ¶
func (m *GetClusterResponse) XXX_Size() int
func (*GetClusterResponse) XXX_Unmarshal ¶
func (m *GetClusterResponse) XXX_Unmarshal(b []byte) error
type UnimplementedClusterManagerServer ¶
type UnimplementedClusterManagerServer struct { }
UnimplementedClusterManagerServer can be embedded to have forward compatible implementations.
func (*UnimplementedClusterManagerServer) GetCluster ¶
func (*UnimplementedClusterManagerServer) GetCluster(ctx context.Context, req *GetClusterRequest) (*GetClusterResponse, error)
func (*UnimplementedClusterManagerServer) GetClusterConnection ¶
func (*UnimplementedClusterManagerServer) GetClusterConnection(ctx context.Context, req *GetClusterConnectionRequest) (*GetClusterConnectionResponse, error)
func (*UnimplementedClusterManagerServer) UpdateClusterConfig ¶
func (*UnimplementedClusterManagerServer) UpdateClusterConfig(ctx context.Context, req *UpdateClusterConfigRequest) (*UpdateClusterConfigResponse, error)
type UpdateClusterConfigRequest ¶
type UpdateClusterConfigRequest struct { ID *uuidpb.UUID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ConfigUpdate *ClusterConfigUpdate `protobuf:"bytes,2,opt,name=config_update,json=configUpdate,proto3" json:"config_update,omitempty"` }
func (*UpdateClusterConfigRequest) Descriptor ¶
func (*UpdateClusterConfigRequest) Descriptor() ([]byte, []int)
func (*UpdateClusterConfigRequest) Equal ¶
func (this *UpdateClusterConfigRequest) Equal(that interface{}) bool
func (*UpdateClusterConfigRequest) GetConfigUpdate ¶
func (m *UpdateClusterConfigRequest) GetConfigUpdate() *ClusterConfigUpdate
func (*UpdateClusterConfigRequest) GetID ¶
func (m *UpdateClusterConfigRequest) GetID() *uuidpb.UUID
func (*UpdateClusterConfigRequest) GoString ¶
func (this *UpdateClusterConfigRequest) GoString() string
func (*UpdateClusterConfigRequest) Marshal ¶
func (m *UpdateClusterConfigRequest) Marshal() (dAtA []byte, err error)
func (*UpdateClusterConfigRequest) MarshalTo ¶
func (m *UpdateClusterConfigRequest) MarshalTo(dAtA []byte) (int, error)
func (*UpdateClusterConfigRequest) MarshalToSizedBuffer ¶
func (m *UpdateClusterConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpdateClusterConfigRequest) ProtoMessage ¶
func (*UpdateClusterConfigRequest) ProtoMessage()
func (*UpdateClusterConfigRequest) Reset ¶
func (m *UpdateClusterConfigRequest) Reset()
func (*UpdateClusterConfigRequest) Size ¶
func (m *UpdateClusterConfigRequest) Size() (n int)
func (*UpdateClusterConfigRequest) String ¶
func (this *UpdateClusterConfigRequest) String() string
func (*UpdateClusterConfigRequest) Unmarshal ¶
func (m *UpdateClusterConfigRequest) Unmarshal(dAtA []byte) error
func (*UpdateClusterConfigRequest) XXX_DiscardUnknown ¶
func (m *UpdateClusterConfigRequest) XXX_DiscardUnknown()
func (*UpdateClusterConfigRequest) XXX_Marshal ¶
func (m *UpdateClusterConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateClusterConfigRequest) XXX_Merge ¶
func (m *UpdateClusterConfigRequest) XXX_Merge(src proto.Message)
func (*UpdateClusterConfigRequest) XXX_Size ¶
func (m *UpdateClusterConfigRequest) XXX_Size() int
func (*UpdateClusterConfigRequest) XXX_Unmarshal ¶
func (m *UpdateClusterConfigRequest) XXX_Unmarshal(b []byte) error
type UpdateClusterConfigResponse ¶
type UpdateClusterConfigResponse struct { }
func (*UpdateClusterConfigResponse) Descriptor ¶
func (*UpdateClusterConfigResponse) Descriptor() ([]byte, []int)
func (*UpdateClusterConfigResponse) Equal ¶
func (this *UpdateClusterConfigResponse) Equal(that interface{}) bool
func (*UpdateClusterConfigResponse) GoString ¶
func (this *UpdateClusterConfigResponse) GoString() string
func (*UpdateClusterConfigResponse) Marshal ¶
func (m *UpdateClusterConfigResponse) Marshal() (dAtA []byte, err error)
func (*UpdateClusterConfigResponse) MarshalTo ¶
func (m *UpdateClusterConfigResponse) MarshalTo(dAtA []byte) (int, error)
func (*UpdateClusterConfigResponse) MarshalToSizedBuffer ¶
func (m *UpdateClusterConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpdateClusterConfigResponse) ProtoMessage ¶
func (*UpdateClusterConfigResponse) ProtoMessage()
func (*UpdateClusterConfigResponse) Reset ¶
func (m *UpdateClusterConfigResponse) Reset()
func (*UpdateClusterConfigResponse) Size ¶
func (m *UpdateClusterConfigResponse) Size() (n int)
func (*UpdateClusterConfigResponse) String ¶
func (this *UpdateClusterConfigResponse) String() string
func (*UpdateClusterConfigResponse) Unmarshal ¶
func (m *UpdateClusterConfigResponse) Unmarshal(dAtA []byte) error
func (*UpdateClusterConfigResponse) XXX_DiscardUnknown ¶
func (m *UpdateClusterConfigResponse) XXX_DiscardUnknown()
func (*UpdateClusterConfigResponse) XXX_Marshal ¶
func (m *UpdateClusterConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateClusterConfigResponse) XXX_Merge ¶
func (m *UpdateClusterConfigResponse) XXX_Merge(src proto.Message)
func (*UpdateClusterConfigResponse) XXX_Size ¶
func (m *UpdateClusterConfigResponse) XXX_Size() int
func (*UpdateClusterConfigResponse) XXX_Unmarshal ¶
func (m *UpdateClusterConfigResponse) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.