pbgo

package
v0.0.5 Latest Latest
Warning

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

Go to latest
Published: Jun 4, 2021 License: MIT Imports: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Code_name = map[int32]string{
		0:  "OK_UNSPECIFIED",
		1:  "CANCELLED",
		2:  "UNKNOWN",
		3:  "INVALID_ARGUMENT",
		4:  "DEADLINE_EXCEEDED",
		5:  "NOT_FOUND",
		6:  "ALREADY_EXISTS",
		7:  "PERMISSION_DENIED",
		16: "UNAUTHENTICATED",
		8:  "RESOURCE_EXHAUSTED",
		9:  "FAILED_PRECONDITION",
		10: "ABORTED",
		11: "OUT_OF_RANGE",
		12: "UNIMPLEMENTED",
		13: "INTERNAL",
		14: "UNAVAILABLE",
	}
	Code_value = map[string]int32{
		"OK_UNSPECIFIED":      0,
		"CANCELLED":           1,
		"UNKNOWN":             2,
		"INVALID_ARGUMENT":    3,
		"DEADLINE_EXCEEDED":   4,
		"NOT_FOUND":           5,
		"ALREADY_EXISTS":      6,
		"PERMISSION_DENIED":   7,
		"UNAUTHENTICATED":     16,
		"RESOURCE_EXHAUSTED":  8,
		"FAILED_PRECONDITION": 9,
		"ABORTED":             10,
		"OUT_OF_RANGE":        11,
		"UNIMPLEMENTED":       12,
		"INTERNAL":            13,
		"UNAVAILABLE":         14,
	}
)

Enum value maps for Code.

View Source
var (
	AppGroupStatus_name = map[int32]string{
		0: "APP_GROUP_UNSPECIFIED",
		1: "APP_GROUP_INSTALLING",
		2: "APP_GROUP_RUNNING",
		4: "APP_GROUP_DELETING",
		5: "APP_GROUP_DELETED",
		6: "APP_GROUP_ERROR",
	}
	AppGroupStatus_value = map[string]int32{
		"APP_GROUP_UNSPECIFIED": 0,
		"APP_GROUP_INSTALLING":  1,
		"APP_GROUP_RUNNING":     2,
		"APP_GROUP_DELETING":    4,
		"APP_GROUP_DELETED":     5,
		"APP_GROUP_ERROR":       6,
	}
)

Enum value maps for AppGroupStatus.

View Source
var (
	ClusterStatus_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "INSTALLING",
		2: "RUNNING",
		4: "DELETING",
		5: "DELETED",
		6: "ERROR",
	}
	ClusterStatus_value = map[string]int32{
		"UNSPECIFIED": 0,
		"INSTALLING":  1,
		"RUNNING":     2,
		"DELETING":    4,
		"DELETED":     5,
		"ERROR":       6,
	}
)

Enum value maps for ClusterStatus.

View Source
var (
	AppType_name = map[int32]string{
		0:  "EP_UNSPECIFIED",
		1:  "THANOS",
		2:  "PROMETHEUS",
		3:  "GRAFANA",
		4:  "KIALI",
		5:  "KIBANA",
		6:  "ELASTICSERCH",
		7:  "CLOUD_CONSOLE",
		8:  "HORIZON",
		9:  "JAEGER",
		10: "KUBERNETES_DASHBOARD",
	}
	AppType_value = map[string]int32{
		"EP_UNSPECIFIED":       0,
		"THANOS":               1,
		"PROMETHEUS":           2,
		"GRAFANA":              3,
		"KIALI":                4,
		"KIBANA":               5,
		"ELASTICSERCH":         6,
		"CLOUD_CONSOLE":        7,
		"HORIZON":              8,
		"JAEGER":               9,
		"KUBERNETES_DASHBOARD": 10,
	}
)

Enum value maps for AppType.

View Source
var (
	AppGroupType_name = map[int32]string{
		0: "APP_TYPE_UNSPECIFIED",
		1: "LMA",
		2: "SERVICE_MESH",
	}
	AppGroupType_value = map[string]int32{
		"APP_TYPE_UNSPECIFIED": 0,
		"LMA":                  1,
		"SERVICE_MESH":         2,
	}
)

Enum value maps for AppGroupType.

View Source
var AppInfoService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pbgo.AppInfoService",
	HandlerType: (*AppInfoServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateAppGroup",
			Handler:    _AppInfoService_CreateAppGroup_Handler,
		},
		{
			MethodName: "GetAppGroupsByClusterID",
			Handler:    _AppInfoService_GetAppGroupsByClusterID_Handler,
		},
		{
			MethodName: "GetAppGroups",
			Handler:    _AppInfoService_GetAppGroups_Handler,
		},
		{
			MethodName: "GetAppGroup",
			Handler:    _AppInfoService_GetAppGroup_Handler,
		},
		{
			MethodName: "UpdateAppGroupStatus",
			Handler:    _AppInfoService_UpdateAppGroupStatus_Handler,
		},
		{
			MethodName: "DeleteAppGroup",
			Handler:    _AppInfoService_DeleteAppGroup_Handler,
		},
		{
			MethodName: "GetAppsByAppGroupID",
			Handler:    _AppInfoService_GetAppsByAppGroupID_Handler,
		},
		{
			MethodName: "GetApps",
			Handler:    _AppInfoService_GetApps_Handler,
		},
		{
			MethodName: "UpdateApp",
			Handler:    _AppInfoService_UpdateApp_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "info.proto",
}

AppInfoService_ServiceDesc is the grpc.ServiceDesc for AppInfoService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var ClusterLcmService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pbgo.ClusterLcmService",
	HandlerType: (*ClusterLcmServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCluster",
			Handler:    _ClusterLcmService_CreateCluster_Handler,
		},
		{
			MethodName: "ScaleCluster",
			Handler:    _ClusterLcmService_ScaleCluster_Handler,
		},
		{
			MethodName: "InstallAppGroups",
			Handler:    _ClusterLcmService_InstallAppGroups_Handler,
		},
		{
			MethodName: "UninstallAppGroups",
			Handler:    _ClusterLcmService_UninstallAppGroups_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cluster_lcm.proto",
}

ClusterLcmService_ServiceDesc is the grpc.ServiceDesc for ClusterLcmService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var ContractService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pbgo.ContractService",
	HandlerType: (*ContractServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateContract",
			Handler:    _ContractService_CreateContract_Handler,
		},
		{
			MethodName: "UpdateQuota",
			Handler:    _ContractService_UpdateQuota_Handler,
		},
		{
			MethodName: "UpdateServices",
			Handler:    _ContractService_UpdateServices_Handler,
		},
		{
			MethodName: "GetContract",
			Handler:    _ContractService_GetContract_Handler,
		},
		{
			MethodName: "GetContracts",
			Handler:    _ContractService_GetContracts_Handler,
		},
		{
			MethodName: "GetQuota",
			Handler:    _ContractService_GetQuota_Handler,
		},
		{
			MethodName: "GetAvailableServices",
			Handler:    _ContractService_GetAvailableServices_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "contract.proto",
}

ContractService_ServiceDesc is the grpc.ServiceDesc for ContractService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_cluster_lcm_proto protoreflect.FileDescriptor
View Source
var File_common_proto protoreflect.FileDescriptor
View Source
var File_contract_proto protoreflect.FileDescriptor
View Source
var InfoService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pbgo.InfoService",
	HandlerType: (*InfoServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCSPInfo",
			Handler:    _InfoService_CreateCSPInfo_Handler,
		},
		{
			MethodName: "GetCSPIDs",
			Handler:    _InfoService_GetCSPIDs_Handler,
		},
		{
			MethodName: "GetCSPIDsByContractID",
			Handler:    _InfoService_GetCSPIDsByContractID_Handler,
		},
		{
			MethodName: "UpdateCSPInfo",
			Handler:    _InfoService_UpdateCSPInfo_Handler,
		},
		{
			MethodName: "GetCSPAuth",
			Handler:    _InfoService_GetCSPAuth_Handler,
		},
		{
			MethodName: "AddClusterInfo",
			Handler:    _InfoService_AddClusterInfo_Handler,
		},
		{
			MethodName: "UpdateClusterConf",
			Handler:    _InfoService_UpdateClusterConf_Handler,
		},
		{
			MethodName: "GetCluster",
			Handler:    _InfoService_GetCluster_Handler,
		},
		{
			MethodName: "GetClusters",
			Handler:    _InfoService_GetClusters_Handler,
		},
		{
			MethodName: "UpdateClusterStatus",
			Handler:    _InfoService_UpdateClusterStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "info.proto",
}

InfoService_ServiceDesc is the grpc.ServiceDesc for InfoService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAppInfoServiceServer added in v0.0.4

func RegisterAppInfoServiceServer(s grpc.ServiceRegistrar, srv AppInfoServiceServer)

func RegisterClusterLcmServiceServer added in v0.0.5

func RegisterClusterLcmServiceServer(s grpc.ServiceRegistrar, srv ClusterLcmServiceServer)

func RegisterContractServiceServer

func RegisterContractServiceServer(s grpc.ServiceRegistrar, srv ContractServiceServer)

func RegisterInfoServiceServer added in v0.0.3

func RegisterInfoServiceServer(s grpc.ServiceRegistrar, srv InfoServiceServer)

Types

type AddClusterInfoRequest added in v0.0.5

type AddClusterInfoRequest struct {

	// contract_id is a contract ID.
	ContractId string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// csp_id is an ID of CSPInfo.
	CspId string `protobuf:"bytes,2,opt,name=csp_id,json=cspId,proto3" json:"csp_id,omitempty"`
	// cluster_name is a cluster name defined by users
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// conf is a cluster configuration
	Conf *ClusterConf `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

AddClusterInfoRequest is used to add a new cluster info

func (*AddClusterInfoRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use AddClusterInfoRequest.ProtoReflect.Descriptor instead.

func (*AddClusterInfoRequest) GetConf added in v0.0.5

func (x *AddClusterInfoRequest) GetConf() *ClusterConf

func (*AddClusterInfoRequest) GetContractId added in v0.0.5

func (x *AddClusterInfoRequest) GetContractId() string

func (*AddClusterInfoRequest) GetCspId added in v0.0.5

func (x *AddClusterInfoRequest) GetCspId() string

func (*AddClusterInfoRequest) GetName added in v0.0.5

func (x *AddClusterInfoRequest) GetName() string

func (*AddClusterInfoRequest) ProtoMessage added in v0.0.5

func (*AddClusterInfoRequest) ProtoMessage()

func (*AddClusterInfoRequest) ProtoReflect added in v0.0.5

func (x *AddClusterInfoRequest) ProtoReflect() protoreflect.Message

func (*AddClusterInfoRequest) Reset added in v0.0.5

func (x *AddClusterInfoRequest) Reset()

func (*AddClusterInfoRequest) String added in v0.0.5

func (x *AddClusterInfoRequest) String() string

type AppGroup added in v0.0.5

type AppGroup struct {

	// app_group_id for the application group
	AppGroupId string `protobuf:"bytes,1,opt,name=app_group_id,json=appGroupId,proto3" json:"app_group_id,omitempty"`
	// app_group_name is a human-readable name.
	AppGroupName string `protobuf:"bytes,2,opt,name=app_group_name,json=appGroupName,proto3" json:"app_group_name,omitempty"`
	// type (LMA/SERVICE_MESH)
	Type AppGroupType `protobuf:"varint,3,opt,name=type,proto3,enum=pbgo.AppGroupType" json:"type,omitempty"`
	// cluster_id is a cluster ID to install application.
	ClusterId string `protobuf:"bytes,4,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// a status of the application eg) Installing/Running/Error
	Status AppGroupStatus `protobuf:"varint,5,opt,name=status,proto3,enum=pbgo.AppGroupStatus" json:"status,omitempty"`
	// external_lable is the label used for globally unique identification
	ExternalLabel string `protobuf:"bytes,6,opt,name=external_label,json=externalLabel,proto3" json:"external_label,omitempty"`
	// created_at is  a creatioin timestamp for the application
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// updated_at is a timestamp for the trigger of status change
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

AppGroup represents an application group such as LMA, ServiceMesh.

func (*AppGroup) Descriptor deprecated added in v0.0.5

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

Deprecated: Use AppGroup.ProtoReflect.Descriptor instead.

func (*AppGroup) GetAppGroupId added in v0.0.5

func (x *AppGroup) GetAppGroupId() string

func (*AppGroup) GetAppGroupName added in v0.0.5

func (x *AppGroup) GetAppGroupName() string

func (*AppGroup) GetClusterId added in v0.0.5

func (x *AppGroup) GetClusterId() string

func (*AppGroup) GetCreatedAt added in v0.0.5

func (x *AppGroup) GetCreatedAt() *timestamppb.Timestamp

func (*AppGroup) GetExternalLabel added in v0.0.5

func (x *AppGroup) GetExternalLabel() string

func (*AppGroup) GetStatus added in v0.0.5

func (x *AppGroup) GetStatus() AppGroupStatus

func (*AppGroup) GetType added in v0.0.5

func (x *AppGroup) GetType() AppGroupType

func (*AppGroup) GetUpdatedAt added in v0.0.5

func (x *AppGroup) GetUpdatedAt() *timestamppb.Timestamp

func (*AppGroup) ProtoMessage added in v0.0.5

func (*AppGroup) ProtoMessage()

func (*AppGroup) ProtoReflect added in v0.0.5

func (x *AppGroup) ProtoReflect() protoreflect.Message

func (*AppGroup) Reset added in v0.0.5

func (x *AppGroup) Reset()

func (*AppGroup) String added in v0.0.5

func (x *AppGroup) String() string

type AppGroupStatus added in v0.0.5

type AppGroupStatus int32

AppGroupStatus represents a status of the application group

const (
	AppGroupStatus_APP_GROUP_UNSPECIFIED AppGroupStatus = 0
	AppGroupStatus_APP_GROUP_INSTALLING  AppGroupStatus = 1
	AppGroupStatus_APP_GROUP_RUNNING     AppGroupStatus = 2
	AppGroupStatus_APP_GROUP_DELETING    AppGroupStatus = 4
	AppGroupStatus_APP_GROUP_DELETED     AppGroupStatus = 5
	AppGroupStatus_APP_GROUP_ERROR       AppGroupStatus = 6
)

func (AppGroupStatus) Descriptor added in v0.0.5

func (AppGroupStatus) Enum added in v0.0.5

func (x AppGroupStatus) Enum() *AppGroupStatus

func (AppGroupStatus) EnumDescriptor deprecated added in v0.0.5

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

Deprecated: Use AppGroupStatus.Descriptor instead.

func (AppGroupStatus) Number added in v0.0.5

func (AppGroupStatus) String added in v0.0.5

func (x AppGroupStatus) String() string

func (AppGroupStatus) Type added in v0.0.5

type AppGroupType added in v0.0.5

type AppGroupType int32

AppGroupType is types of app group

const (
	AppGroupType_APP_TYPE_UNSPECIFIED AppGroupType = 0
	AppGroupType_LMA                  AppGroupType = 1
	AppGroupType_SERVICE_MESH         AppGroupType = 2
)

func (AppGroupType) Descriptor added in v0.0.5

func (AppGroupType) Enum added in v0.0.5

func (x AppGroupType) Enum() *AppGroupType

func (AppGroupType) EnumDescriptor deprecated added in v0.0.5

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

Deprecated: Use AppGroupType.Descriptor instead.

func (AppGroupType) Number added in v0.0.5

func (AppGroupType) String added in v0.0.5

func (x AppGroupType) String() string

func (AppGroupType) Type added in v0.0.5

type AppInfoServiceClient added in v0.0.4

type AppInfoServiceClient interface {
	// CreateAppGroup creates a new application group.
	CreateAppGroup(ctx context.Context, in *CreateAppGroupRequest, opts ...grpc.CallOption) (*IDResponse, error)
	// GetAppGroupsByClusterID gets an array of app infos By the clusterID
	GetAppGroupsByClusterID(ctx context.Context, in *IDRequest, opts ...grpc.CallOption) (*GetAppGroupsResponse, error)
	// GetAppGroups gets an array of app infos by name & type in the cluster
	GetAppGroups(ctx context.Context, in *GetAppGroupsRequest, opts ...grpc.CallOption) (*GetAppGroupsResponse, error)
	// GetAppGroup gets an application group by application group ID
	GetAppGroup(ctx context.Context, in *GetAppGroupRequest, opts ...grpc.CallOption) (*GetAppGroupResponse, error)
	// UpdateAppGroupStatus updates a status of an application group
	UpdateAppGroupStatus(ctx context.Context, in *UpdateAppGroupStatusRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
	// DeleteAppGroup deletes an app group.
	DeleteAppGroup(ctx context.Context, in *DeleteAppGroupRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
	// GetAppsByClusterID gets applications by application group id.
	GetAppsByAppGroupID(ctx context.Context, in *IDRequest, opts ...grpc.CallOption) (*GetAppsResponse, error)
	// GetApps gets applications by application type and application id.
	GetApps(ctx context.Context, in *GetAppsRequest, opts ...grpc.CallOption) (*GetAppsResponse, error)
	// UpdateApp updates application data.
	UpdateApp(ctx context.Context, in *UpdateAppRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
}

AppInfoServiceClient is the client API for AppInfoService 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 NewAppInfoServiceClient added in v0.0.4

func NewAppInfoServiceClient(cc grpc.ClientConnInterface) AppInfoServiceClient

type AppInfoServiceServer added in v0.0.4

type AppInfoServiceServer interface {
	// CreateAppGroup creates a new application group.
	CreateAppGroup(context.Context, *CreateAppGroupRequest) (*IDResponse, error)
	// GetAppGroupsByClusterID gets an array of app infos By the clusterID
	GetAppGroupsByClusterID(context.Context, *IDRequest) (*GetAppGroupsResponse, error)
	// GetAppGroups gets an array of app infos by name & type in the cluster
	GetAppGroups(context.Context, *GetAppGroupsRequest) (*GetAppGroupsResponse, error)
	// GetAppGroup gets an application group by application group ID
	GetAppGroup(context.Context, *GetAppGroupRequest) (*GetAppGroupResponse, error)
	// UpdateAppGroupStatus updates a status of an application group
	UpdateAppGroupStatus(context.Context, *UpdateAppGroupStatusRequest) (*SimpleResponse, error)
	// DeleteAppGroup deletes an app group.
	DeleteAppGroup(context.Context, *DeleteAppGroupRequest) (*SimpleResponse, error)
	// GetAppsByClusterID gets applications by application group id.
	GetAppsByAppGroupID(context.Context, *IDRequest) (*GetAppsResponse, error)
	// GetApps gets applications by application type and application id.
	GetApps(context.Context, *GetAppsRequest) (*GetAppsResponse, error)
	// UpdateApp updates application data.
	UpdateApp(context.Context, *UpdateAppRequest) (*SimpleResponse, error)
	// contains filtered or unexported methods
}

AppInfoServiceServer is the server API for AppInfoService service. All implementations must embed UnimplementedAppInfoServiceServer for forward compatibility

type AppType added in v0.0.5

type AppType int32

AppType is a type of application.

const (
	AppType_EP_UNSPECIFIED       AppType = 0
	AppType_THANOS               AppType = 1
	AppType_PROMETHEUS           AppType = 2
	AppType_GRAFANA              AppType = 3
	AppType_KIALI                AppType = 4
	AppType_KIBANA               AppType = 5
	AppType_ELASTICSERCH         AppType = 6
	AppType_CLOUD_CONSOLE        AppType = 7
	AppType_HORIZON              AppType = 8
	AppType_JAEGER               AppType = 9
	AppType_KUBERNETES_DASHBOARD AppType = 10
)

func (AppType) Descriptor added in v0.0.5

func (AppType) Descriptor() protoreflect.EnumDescriptor

func (AppType) Enum added in v0.0.5

func (x AppType) Enum() *AppType

func (AppType) EnumDescriptor deprecated added in v0.0.5

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

Deprecated: Use AppType.Descriptor instead.

func (AppType) Number added in v0.0.5

func (x AppType) Number() protoreflect.EnumNumber

func (AppType) String added in v0.0.5

func (x AppType) String() string

func (AppType) Type added in v0.0.5

func (AppType) Type() protoreflect.EnumType

type Application added in v0.0.5

type Application struct {

	//id for the application
	AppId string `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	// type (Prometheus/Grafana/...)
	Type AppType `protobuf:"varint,2,opt,name=type,proto3,enum=pbgo.AppType" json:"type,omitempty"`
	// app_group_id is an applicagion group ID.
	AppGroupId string `protobuf:"bytes,3,opt,name=app_group_id,json=appGroupId,proto3" json:"app_group_id,omitempty"`
	// endpoint is a endpoint string.
	Endpoint string `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// metadata is a unstructured information for application.
	Metadata string `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// created_at is  a creatioin timestamp for the application
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// updated_at is a timestamp for the trigger of status change
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Application represents each Application.

func (*Application) Descriptor deprecated added in v0.0.5

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

Deprecated: Use Application.ProtoReflect.Descriptor instead.

func (*Application) GetAppGroupId added in v0.0.5

func (x *Application) GetAppGroupId() string

func (*Application) GetAppId added in v0.0.5

func (x *Application) GetAppId() string

func (*Application) GetCreatedAt added in v0.0.5

func (x *Application) GetCreatedAt() *timestamppb.Timestamp

func (*Application) GetEndpoint added in v0.0.5

func (x *Application) GetEndpoint() string

func (*Application) GetMetadata added in v0.0.5

func (x *Application) GetMetadata() string

func (*Application) GetType added in v0.0.5

func (x *Application) GetType() AppType

func (*Application) GetUpdatedAt added in v0.0.5

func (x *Application) GetUpdatedAt() *timestamppb.Timestamp

func (*Application) ProtoMessage added in v0.0.5

func (*Application) ProtoMessage()

func (*Application) ProtoReflect added in v0.0.5

func (x *Application) ProtoReflect() protoreflect.Message

func (*Application) Reset added in v0.0.5

func (x *Application) Reset()

func (*Application) String added in v0.0.5

func (x *Application) String() string

type Cluster added in v0.0.3

type Cluster struct {

	// is is a unique id for the cluster
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// name is a cluster name for users
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// created_at is a creatioin timestamp for the cluster
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// updated_at is a timestamp for the trigger of status change
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// status is a status of the cluste eg) Installing/Running/Error
	Status ClusterStatus `protobuf:"varint,5,opt,name=status,proto3,enum=pbgo.ClusterStatus" json:"status,omitempty"`
	// contract_id is a contract ID.
	ContractId string `protobuf:"bytes,6,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// csp_id is an ID of CSPInfo.
	CspId string `protobuf:"bytes,7,opt,name=csp_id,json=cspId,proto3" json:"csp_id,omitempty"`
	// conf is a kubernete cluster configuration
	Conf *ClusterConf `protobuf:"bytes,8,opt,name=conf,proto3" json:"conf,omitempty"`
	// app_groups is a array of applications
	AppGroups []*AppGroup `protobuf:"bytes,9,rep,name=app_groups,json=appGroups,proto3" json:"app_groups,omitempty"`
	// kubeconfig is a default kubeconfig for the cluster
	Kubeconfig string `protobuf:"bytes,10,opt,name=kubeconfig,proto3" json:"kubeconfig,omitempty"`
	// contains filtered or unexported fields
}

Cluster represents each Cluster.

func (*Cluster) Descriptor deprecated added in v0.0.3

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetAppGroups added in v0.0.5

func (x *Cluster) GetAppGroups() []*AppGroup

func (*Cluster) GetConf added in v0.0.5

func (x *Cluster) GetConf() *ClusterConf

func (*Cluster) GetContractId added in v0.0.5

func (x *Cluster) GetContractId() string

func (*Cluster) GetCreatedAt added in v0.0.5

func (x *Cluster) GetCreatedAt() *timestamppb.Timestamp

func (*Cluster) GetCspId added in v0.0.5

func (x *Cluster) GetCspId() string

func (*Cluster) GetId added in v0.0.3

func (x *Cluster) GetId() string

func (*Cluster) GetKubeconfig added in v0.0.3

func (x *Cluster) GetKubeconfig() string

func (*Cluster) GetName added in v0.0.3

func (x *Cluster) GetName() string

func (*Cluster) GetStatus added in v0.0.3

func (x *Cluster) GetStatus() ClusterStatus

func (*Cluster) GetUpdatedAt added in v0.0.5

func (x *Cluster) GetUpdatedAt() *timestamppb.Timestamp

func (*Cluster) ProtoMessage added in v0.0.3

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect added in v0.0.3

func (x *Cluster) ProtoReflect() protoreflect.Message

func (*Cluster) Reset added in v0.0.3

func (x *Cluster) Reset()

func (*Cluster) String added in v0.0.3

func (x *Cluster) String() string

type ClusterConf added in v0.0.5

type ClusterConf struct {

	// master_flavor is a machine node spec flavor for the master nodes
	MasterFlavor string `protobuf:"bytes,1,opt,name=master_flavor,json=masterFlavor,proto3" json:"master_flavor,omitempty"`
	// master_replicas is a number of the master nodes
	MasterReplicas int32 `protobuf:"varint,2,opt,name=master_replicas,json=masterReplicas,proto3" json:"master_replicas,omitempty"`
	// master_root_size is a root volume size of the master nodes
	MasterRootSize int64 `protobuf:"varint,3,opt,name=master_root_size,json=masterRootSize,proto3" json:"master_root_size,omitempty"`
	// worker_flavor is a machine node spec flavor for the worker nodes
	WorkerFlavor string `protobuf:"bytes,4,opt,name=worker_flavor,json=workerFlavor,proto3" json:"worker_flavor,omitempty"`
	// worker_replicas is a number of the worker nodes
	WorkerReplicas int32 `protobuf:"varint,5,opt,name=worker_replicas,json=workerReplicas,proto3" json:"worker_replicas,omitempty"`
	// worker_root_size is a root volume size of the worker nodes
	WorkerRootSize int64 `protobuf:"varint,6,opt,name=worker_root_size,json=workerRootSize,proto3" json:"worker_root_size,omitempty"`
	// k8s_version is a kubernetes version for the cluster
	K8SVersion string `protobuf:"bytes,7,opt,name=k8s_version,json=k8sVersion,proto3" json:"k8s_version,omitempty"`
	// contains filtered or unexported fields
}

ClusterConf represents a Kubernetes cluster configuration.

func (*ClusterConf) Descriptor deprecated added in v0.0.5

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

Deprecated: Use ClusterConf.ProtoReflect.Descriptor instead.

func (*ClusterConf) GetK8SVersion added in v0.0.5

func (x *ClusterConf) GetK8SVersion() string

func (*ClusterConf) GetMasterFlavor added in v0.0.5

func (x *ClusterConf) GetMasterFlavor() string

func (*ClusterConf) GetMasterReplicas added in v0.0.5

func (x *ClusterConf) GetMasterReplicas() int32

func (*ClusterConf) GetMasterRootSize added in v0.0.5

func (x *ClusterConf) GetMasterRootSize() int64

func (*ClusterConf) GetWorkerFlavor added in v0.0.5

func (x *ClusterConf) GetWorkerFlavor() string

func (*ClusterConf) GetWorkerReplicas added in v0.0.5

func (x *ClusterConf) GetWorkerReplicas() int32

func (*ClusterConf) GetWorkerRootSize added in v0.0.5

func (x *ClusterConf) GetWorkerRootSize() int64

func (*ClusterConf) ProtoMessage added in v0.0.5

func (*ClusterConf) ProtoMessage()

func (*ClusterConf) ProtoReflect added in v0.0.5

func (x *ClusterConf) ProtoReflect() protoreflect.Message

func (*ClusterConf) Reset added in v0.0.5

func (x *ClusterConf) Reset()

func (*ClusterConf) String added in v0.0.5

func (x *ClusterConf) String() string

type ClusterLcmServiceClient added in v0.0.5

type ClusterLcmServiceClient interface {
	// CreateCluster creates a Kubernetes cluster and returns cluster id
	CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*IDsResponse, error)
	// ScaleCluster scales the Kubernetes cluster
	ScaleCluster(ctx context.Context, in *ScaleClusterRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
	// InstallAppGroups install app groups, return a array of app group id
	InstallAppGroups(ctx context.Context, in *InstallAppGroupsRequest, opts ...grpc.CallOption) (*IDsResponse, error)
	// UninstallAppGroups uninstall app groups.
	UninstallAppGroups(ctx context.Context, in *UninstallAppGroupsRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
}

ClusterLcmServiceClient is the client API for ClusterLcmService 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 NewClusterLcmServiceClient added in v0.0.5

func NewClusterLcmServiceClient(cc grpc.ClientConnInterface) ClusterLcmServiceClient

type ClusterLcmServiceServer added in v0.0.5

type ClusterLcmServiceServer interface {
	// CreateCluster creates a Kubernetes cluster and returns cluster id
	CreateCluster(context.Context, *CreateClusterRequest) (*IDsResponse, error)
	// ScaleCluster scales the Kubernetes cluster
	ScaleCluster(context.Context, *ScaleClusterRequest) (*SimpleResponse, error)
	// InstallAppGroups install app groups, return a array of app group id
	InstallAppGroups(context.Context, *InstallAppGroupsRequest) (*IDsResponse, error)
	// UninstallAppGroups uninstall app groups.
	UninstallAppGroups(context.Context, *UninstallAppGroupsRequest) (*SimpleResponse, error)
	// contains filtered or unexported methods
}

ClusterLcmServiceServer is the server API for ClusterLcmService service. All implementations must embed UnimplementedClusterLcmServiceServer for forward compatibility

type ClusterStatus added in v0.0.3

type ClusterStatus int32

ClusterStatus represents a status of the cluster

const (
	ClusterStatus_UNSPECIFIED ClusterStatus = 0
	ClusterStatus_INSTALLING  ClusterStatus = 1
	ClusterStatus_RUNNING     ClusterStatus = 2
	ClusterStatus_DELETING    ClusterStatus = 4
	ClusterStatus_DELETED     ClusterStatus = 5
	ClusterStatus_ERROR       ClusterStatus = 6
)

func (ClusterStatus) Descriptor added in v0.0.3

func (ClusterStatus) Enum added in v0.0.3

func (x ClusterStatus) Enum() *ClusterStatus

func (ClusterStatus) EnumDescriptor deprecated added in v0.0.3

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

Deprecated: Use ClusterStatus.Descriptor instead.

func (ClusterStatus) Number added in v0.0.3

func (ClusterStatus) String added in v0.0.3

func (x ClusterStatus) String() string

func (ClusterStatus) Type added in v0.0.3

type Code

type Code int32

Code is a response code for gRpc request.

const (
	Code_OK_UNSPECIFIED      Code = 0
	Code_CANCELLED           Code = 1
	Code_UNKNOWN             Code = 2
	Code_INVALID_ARGUMENT    Code = 3
	Code_DEADLINE_EXCEEDED   Code = 4
	Code_NOT_FOUND           Code = 5
	Code_ALREADY_EXISTS      Code = 6
	Code_PERMISSION_DENIED   Code = 7
	Code_UNAUTHENTICATED     Code = 16
	Code_RESOURCE_EXHAUSTED  Code = 8
	Code_FAILED_PRECONDITION Code = 9
	Code_ABORTED             Code = 10
	Code_OUT_OF_RANGE        Code = 11
	Code_UNIMPLEMENTED       Code = 12
	Code_INTERNAL            Code = 13
	Code_UNAVAILABLE         Code = 14
)

func (Code) Descriptor

func (Code) Descriptor() protoreflect.EnumDescriptor

func (Code) Enum

func (x Code) Enum() *Code

func (Code) EnumDescriptor deprecated

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

Deprecated: Use Code.Descriptor instead.

func (Code) Number

func (x Code) Number() protoreflect.EnumNumber

func (Code) String

func (x Code) String() string

func (Code) Type

func (Code) Type() protoreflect.EnumType

type Contract added in v0.0.5

type Contract struct {

	// contractor_name is a name of contractor
	ContractorName string `protobuf:"bytes,1,opt,name=contractor_name,json=contractorName,proto3" json:"contractor_name,omitempty"`
	// contract_id is a global unique ID created by CBP
	ContractId string `protobuf:"bytes,2,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// quota is a resource quota for cpu, memory, storage and so on.
	Quota *ContractQuota `protobuf:"bytes,3,opt,name=quota,proto3" json:"quota,omitempty"`
	// availavle_services is a list of services constomer purchased.
	AvailableServices []string `protobuf:"bytes,4,rep,name=available_services,json=availableServices,proto3" json:"available_services,omitempty"`
	// csp_id is a global unique ID created by the info service.
	CspId string `protobuf:"bytes,5,opt,name=csp_id,json=cspId,proto3" json:"csp_id,omitempty"`
	// updated_at is a timestamp last updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// created_at is a timestamp created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

Contract is a contract information.

func (*Contract) Descriptor deprecated added in v0.0.5

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

Deprecated: Use Contract.ProtoReflect.Descriptor instead.

func (*Contract) GetAvailableServices added in v0.0.5

func (x *Contract) GetAvailableServices() []string

func (*Contract) GetContractId added in v0.0.5

func (x *Contract) GetContractId() string

func (*Contract) GetContractorName added in v0.0.5

func (x *Contract) GetContractorName() string

func (*Contract) GetCreatedAt added in v0.0.5

func (x *Contract) GetCreatedAt() *timestamppb.Timestamp

func (*Contract) GetCspId added in v0.0.5

func (x *Contract) GetCspId() string

func (*Contract) GetQuota added in v0.0.5

func (x *Contract) GetQuota() *ContractQuota

func (*Contract) GetUpdatedAt added in v0.0.5

func (x *Contract) GetUpdatedAt() *timestamppb.Timestamp

func (*Contract) ProtoMessage added in v0.0.5

func (*Contract) ProtoMessage()

func (*Contract) ProtoReflect added in v0.0.5

func (x *Contract) ProtoReflect() protoreflect.Message

func (*Contract) Reset added in v0.0.5

func (x *Contract) Reset()

func (*Contract) String added in v0.0.5

func (x *Contract) String() string

type ContractQuota

type ContractQuota struct {

	// cpu unit(GB) from 10 to 10000
	Cpu int64 `protobuf:"zigzag64,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// memory unit(MB) from 40 to 40000
	Memory int64 `protobuf:"zigzag64,2,opt,name=memory,proto3" json:"memory,omitempty"`
	// block storage(MB) from 0 to 256000000
	Block int64 `protobuf:"zigzag64,3,opt,name=block,proto3" json:"block,omitempty"`
	// // block ssd storage(MB) from 0 to 256000000
	BlockSsd int64 `protobuf:"zigzag64,4,opt,name=block_ssd,json=blockSsd,proto3" json:"block_ssd,omitempty"`
	// filesystem (MB) from 0 to 256000000
	Fs int64 `protobuf:"zigzag64,5,opt,name=fs,proto3" json:"fs,omitempty"`
	// SSD filesystem (MB) from 0 to 256000000
	FsSsd int64 `protobuf:"zigzag64,6,opt,name=fs_ssd,json=fsSsd,proto3" json:"fs_ssd,omitempty"`
	// contains filtered or unexported fields
}

ContractQuota is a resource quota for total usage in clusters.

func (*ContractQuota) Descriptor deprecated

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

Deprecated: Use ContractQuota.ProtoReflect.Descriptor instead.

func (*ContractQuota) GetBlock

func (x *ContractQuota) GetBlock() int64

func (*ContractQuota) GetBlockSsd

func (x *ContractQuota) GetBlockSsd() int64

func (*ContractQuota) GetCpu

func (x *ContractQuota) GetCpu() int64

func (*ContractQuota) GetFs

func (x *ContractQuota) GetFs() int64

func (*ContractQuota) GetFsSsd

func (x *ContractQuota) GetFsSsd() int64

func (*ContractQuota) GetMemory

func (x *ContractQuota) GetMemory() int64

func (*ContractQuota) ProtoMessage

func (*ContractQuota) ProtoMessage()

func (*ContractQuota) ProtoReflect

func (x *ContractQuota) ProtoReflect() protoreflect.Message

func (*ContractQuota) Reset

func (x *ContractQuota) Reset()

func (*ContractQuota) String

func (x *ContractQuota) String() string

type ContractServiceClient

type ContractServiceClient interface {
	// CreateContract creates new contract.
	CreateContract(ctx context.Context, in *CreateContractRequest, opts ...grpc.CallOption) (*CreateContractResponse, error)
	// UpdateQuota updates quota of the contract.
	UpdateQuota(ctx context.Context, in *UpdateQuotaRequest, opts ...grpc.CallOption) (*UpdateQuotaResponse, error)
	// UpdateServices updates list of available services of the contract.
	UpdateServices(ctx context.Context, in *UpdateServicesRequest, opts ...grpc.CallOption) (*UpdateServicesResponse, error)
	// GetContract returns a contract if exists.
	GetContract(ctx context.Context, in *GetContractRequest, opts ...grpc.CallOption) (*GetContractResponse, error)
	// Getcontracts return a list of contract.
	GetContracts(ctx context.Context, in *GetContractsRequest, opts ...grpc.CallOption) (*GetContractsResponse, error)
	// GetQuota returns a quota for the contract.
	GetQuota(ctx context.Context, in *GetQuotaRequest, opts ...grpc.CallOption) (*GetQuotaResponse, error)
	// GetAvailableServices returns list of available services for the contract.
	GetAvailableServices(ctx context.Context, in *GetAvailableServicesRequest, opts ...grpc.CallOption) (*GetAvailableServicesResponse, error)
}

ContractServiceClient is the client API for ContractService 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.

type ContractServiceServer

type ContractServiceServer interface {
	// CreateContract creates new contract.
	CreateContract(context.Context, *CreateContractRequest) (*CreateContractResponse, error)
	// UpdateQuota updates quota of the contract.
	UpdateQuota(context.Context, *UpdateQuotaRequest) (*UpdateQuotaResponse, error)
	// UpdateServices updates list of available services of the contract.
	UpdateServices(context.Context, *UpdateServicesRequest) (*UpdateServicesResponse, error)
	// GetContract returns a contract if exists.
	GetContract(context.Context, *GetContractRequest) (*GetContractResponse, error)
	// Getcontracts return a list of contract.
	GetContracts(context.Context, *GetContractsRequest) (*GetContractsResponse, error)
	// GetQuota returns a quota for the contract.
	GetQuota(context.Context, *GetQuotaRequest) (*GetQuotaResponse, error)
	// GetAvailableServices returns list of available services for the contract.
	GetAvailableServices(context.Context, *GetAvailableServicesRequest) (*GetAvailableServicesResponse, error)
	// contains filtered or unexported methods
}

ContractServiceServer is the server API for ContractService service. All implementations must embed UnimplementedContractServiceServer for forward compatibility

type CreateAppGroupRequest added in v0.0.5

type CreateAppGroupRequest struct {

	// cluster_id is a cluster ID
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// app_group is an application group
	AppGroup *AppGroup `protobuf:"bytes,2,opt,name=app_group,json=appGroup,proto3" json:"app_group,omitempty"`
	// contains filtered or unexported fields
}

CreateAppGroupRequest is used to create a new app group.

func (*CreateAppGroupRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use CreateAppGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateAppGroupRequest) GetAppGroup added in v0.0.5

func (x *CreateAppGroupRequest) GetAppGroup() *AppGroup

func (*CreateAppGroupRequest) GetClusterId added in v0.0.5

func (x *CreateAppGroupRequest) GetClusterId() string

func (*CreateAppGroupRequest) ProtoMessage added in v0.0.5

func (*CreateAppGroupRequest) ProtoMessage()

func (*CreateAppGroupRequest) ProtoReflect added in v0.0.5

func (x *CreateAppGroupRequest) ProtoReflect() protoreflect.Message

func (*CreateAppGroupRequest) Reset added in v0.0.5

func (x *CreateAppGroupRequest) Reset()

func (*CreateAppGroupRequest) String added in v0.0.5

func (x *CreateAppGroupRequest) String() string

type CreateCSPInfoRequest added in v0.0.5

type CreateCSPInfoRequest struct {

	// contract_id is Global Unique MultiCluster ID
	ContractId string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// csp_name is a name for users
	CspName string `protobuf:"bytes,2,opt,name=csp_name,json=cspName,proto3" json:"csp_name,omitempty"`
	// auth is an optional. This is an authentication info for IaaS.
	Auth string `protobuf:"bytes,3,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

CreateCSPInfoRequest is used to create a new CSP Info

func (*CreateCSPInfoRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use CreateCSPInfoRequest.ProtoReflect.Descriptor instead.

func (*CreateCSPInfoRequest) GetAuth added in v0.0.5

func (x *CreateCSPInfoRequest) GetAuth() string

func (*CreateCSPInfoRequest) GetContractId added in v0.0.5

func (x *CreateCSPInfoRequest) GetContractId() string

func (*CreateCSPInfoRequest) GetCspName added in v0.0.5

func (x *CreateCSPInfoRequest) GetCspName() string

func (*CreateCSPInfoRequest) ProtoMessage added in v0.0.5

func (*CreateCSPInfoRequest) ProtoMessage()

func (*CreateCSPInfoRequest) ProtoReflect added in v0.0.5

func (x *CreateCSPInfoRequest) ProtoReflect() protoreflect.Message

func (*CreateCSPInfoRequest) Reset added in v0.0.5

func (x *CreateCSPInfoRequest) Reset()

func (*CreateCSPInfoRequest) String added in v0.0.5

func (x *CreateCSPInfoRequest) String() string

type CreateClusterRequest added in v0.0.3

type CreateClusterRequest struct {

	// contract_id is a contract ID.
	ContractId string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// csp_id is an ID of CSPInfo.
	CspId string `protobuf:"bytes,2,opt,name=csp_id,json=cspId,proto3" json:"csp_id,omitempty"`
	// cluster_name is a cluster name defined by users
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// conf is a cluster configuration
	Conf *ClusterConf `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

CreateClusterRequest is a request to create a Kubernetes cluster

func (*CreateClusterRequest) Descriptor deprecated added in v0.0.3

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

Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterRequest) GetConf added in v0.0.5

func (x *CreateClusterRequest) GetConf() *ClusterConf

func (*CreateClusterRequest) GetContractId added in v0.0.5

func (x *CreateClusterRequest) GetContractId() string

func (*CreateClusterRequest) GetCspId added in v0.0.5

func (x *CreateClusterRequest) GetCspId() string

func (*CreateClusterRequest) GetName added in v0.0.5

func (x *CreateClusterRequest) GetName() string

func (*CreateClusterRequest) ProtoMessage added in v0.0.3

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) ProtoReflect added in v0.0.3

func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message

func (*CreateClusterRequest) Reset added in v0.0.3

func (x *CreateClusterRequest) Reset()

func (*CreateClusterRequest) String added in v0.0.3

func (x *CreateClusterRequest) String() string

type CreateContractRequest

type CreateContractRequest struct {

	// contractor_name is a name of contractor
	ContractorName string `protobuf:"bytes,1,opt,name=contractor_name,json=contractorName,proto3" json:"contractor_name,omitempty"`
	// quota is a resource quota for this contract
	Quota *ContractQuota `protobuf:"bytes,2,opt,name=quota,proto3" json:"quota,omitempty"`
	// availavle_services is a list of services constomer purchased.
	AvailableServices []string `protobuf:"bytes,3,rep,name=available_services,json=availableServices,proto3" json:"available_services,omitempty"`
	// csp_name is a name of csp for user.
	CspName string `protobuf:"bytes,4,opt,name=csp_name,json=cspName,proto3" json:"csp_name,omitempty"`
	// csp_auth is an authentication information for IaaS Provider.
	CspAuth string `protobuf:"bytes,5,opt,name=csp_auth,json=cspAuth,proto3" json:"csp_auth,omitempty"`
	// contains filtered or unexported fields
}

CreateContractRequest is a request to create new contract to the contract service.

func (*CreateContractRequest) Descriptor deprecated

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

Deprecated: Use CreateContractRequest.ProtoReflect.Descriptor instead.

func (*CreateContractRequest) GetAvailableServices

func (x *CreateContractRequest) GetAvailableServices() []string

func (*CreateContractRequest) GetContractorName

func (x *CreateContractRequest) GetContractorName() string

func (*CreateContractRequest) GetCspAuth added in v0.0.5

func (x *CreateContractRequest) GetCspAuth() string

func (*CreateContractRequest) GetCspName added in v0.0.5

func (x *CreateContractRequest) GetCspName() string

func (*CreateContractRequest) GetQuota

func (x *CreateContractRequest) GetQuota() *ContractQuota

func (*CreateContractRequest) ProtoMessage

func (*CreateContractRequest) ProtoMessage()

func (*CreateContractRequest) ProtoReflect

func (x *CreateContractRequest) ProtoReflect() protoreflect.Message

func (*CreateContractRequest) Reset

func (x *CreateContractRequest) Reset()

func (*CreateContractRequest) String

func (x *CreateContractRequest) String() string

type CreateContractResponse

type CreateContractResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// csp_id is a global unique ID created by the info service.
	CspId string `protobuf:"bytes,3,opt,name=csp_id,json=cspId,proto3" json:"csp_id,omitempty"`
	// contract_id is a global unique ID created by the contract service.
	ContractId string `protobuf:"bytes,4,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// contains filtered or unexported fields
}

CreateContractResponse is a response to the CreateContractRequest request

from the contract service.

func (*CreateContractResponse) Descriptor deprecated

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

Deprecated: Use CreateContractResponse.ProtoReflect.Descriptor instead.

func (*CreateContractResponse) GetCode

func (x *CreateContractResponse) GetCode() Code

func (*CreateContractResponse) GetContractId added in v0.0.5

func (x *CreateContractResponse) GetContractId() string

func (*CreateContractResponse) GetCspId added in v0.0.5

func (x *CreateContractResponse) GetCspId() string

func (*CreateContractResponse) GetError

func (x *CreateContractResponse) GetError() *Error

func (*CreateContractResponse) ProtoMessage

func (*CreateContractResponse) ProtoMessage()

func (*CreateContractResponse) ProtoReflect

func (x *CreateContractResponse) ProtoReflect() protoreflect.Message

func (*CreateContractResponse) Reset

func (x *CreateContractResponse) Reset()

func (*CreateContractResponse) String

func (x *CreateContractResponse) String() string

type DeleteAppGroupRequest added in v0.0.5

type DeleteAppGroupRequest struct {

	// app_group_id is an app group id to delete.
	AppGroupId string `protobuf:"bytes,1,opt,name=app_group_id,json=appGroupId,proto3" json:"app_group_id,omitempty"`
	// contains filtered or unexported fields
}

DeleteAppGroupRequest is used to delete app group.

func (*DeleteAppGroupRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use DeleteAppGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteAppGroupRequest) GetAppGroupId added in v0.0.5

func (x *DeleteAppGroupRequest) GetAppGroupId() string

func (*DeleteAppGroupRequest) ProtoMessage added in v0.0.5

func (*DeleteAppGroupRequest) ProtoMessage()

func (*DeleteAppGroupRequest) ProtoReflect added in v0.0.5

func (x *DeleteAppGroupRequest) ProtoReflect() protoreflect.Message

func (*DeleteAppGroupRequest) Reset added in v0.0.5

func (x *DeleteAppGroupRequest) Reset()

func (*DeleteAppGroupRequest) String added in v0.0.5

func (x *DeleteAppGroupRequest) String() string

type Error

type Error struct {

	// msg is an error message.
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

Error represents a detailed error for gRPC request.

func (*Error) Descriptor deprecated

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetMsg

func (x *Error) GetMsg() string

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) ProtoReflect

func (x *Error) ProtoReflect() protoreflect.Message

func (*Error) Reset

func (x *Error) Reset()

func (*Error) String

func (x *Error) String() string

type GetAppGroupRequest added in v0.0.5

type GetAppGroupRequest struct {

	// app_group_id is an id of the application group
	AppGroupId string `protobuf:"bytes,1,opt,name=app_group_id,json=appGroupId,proto3" json:"app_group_id,omitempty"`
	// contains filtered or unexported fields
}

GetAppGroupRequest returns an array of application groups on the cluster

func (*GetAppGroupRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use GetAppGroupRequest.ProtoReflect.Descriptor instead.

func (*GetAppGroupRequest) GetAppGroupId added in v0.0.5

func (x *GetAppGroupRequest) GetAppGroupId() string

func (*GetAppGroupRequest) ProtoMessage added in v0.0.5

func (*GetAppGroupRequest) ProtoMessage()

func (*GetAppGroupRequest) ProtoReflect added in v0.0.5

func (x *GetAppGroupRequest) ProtoReflect() protoreflect.Message

func (*GetAppGroupRequest) Reset added in v0.0.5

func (x *GetAppGroupRequest) Reset()

func (*GetAppGroupRequest) String added in v0.0.5

func (x *GetAppGroupRequest) String() string

type GetAppGroupResponse added in v0.0.5

type GetAppGroupResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// app_group is an application group
	AppGroup *AppGroup `protobuf:"bytes,3,opt,name=app_group,json=appGroup,proto3" json:"app_group,omitempty"`
	// contains filtered or unexported fields
}

GetAppGroupResponse contains an array of application groups.

func (*GetAppGroupResponse) Descriptor deprecated added in v0.0.5

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

Deprecated: Use GetAppGroupResponse.ProtoReflect.Descriptor instead.

func (*GetAppGroupResponse) GetAppGroup added in v0.0.5

func (x *GetAppGroupResponse) GetAppGroup() *AppGroup

func (*GetAppGroupResponse) GetCode added in v0.0.5

func (x *GetAppGroupResponse) GetCode() Code

func (*GetAppGroupResponse) GetError added in v0.0.5

func (x *GetAppGroupResponse) GetError() *Error

func (*GetAppGroupResponse) ProtoMessage added in v0.0.5

func (*GetAppGroupResponse) ProtoMessage()

func (*GetAppGroupResponse) ProtoReflect added in v0.0.5

func (x *GetAppGroupResponse) ProtoReflect() protoreflect.Message

func (*GetAppGroupResponse) Reset added in v0.0.5

func (x *GetAppGroupResponse) Reset()

func (*GetAppGroupResponse) String added in v0.0.5

func (x *GetAppGroupResponse) String() string

type GetAppGroupsRequest added in v0.0.5

type GetAppGroupsRequest struct {

	// app_name is a name of the application
	AppGroupName string `protobuf:"bytes,1,opt,name=app_group_name,json=appGroupName,proto3" json:"app_group_name,omitempty"`
	// app_type is a type of the application
	Type AppGroupType `protobuf:"varint,2,opt,name=type,proto3,enum=pbgo.AppGroupType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

GetAppGroupsRequest is used to get an array of application infos on cluster

func (*GetAppGroupsRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use GetAppGroupsRequest.ProtoReflect.Descriptor instead.

func (*GetAppGroupsRequest) GetAppGroupName added in v0.0.5

func (x *GetAppGroupsRequest) GetAppGroupName() string

func (*GetAppGroupsRequest) GetType added in v0.0.5

func (x *GetAppGroupsRequest) GetType() AppGroupType

func (*GetAppGroupsRequest) ProtoMessage added in v0.0.5

func (*GetAppGroupsRequest) ProtoMessage()

func (*GetAppGroupsRequest) ProtoReflect added in v0.0.5

func (x *GetAppGroupsRequest) ProtoReflect() protoreflect.Message

func (*GetAppGroupsRequest) Reset added in v0.0.5

func (x *GetAppGroupsRequest) Reset()

func (*GetAppGroupsRequest) String added in v0.0.5

func (x *GetAppGroupsRequest) String() string

type GetAppGroupsResponse added in v0.0.5

type GetAppGroupsResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// app_groups is an array of applications
	AppGroups []*AppGroup `protobuf:"bytes,3,rep,name=app_groups,json=appGroups,proto3" json:"app_groups,omitempty"`
	// contains filtered or unexported fields
}

GetAppGroupsResponse contains an array of application infos.

func (*GetAppGroupsResponse) Descriptor deprecated added in v0.0.5

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

Deprecated: Use GetAppGroupsResponse.ProtoReflect.Descriptor instead.

func (*GetAppGroupsResponse) GetAppGroups added in v0.0.5

func (x *GetAppGroupsResponse) GetAppGroups() []*AppGroup

func (*GetAppGroupsResponse) GetCode added in v0.0.5

func (x *GetAppGroupsResponse) GetCode() Code

func (*GetAppGroupsResponse) GetError added in v0.0.5

func (x *GetAppGroupsResponse) GetError() *Error

func (*GetAppGroupsResponse) ProtoMessage added in v0.0.5

func (*GetAppGroupsResponse) ProtoMessage()

func (*GetAppGroupsResponse) ProtoReflect added in v0.0.5

func (x *GetAppGroupsResponse) ProtoReflect() protoreflect.Message

func (*GetAppGroupsResponse) Reset added in v0.0.5

func (x *GetAppGroupsResponse) Reset()

func (*GetAppGroupsResponse) String added in v0.0.5

func (x *GetAppGroupsResponse) String() string

type GetAppsRequest added in v0.0.3

type GetAppsRequest struct {

	// app_group_id is a name of the application
	AppGroupId string `protobuf:"bytes,1,opt,name=app_group_id,json=appGroupId,proto3" json:"app_group_id,omitempty"`
	// app_type is a type of the application
	Type AppType `protobuf:"varint,2,opt,name=type,proto3,enum=pbgo.AppType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

GetAppsRequest returns an array of applications

func (*GetAppsRequest) Descriptor deprecated added in v0.0.3

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

Deprecated: Use GetAppsRequest.ProtoReflect.Descriptor instead.

func (*GetAppsRequest) GetAppGroupId added in v0.0.5

func (x *GetAppsRequest) GetAppGroupId() string

func (*GetAppsRequest) GetType added in v0.0.5

func (x *GetAppsRequest) GetType() AppType

func (*GetAppsRequest) ProtoMessage added in v0.0.3

func (*GetAppsRequest) ProtoMessage()

func (*GetAppsRequest) ProtoReflect added in v0.0.3

func (x *GetAppsRequest) ProtoReflect() protoreflect.Message

func (*GetAppsRequest) Reset added in v0.0.3

func (x *GetAppsRequest) Reset()

func (*GetAppsRequest) String added in v0.0.3

func (x *GetAppsRequest) String() string

type GetAppsResponse added in v0.0.3

type GetAppsResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// app_groups is an array of applications
	Apps []*Application `protobuf:"bytes,3,rep,name=apps,proto3" json:"apps,omitempty"`
	// contains filtered or unexported fields
}

GetAppsResponse returns an array of applications.

func (*GetAppsResponse) Descriptor deprecated added in v0.0.3

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

Deprecated: Use GetAppsResponse.ProtoReflect.Descriptor instead.

func (*GetAppsResponse) GetApps added in v0.0.3

func (x *GetAppsResponse) GetApps() []*Application

func (*GetAppsResponse) GetCode added in v0.0.3

func (x *GetAppsResponse) GetCode() Code

func (*GetAppsResponse) GetError added in v0.0.3

func (x *GetAppsResponse) GetError() *Error

func (*GetAppsResponse) ProtoMessage added in v0.0.3

func (*GetAppsResponse) ProtoMessage()

func (*GetAppsResponse) ProtoReflect added in v0.0.3

func (x *GetAppsResponse) ProtoReflect() protoreflect.Message

func (*GetAppsResponse) Reset added in v0.0.3

func (x *GetAppsResponse) Reset()

func (*GetAppsResponse) String added in v0.0.3

func (x *GetAppsResponse) String() string

type GetAvailableServicesRequest added in v0.0.5

type GetAvailableServicesRequest struct {

	// contract_id is a global unique ID created by the contract service.
	ContractId string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// contains filtered or unexported fields
}

GetAvailableServicesRequest is a request to get available service list

for the specific contract.

func (*GetAvailableServicesRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use GetAvailableServicesRequest.ProtoReflect.Descriptor instead.

func (*GetAvailableServicesRequest) GetContractId added in v0.0.5

func (x *GetAvailableServicesRequest) GetContractId() string

func (*GetAvailableServicesRequest) ProtoMessage added in v0.0.5

func (*GetAvailableServicesRequest) ProtoMessage()

func (*GetAvailableServicesRequest) ProtoReflect added in v0.0.5

func (*GetAvailableServicesRequest) Reset added in v0.0.5

func (x *GetAvailableServicesRequest) Reset()

func (*GetAvailableServicesRequest) String added in v0.0.5

func (x *GetAvailableServicesRequest) String() string

type GetAvailableServicesResponse added in v0.0.5

type GetAvailableServicesResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// availavle_services is a list of services constomer purchased.
	AvaiableServiceApps []string `protobuf:"bytes,3,rep,name=avaiable_service_apps,json=avaiableServiceApps,proto3" json:"avaiable_service_apps,omitempty"`
	// contains filtered or unexported fields
}

GetAvailableServicesResponse is a response to the GetAvailableServicesRequest

from the contract service.

func (*GetAvailableServicesResponse) Descriptor deprecated added in v0.0.5

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

Deprecated: Use GetAvailableServicesResponse.ProtoReflect.Descriptor instead.

func (*GetAvailableServicesResponse) GetAvaiableServiceApps added in v0.0.5

func (x *GetAvailableServicesResponse) GetAvaiableServiceApps() []string

func (*GetAvailableServicesResponse) GetCode added in v0.0.5

func (x *GetAvailableServicesResponse) GetCode() Code

func (*GetAvailableServicesResponse) GetError added in v0.0.5

func (x *GetAvailableServicesResponse) GetError() *Error

func (*GetAvailableServicesResponse) ProtoMessage added in v0.0.5

func (*GetAvailableServicesResponse) ProtoMessage()

func (*GetAvailableServicesResponse) ProtoReflect added in v0.0.5

func (*GetAvailableServicesResponse) Reset added in v0.0.5

func (x *GetAvailableServicesResponse) Reset()

func (*GetAvailableServicesResponse) String added in v0.0.5

type GetCSPAuthResponse added in v0.0.5

type GetCSPAuthResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// auth is an authentication info stiringified in JSON.
	Auth string `protobuf:"bytes,3,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

GetCSPAuthResponse is used to get an authentication information by

csp id.

func (*GetCSPAuthResponse) Descriptor deprecated added in v0.0.5

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

Deprecated: Use GetCSPAuthResponse.ProtoReflect.Descriptor instead.

func (*GetCSPAuthResponse) GetAuth added in v0.0.5

func (x *GetCSPAuthResponse) GetAuth() string

func (*GetCSPAuthResponse) GetCode added in v0.0.5

func (x *GetCSPAuthResponse) GetCode() Code

func (*GetCSPAuthResponse) GetError added in v0.0.5

func (x *GetCSPAuthResponse) GetError() *Error

func (*GetCSPAuthResponse) ProtoMessage added in v0.0.5

func (*GetCSPAuthResponse) ProtoMessage()

func (*GetCSPAuthResponse) ProtoReflect added in v0.0.5

func (x *GetCSPAuthResponse) ProtoReflect() protoreflect.Message

func (*GetCSPAuthResponse) Reset added in v0.0.5

func (x *GetCSPAuthResponse) Reset()

func (*GetCSPAuthResponse) String added in v0.0.5

func (x *GetCSPAuthResponse) String() string

type GetClusterRequest added in v0.0.3

type GetClusterRequest struct {

	// cluster_id is a cluster ID
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

GetClusterRequest is used to get info of MultiCluster to correspond with id

func (*GetClusterRequest) Descriptor deprecated added in v0.0.3

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

Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.

func (*GetClusterRequest) GetClusterId added in v0.0.3

func (x *GetClusterRequest) GetClusterId() string

func (*GetClusterRequest) ProtoMessage added in v0.0.3

func (*GetClusterRequest) ProtoMessage()

func (*GetClusterRequest) ProtoReflect added in v0.0.3

func (x *GetClusterRequest) ProtoReflect() protoreflect.Message

func (*GetClusterRequest) Reset added in v0.0.3

func (x *GetClusterRequest) Reset()

func (*GetClusterRequest) String added in v0.0.3

func (x *GetClusterRequest) String() string

type GetClusterResponse added in v0.0.3

type GetClusterResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// cluster is info for the cluster
	Cluster *Cluster `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

GetClusterResponse contains a cluster info.

func (*GetClusterResponse) Descriptor deprecated added in v0.0.3

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

Deprecated: Use GetClusterResponse.ProtoReflect.Descriptor instead.

func (*GetClusterResponse) GetCluster added in v0.0.3

func (x *GetClusterResponse) GetCluster() *Cluster

func (*GetClusterResponse) GetCode added in v0.0.3

func (x *GetClusterResponse) GetCode() Code

func (*GetClusterResponse) GetError added in v0.0.3

func (x *GetClusterResponse) GetError() *Error

func (*GetClusterResponse) ProtoMessage added in v0.0.3

func (*GetClusterResponse) ProtoMessage()

func (*GetClusterResponse) ProtoReflect added in v0.0.3

func (x *GetClusterResponse) ProtoReflect() protoreflect.Message

func (*GetClusterResponse) Reset added in v0.0.3

func (x *GetClusterResponse) Reset()

func (*GetClusterResponse) String added in v0.0.3

func (x *GetClusterResponse) String() string

type GetClustersRequest added in v0.0.3

type GetClustersRequest struct {

	// csp_id is a Global Unique ID
	CspId string `protobuf:"bytes,1,opt,name=csp_id,json=cspId,proto3" json:"csp_id,omitempty"`
	// contains filtered or unexported fields
}

GetClustersRequest returns a list of clusters in specific CSP.

func (*GetClustersRequest) Descriptor deprecated added in v0.0.3

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

Deprecated: Use GetClustersRequest.ProtoReflect.Descriptor instead.

func (*GetClustersRequest) GetCspId added in v0.0.5

func (x *GetClustersRequest) GetCspId() string

func (*GetClustersRequest) ProtoMessage added in v0.0.3

func (*GetClustersRequest) ProtoMessage()

func (*GetClustersRequest) ProtoReflect added in v0.0.3

func (x *GetClustersRequest) ProtoReflect() protoreflect.Message

func (*GetClustersRequest) Reset added in v0.0.3

func (x *GetClustersRequest) Reset()

func (*GetClustersRequest) String added in v0.0.3

func (x *GetClustersRequest) String() string

type GetClustersResponse added in v0.0.3

type GetClustersResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// cluster is info. for the cluster
	Clusters []*Cluster `protobuf:"bytes,3,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

GetClustersResponse contains an array of cluster infos.

func (*GetClustersResponse) Descriptor deprecated added in v0.0.3

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

Deprecated: Use GetClustersResponse.ProtoReflect.Descriptor instead.

func (*GetClustersResponse) GetClusters added in v0.0.3

func (x *GetClustersResponse) GetClusters() []*Cluster

func (*GetClustersResponse) GetCode added in v0.0.3

func (x *GetClustersResponse) GetCode() Code

func (*GetClustersResponse) GetError added in v0.0.3

func (x *GetClustersResponse) GetError() *Error

func (*GetClustersResponse) ProtoMessage added in v0.0.3

func (*GetClustersResponse) ProtoMessage()

func (*GetClustersResponse) ProtoReflect added in v0.0.3

func (x *GetClustersResponse) ProtoReflect() protoreflect.Message

func (*GetClustersResponse) Reset added in v0.0.3

func (x *GetClustersResponse) Reset()

func (*GetClustersResponse) String added in v0.0.3

func (x *GetClustersResponse) String() string

type GetContractRequest

type GetContractRequest struct {

	// contract_id is a global unique ID created by CBP
	ContractId string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// contains filtered or unexported fields
}

GetContractRequest is a request to inquire contract to the contract service.

func (*GetContractRequest) Descriptor deprecated

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

Deprecated: Use GetContractRequest.ProtoReflect.Descriptor instead.

func (*GetContractRequest) GetContractId

func (x *GetContractRequest) GetContractId() string

func (*GetContractRequest) ProtoMessage

func (*GetContractRequest) ProtoMessage()

func (*GetContractRequest) ProtoReflect

func (x *GetContractRequest) ProtoReflect() protoreflect.Message

func (*GetContractRequest) Reset

func (x *GetContractRequest) Reset()

func (*GetContractRequest) String

func (x *GetContractRequest) String() string

type GetContractResponse

type GetContractResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contract is a contract information.
	Contract *Contract `protobuf:"bytes,3,opt,name=contract,proto3" json:"contract,omitempty"`
	// contains filtered or unexported fields
}

GetContractResponse is a response to the GetContractRequest

from the contract service.

func (*GetContractResponse) Descriptor deprecated

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

Deprecated: Use GetContractResponse.ProtoReflect.Descriptor instead.

func (*GetContractResponse) GetCode

func (x *GetContractResponse) GetCode() Code

func (*GetContractResponse) GetContract added in v0.0.5

func (x *GetContractResponse) GetContract() *Contract

func (*GetContractResponse) GetError

func (x *GetContractResponse) GetError() *Error

func (*GetContractResponse) ProtoMessage

func (*GetContractResponse) ProtoMessage()

func (*GetContractResponse) ProtoReflect

func (x *GetContractResponse) ProtoReflect() protoreflect.Message

func (*GetContractResponse) Reset

func (x *GetContractResponse) Reset()

func (*GetContractResponse) String

func (x *GetContractResponse) String() string

type GetContractsRequest added in v0.0.5

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

GetContractsRequest is a request to inquire all contracts

to the contract service.

func (*GetContractsRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use GetContractsRequest.ProtoReflect.Descriptor instead.

func (*GetContractsRequest) ProtoMessage added in v0.0.5

func (*GetContractsRequest) ProtoMessage()

func (*GetContractsRequest) ProtoReflect added in v0.0.5

func (x *GetContractsRequest) ProtoReflect() protoreflect.Message

func (*GetContractsRequest) Reset added in v0.0.5

func (x *GetContractsRequest) Reset()

func (*GetContractsRequest) String added in v0.0.5

func (x *GetContractsRequest) String() string

type GetContractsResponse added in v0.0.5

type GetContractsResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contracts is a list of contracts.
	Contracts []*Contract `protobuf:"bytes,3,rep,name=contracts,proto3" json:"contracts,omitempty"`
	// contains filtered or unexported fields
}

GetContractsResponse is a response to the GetContractsRequest

from the contract service.

func (*GetContractsResponse) Descriptor deprecated added in v0.0.5

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

Deprecated: Use GetContractsResponse.ProtoReflect.Descriptor instead.

func (*GetContractsResponse) GetCode added in v0.0.5

func (x *GetContractsResponse) GetCode() Code

func (*GetContractsResponse) GetContracts added in v0.0.5

func (x *GetContractsResponse) GetContracts() []*Contract

func (*GetContractsResponse) GetError added in v0.0.5

func (x *GetContractsResponse) GetError() *Error

func (*GetContractsResponse) ProtoMessage added in v0.0.5

func (*GetContractsResponse) ProtoMessage()

func (*GetContractsResponse) ProtoReflect added in v0.0.5

func (x *GetContractsResponse) ProtoReflect() protoreflect.Message

func (*GetContractsResponse) Reset added in v0.0.5

func (x *GetContractsResponse) Reset()

func (*GetContractsResponse) String added in v0.0.5

func (x *GetContractsResponse) String() string

type GetQuotaRequest

type GetQuotaRequest struct {

	// contract_id is a global unique ID created by CBP
	ContractId string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// contains filtered or unexported fields
}

GetQuotaRequest is a request to inquire quota information

of the specific contract.

func (*GetQuotaRequest) Descriptor deprecated

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

Deprecated: Use GetQuotaRequest.ProtoReflect.Descriptor instead.

func (*GetQuotaRequest) GetContractId

func (x *GetQuotaRequest) GetContractId() string

func (*GetQuotaRequest) ProtoMessage

func (*GetQuotaRequest) ProtoMessage()

func (*GetQuotaRequest) ProtoReflect

func (x *GetQuotaRequest) ProtoReflect() protoreflect.Message

func (*GetQuotaRequest) Reset

func (x *GetQuotaRequest) Reset()

func (*GetQuotaRequest) String

func (x *GetQuotaRequest) String() string

type GetQuotaResponse

type GetQuotaResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// quota is a resource quota for cpu, memory, storage and so on.
	Quota *ContractQuota `protobuf:"bytes,3,opt,name=quota,proto3" json:"quota,omitempty"`
	// contains filtered or unexported fields
}

GetQuotaResponse is a response to the GetQuotaRequest

from the contract service.

func (*GetQuotaResponse) Descriptor deprecated

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

Deprecated: Use GetQuotaResponse.ProtoReflect.Descriptor instead.

func (*GetQuotaResponse) GetCode

func (x *GetQuotaResponse) GetCode() Code

func (*GetQuotaResponse) GetError

func (x *GetQuotaResponse) GetError() *Error

func (*GetQuotaResponse) GetQuota

func (x *GetQuotaResponse) GetQuota() *ContractQuota

func (*GetQuotaResponse) ProtoMessage

func (*GetQuotaResponse) ProtoMessage()

func (*GetQuotaResponse) ProtoReflect

func (x *GetQuotaResponse) ProtoReflect() protoreflect.Message

func (*GetQuotaResponse) Reset

func (x *GetQuotaResponse) Reset()

func (*GetQuotaResponse) String

func (x *GetQuotaResponse) String() string

type IDRequest added in v0.0.3

type IDRequest struct {

	// id is a id to ask
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

IDRequest is a request with a id

func (*IDRequest) Descriptor deprecated added in v0.0.3

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

Deprecated: Use IDRequest.ProtoReflect.Descriptor instead.

func (*IDRequest) GetId added in v0.0.3

func (x *IDRequest) GetId() string

func (*IDRequest) ProtoMessage added in v0.0.3

func (*IDRequest) ProtoMessage()

func (*IDRequest) ProtoReflect added in v0.0.3

func (x *IDRequest) ProtoReflect() protoreflect.Message

func (*IDRequest) Reset added in v0.0.3

func (x *IDRequest) Reset()

func (*IDRequest) String added in v0.0.3

func (x *IDRequest) String() string

type IDResponse added in v0.0.3

type IDResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// id is a id
	Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

IDResponse returns a id

func (*IDResponse) Descriptor deprecated added in v0.0.3

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

Deprecated: Use IDResponse.ProtoReflect.Descriptor instead.

func (*IDResponse) GetCode added in v0.0.3

func (x *IDResponse) GetCode() Code

func (*IDResponse) GetError added in v0.0.3

func (x *IDResponse) GetError() *Error

func (*IDResponse) GetId added in v0.0.3

func (x *IDResponse) GetId() string

func (*IDResponse) ProtoMessage added in v0.0.3

func (*IDResponse) ProtoMessage()

func (*IDResponse) ProtoReflect added in v0.0.3

func (x *IDResponse) ProtoReflect() protoreflect.Message

func (*IDResponse) Reset added in v0.0.3

func (x *IDResponse) Reset()

func (*IDResponse) String added in v0.0.3

func (x *IDResponse) String() string

type IDsResponse added in v0.0.3

type IDsResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// ids is a array of ids
	Ids []string `protobuf:"bytes,3,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

IDsResponse returns arry of ids

func (*IDsResponse) Descriptor deprecated added in v0.0.3

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

Deprecated: Use IDsResponse.ProtoReflect.Descriptor instead.

func (*IDsResponse) GetCode added in v0.0.3

func (x *IDsResponse) GetCode() Code

func (*IDsResponse) GetError added in v0.0.3

func (x *IDsResponse) GetError() *Error

func (*IDsResponse) GetIds added in v0.0.3

func (x *IDsResponse) GetIds() []string

func (*IDsResponse) ProtoMessage added in v0.0.3

func (*IDsResponse) ProtoMessage()

func (*IDsResponse) ProtoReflect added in v0.0.3

func (x *IDsResponse) ProtoReflect() protoreflect.Message

func (*IDsResponse) Reset added in v0.0.3

func (x *IDsResponse) Reset()

func (*IDsResponse) String added in v0.0.3

func (x *IDsResponse) String() string

type InfoServiceClient added in v0.0.3

type InfoServiceClient interface {
	// CreateCSPInfo create new CSP Info for the contract id.
	CreateCSPInfo(ctx context.Context, in *CreateCSPInfoRequest, opts ...grpc.CallOption) (*IDResponse, error)
	// GetCSPIDs returns all CSP ids.
	GetCSPIDs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*IDsResponse, error)
	// GetCSPIDsByContractID returns the CSP ids by the contract id.
	GetCSPIDsByContractID(ctx context.Context, in *IDRequest, opts ...grpc.CallOption) (*IDsResponse, error)
	// UpdateCSPInfo updates an authentication config for CSP.
	UpdateCSPInfo(ctx context.Context, in *UpdateCSPInfoRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
	// GetCSPAuth returns an authentication info by csp id.
	GetCSPAuth(ctx context.Context, in *IDRequest, opts ...grpc.CallOption) (*GetCSPAuthResponse, error)
	// AddClusterInfo adds newly created cluster information
	AddClusterInfo(ctx context.Context, in *AddClusterInfoRequest, opts ...grpc.CallOption) (*IDResponse, error)
	// UpdateClusterConf updates the cluster configuration information
	UpdateClusterConf(ctx context.Context, in *UpdateClusterConfRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
	// GetClusterget cluster for the id of the cluster
	GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*GetClusterResponse, error)
	// GetClusters get every clusters on the mutlcluster
	GetClusters(ctx context.Context, in *GetClustersRequest, opts ...grpc.CallOption) (*GetClustersResponse, error)
	// UpdateClusterStatus update Status of the Cluster
	UpdateClusterStatus(ctx context.Context, in *UpdateClusterStatusRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
}

InfoServiceClient is the client API for InfoService 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 NewInfoServiceClient added in v0.0.3

func NewInfoServiceClient(cc grpc.ClientConnInterface) InfoServiceClient

type InfoServiceServer added in v0.0.3

type InfoServiceServer interface {
	// CreateCSPInfo create new CSP Info for the contract id.
	CreateCSPInfo(context.Context, *CreateCSPInfoRequest) (*IDResponse, error)
	// GetCSPIDs returns all CSP ids.
	GetCSPIDs(context.Context, *emptypb.Empty) (*IDsResponse, error)
	// GetCSPIDsByContractID returns the CSP ids by the contract id.
	GetCSPIDsByContractID(context.Context, *IDRequest) (*IDsResponse, error)
	// UpdateCSPInfo updates an authentication config for CSP.
	UpdateCSPInfo(context.Context, *UpdateCSPInfoRequest) (*SimpleResponse, error)
	// GetCSPAuth returns an authentication info by csp id.
	GetCSPAuth(context.Context, *IDRequest) (*GetCSPAuthResponse, error)
	// AddClusterInfo adds newly created cluster information
	AddClusterInfo(context.Context, *AddClusterInfoRequest) (*IDResponse, error)
	// UpdateClusterConf updates the cluster configuration information
	UpdateClusterConf(context.Context, *UpdateClusterConfRequest) (*SimpleResponse, error)
	// GetClusterget cluster for the id of the cluster
	GetCluster(context.Context, *GetClusterRequest) (*GetClusterResponse, error)
	// GetClusters get every clusters on the mutlcluster
	GetClusters(context.Context, *GetClustersRequest) (*GetClustersResponse, error)
	// UpdateClusterStatus update Status of the Cluster
	UpdateClusterStatus(context.Context, *UpdateClusterStatusRequest) (*SimpleResponse, error)
	// contains filtered or unexported methods
}

InfoServiceServer is the server API for InfoService service. All implementations must embed UnimplementedInfoServiceServer for forward compatibility

type InstallAppGroupsRequest added in v0.0.5

type InstallAppGroupsRequest struct {

	// apps are applications to install into target cluster.
	AppGroups []*AppGroup `protobuf:"bytes,1,rep,name=app_groups,json=appGroups,proto3" json:"app_groups,omitempty"`
	// contains filtered or unexported fields
}

InstallAppGroupsRequest requests to install application groups on cluster

func (*InstallAppGroupsRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use InstallAppGroupsRequest.ProtoReflect.Descriptor instead.

func (*InstallAppGroupsRequest) GetAppGroups added in v0.0.5

func (x *InstallAppGroupsRequest) GetAppGroups() []*AppGroup

func (*InstallAppGroupsRequest) ProtoMessage added in v0.0.5

func (*InstallAppGroupsRequest) ProtoMessage()

func (*InstallAppGroupsRequest) ProtoReflect added in v0.0.5

func (x *InstallAppGroupsRequest) ProtoReflect() protoreflect.Message

func (*InstallAppGroupsRequest) Reset added in v0.0.5

func (x *InstallAppGroupsRequest) Reset()

func (*InstallAppGroupsRequest) String added in v0.0.5

func (x *InstallAppGroupsRequest) String() string

type ScaleClusterRequest added in v0.0.5

type ScaleClusterRequest struct {

	// cluster_id is Global Unique ID
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// master_replicas is the number of master node
	MasterReplicas int32 `protobuf:"varint,2,opt,name=master_replicas,json=masterReplicas,proto3" json:"master_replicas,omitempty"`
	// worker_replicas is the number of worker node
	WorkerReplicas int32 `protobuf:"varint,3,opt,name=worker_replicas,json=workerReplicas,proto3" json:"worker_replicas,omitempty"`
	// contains filtered or unexported fields
}

ScaleClusterRequest is a request to scale the number of nodes on the cluster

func (*ScaleClusterRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use ScaleClusterRequest.ProtoReflect.Descriptor instead.

func (*ScaleClusterRequest) GetClusterId added in v0.0.5

func (x *ScaleClusterRequest) GetClusterId() string

func (*ScaleClusterRequest) GetMasterReplicas added in v0.0.5

func (x *ScaleClusterRequest) GetMasterReplicas() int32

func (*ScaleClusterRequest) GetWorkerReplicas added in v0.0.5

func (x *ScaleClusterRequest) GetWorkerReplicas() int32

func (*ScaleClusterRequest) ProtoMessage added in v0.0.5

func (*ScaleClusterRequest) ProtoMessage()

func (*ScaleClusterRequest) ProtoReflect added in v0.0.5

func (x *ScaleClusterRequest) ProtoReflect() protoreflect.Message

func (*ScaleClusterRequest) Reset added in v0.0.5

func (x *ScaleClusterRequest) Reset()

func (*ScaleClusterRequest) String added in v0.0.5

func (x *ScaleClusterRequest) String() string

type SimpleResponse added in v0.0.3

type SimpleResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

SimpleResponse returns a result for the request (the simplest return type)

func (*SimpleResponse) Descriptor deprecated added in v0.0.3

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

Deprecated: Use SimpleResponse.ProtoReflect.Descriptor instead.

func (*SimpleResponse) GetCode added in v0.0.3

func (x *SimpleResponse) GetCode() Code

func (*SimpleResponse) GetError added in v0.0.3

func (x *SimpleResponse) GetError() *Error

func (*SimpleResponse) ProtoMessage added in v0.0.3

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) ProtoReflect added in v0.0.3

func (x *SimpleResponse) ProtoReflect() protoreflect.Message

func (*SimpleResponse) Reset added in v0.0.3

func (x *SimpleResponse) Reset()

func (*SimpleResponse) String added in v0.0.3

func (x *SimpleResponse) String() string

type UnimplementedAppInfoServiceServer added in v0.0.4

type UnimplementedAppInfoServiceServer struct {
}

UnimplementedAppInfoServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAppInfoServiceServer) CreateAppGroup added in v0.0.5

func (UnimplementedAppInfoServiceServer) DeleteAppGroup added in v0.0.5

func (UnimplementedAppInfoServiceServer) GetAppGroup added in v0.0.5

func (UnimplementedAppInfoServiceServer) GetAppGroups added in v0.0.5

func (UnimplementedAppInfoServiceServer) GetAppGroupsByClusterID added in v0.0.5

func (UnimplementedAppInfoServiceServer) GetApps added in v0.0.4

func (UnimplementedAppInfoServiceServer) GetAppsByAppGroupID added in v0.0.5

func (UnimplementedAppInfoServiceServer) UpdateApp added in v0.0.5

func (UnimplementedAppInfoServiceServer) UpdateAppGroupStatus added in v0.0.5

type UnimplementedClusterLcmServiceServer added in v0.0.5

type UnimplementedClusterLcmServiceServer struct {
}

UnimplementedClusterLcmServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterLcmServiceServer) CreateCluster added in v0.0.5

func (UnimplementedClusterLcmServiceServer) InstallAppGroups added in v0.0.5

func (UnimplementedClusterLcmServiceServer) ScaleCluster added in v0.0.5

func (UnimplementedClusterLcmServiceServer) UninstallAppGroups added in v0.0.5

type UnimplementedContractServiceServer

type UnimplementedContractServiceServer struct {
}

UnimplementedContractServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedContractServiceServer) CreateContract

func (UnimplementedContractServiceServer) GetAvailableServices added in v0.0.5

func (UnimplementedContractServiceServer) GetContract

func (UnimplementedContractServiceServer) GetContracts added in v0.0.5

func (UnimplementedContractServiceServer) GetQuota

func (UnimplementedContractServiceServer) UpdateQuota

func (UnimplementedContractServiceServer) UpdateServices

type UnimplementedInfoServiceServer added in v0.0.3

type UnimplementedInfoServiceServer struct {
}

UnimplementedInfoServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedInfoServiceServer) AddClusterInfo added in v0.0.5

func (UnimplementedInfoServiceServer) CreateCSPInfo added in v0.0.5

func (UnimplementedInfoServiceServer) GetCSPAuth added in v0.0.5

func (UnimplementedInfoServiceServer) GetCSPIDs added in v0.0.5

func (UnimplementedInfoServiceServer) GetCSPIDsByContractID added in v0.0.5

func (UnimplementedInfoServiceServer) GetCluster added in v0.0.3

func (UnimplementedInfoServiceServer) GetClusters added in v0.0.3

func (UnimplementedInfoServiceServer) UpdateCSPInfo added in v0.0.5

func (UnimplementedInfoServiceServer) UpdateClusterConf added in v0.0.5

func (UnimplementedInfoServiceServer) UpdateClusterStatus added in v0.0.3

type UninstallAppGroupsRequest added in v0.0.5

type UninstallAppGroupsRequest struct {

	// cluster_id is Global Unique ID
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// app_group_ids is a array of app_group_id.
	AppGroupIds []string `protobuf:"bytes,2,rep,name=app_group_ids,json=appGroupIds,proto3" json:"app_group_ids,omitempty"`
	// contains filtered or unexported fields
}

UninstallAppGroupsRequest is a request to delete applications on the Cluster

func (*UninstallAppGroupsRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use UninstallAppGroupsRequest.ProtoReflect.Descriptor instead.

func (*UninstallAppGroupsRequest) GetAppGroupIds added in v0.0.5

func (x *UninstallAppGroupsRequest) GetAppGroupIds() []string

func (*UninstallAppGroupsRequest) GetClusterId added in v0.0.5

func (x *UninstallAppGroupsRequest) GetClusterId() string

func (*UninstallAppGroupsRequest) ProtoMessage added in v0.0.5

func (*UninstallAppGroupsRequest) ProtoMessage()

func (*UninstallAppGroupsRequest) ProtoReflect added in v0.0.5

func (*UninstallAppGroupsRequest) Reset added in v0.0.5

func (x *UninstallAppGroupsRequest) Reset()

func (*UninstallAppGroupsRequest) String added in v0.0.5

func (x *UninstallAppGroupsRequest) String() string

type UnsafeAppInfoServiceServer added in v0.0.4

type UnsafeAppInfoServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeAppInfoServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AppInfoServiceServer will result in compilation errors.

type UnsafeClusterLcmServiceServer added in v0.0.5

type UnsafeClusterLcmServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeClusterLcmServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterLcmServiceServer will result in compilation errors.

type UnsafeContractServiceServer

type UnsafeContractServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeContractServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ContractServiceServer will result in compilation errors.

type UnsafeInfoServiceServer added in v0.0.3

type UnsafeInfoServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeInfoServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InfoServiceServer will result in compilation errors.

type UpdateAppGroupStatusRequest added in v0.0.5

type UpdateAppGroupStatusRequest struct {

	// app_group_id is the application group id to change the status
	AppGroupId string `protobuf:"bytes,1,opt,name=app_group_id,json=appGroupId,proto3" json:"app_group_id,omitempty"`
	// status is a AppStatus of the application
	Status AppGroupStatus `protobuf:"varint,2,opt,name=status,proto3,enum=pbgo.AppGroupStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

UpdateAppGroupStatusRequest is used to change the status of the app

func (*UpdateAppGroupStatusRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use UpdateAppGroupStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateAppGroupStatusRequest) GetAppGroupId added in v0.0.5

func (x *UpdateAppGroupStatusRequest) GetAppGroupId() string

func (*UpdateAppGroupStatusRequest) GetStatus added in v0.0.5

func (*UpdateAppGroupStatusRequest) ProtoMessage added in v0.0.5

func (*UpdateAppGroupStatusRequest) ProtoMessage()

func (*UpdateAppGroupStatusRequest) ProtoReflect added in v0.0.5

func (*UpdateAppGroupStatusRequest) Reset added in v0.0.5

func (x *UpdateAppGroupStatusRequest) Reset()

func (*UpdateAppGroupStatusRequest) String added in v0.0.5

func (x *UpdateAppGroupStatusRequest) String() string

type UpdateAppRequest added in v0.0.5

type UpdateAppRequest struct {

	// app_group_id is the application group id.
	AppGroupId string `protobuf:"bytes,1,opt,name=app_group_id,json=appGroupId,proto3" json:"app_group_id,omitempty"`
	// app_type is a type of the application
	AppType AppType `protobuf:"varint,2,opt,name=app_type,json=appType,proto3,enum=pbgo.AppType" json:"app_type,omitempty"`
	// endpoints is an endpoint string.
	Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// metadata is an unstructured metadata for application.
	Metadata string `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

UpdateAppRequest updates an information of application such as endpoints.

func (*UpdateAppRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use UpdateAppRequest.ProtoReflect.Descriptor instead.

func (*UpdateAppRequest) GetAppGroupId added in v0.0.5

func (x *UpdateAppRequest) GetAppGroupId() string

func (*UpdateAppRequest) GetAppType added in v0.0.5

func (x *UpdateAppRequest) GetAppType() AppType

func (*UpdateAppRequest) GetEndpoint added in v0.0.5

func (x *UpdateAppRequest) GetEndpoint() string

func (*UpdateAppRequest) GetMetadata added in v0.0.5

func (x *UpdateAppRequest) GetMetadata() string

func (*UpdateAppRequest) ProtoMessage added in v0.0.5

func (*UpdateAppRequest) ProtoMessage()

func (*UpdateAppRequest) ProtoReflect added in v0.0.5

func (x *UpdateAppRequest) ProtoReflect() protoreflect.Message

func (*UpdateAppRequest) Reset added in v0.0.5

func (x *UpdateAppRequest) Reset()

func (*UpdateAppRequest) String added in v0.0.5

func (x *UpdateAppRequest) String() string

type UpdateCSPInfoRequest added in v0.0.5

type UpdateCSPInfoRequest struct {

	// csp_id is .
	CspId string `protobuf:"bytes,1,opt,name=csp_id,json=cspId,proto3" json:"csp_id,omitempty"`
	// auth is an authentication info to update.
	Auth string `protobuf:"bytes,2,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

UpdateCSPInfoRequest updates an authenticationg information for CSP.

func (*UpdateCSPInfoRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use UpdateCSPInfoRequest.ProtoReflect.Descriptor instead.

func (*UpdateCSPInfoRequest) GetAuth added in v0.0.5

func (x *UpdateCSPInfoRequest) GetAuth() string

func (*UpdateCSPInfoRequest) GetCspId added in v0.0.5

func (x *UpdateCSPInfoRequest) GetCspId() string

func (*UpdateCSPInfoRequest) ProtoMessage added in v0.0.5

func (*UpdateCSPInfoRequest) ProtoMessage()

func (*UpdateCSPInfoRequest) ProtoReflect added in v0.0.5

func (x *UpdateCSPInfoRequest) ProtoReflect() protoreflect.Message

func (*UpdateCSPInfoRequest) Reset added in v0.0.5

func (x *UpdateCSPInfoRequest) Reset()

func (*UpdateCSPInfoRequest) String added in v0.0.5

func (x *UpdateCSPInfoRequest) String() string

type UpdateClusterConfRequest added in v0.0.5

type UpdateClusterConfRequest struct {

	// cluster_id is a cluster ID
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// conf is a kubernetes cluster configuration
	Conf *ClusterConf `protobuf:"bytes,2,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

UpdateClusterConfRequest is used to update kubernetes cluster configuration to correspond with id

func (*UpdateClusterConfRequest) Descriptor deprecated added in v0.0.5

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

Deprecated: Use UpdateClusterConfRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterConfRequest) GetClusterId added in v0.0.5

func (x *UpdateClusterConfRequest) GetClusterId() string

func (*UpdateClusterConfRequest) GetConf added in v0.0.5

func (x *UpdateClusterConfRequest) GetConf() *ClusterConf

func (*UpdateClusterConfRequest) ProtoMessage added in v0.0.5

func (*UpdateClusterConfRequest) ProtoMessage()

func (*UpdateClusterConfRequest) ProtoReflect added in v0.0.5

func (x *UpdateClusterConfRequest) ProtoReflect() protoreflect.Message

func (*UpdateClusterConfRequest) Reset added in v0.0.5

func (x *UpdateClusterConfRequest) Reset()

func (*UpdateClusterConfRequest) String added in v0.0.5

func (x *UpdateClusterConfRequest) String() string

type UpdateClusterStatusRequest added in v0.0.3

type UpdateClusterStatusRequest struct {

	// cluster_id is a cluster ID
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// status is the clusterstatus to be changed
	Status ClusterStatus `protobuf:"varint,2,opt,name=status,proto3,enum=pbgo.ClusterStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

UpdateClusterStatusRequest is used to change status of the cluster

func (*UpdateClusterStatusRequest) Descriptor deprecated added in v0.0.3

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

Deprecated: Use UpdateClusterStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterStatusRequest) GetClusterId added in v0.0.3

func (x *UpdateClusterStatusRequest) GetClusterId() string

func (*UpdateClusterStatusRequest) GetStatus added in v0.0.3

func (*UpdateClusterStatusRequest) ProtoMessage added in v0.0.3

func (*UpdateClusterStatusRequest) ProtoMessage()

func (*UpdateClusterStatusRequest) ProtoReflect added in v0.0.3

func (*UpdateClusterStatusRequest) Reset added in v0.0.3

func (x *UpdateClusterStatusRequest) Reset()

func (*UpdateClusterStatusRequest) String added in v0.0.3

func (x *UpdateClusterStatusRequest) String() string

type UpdateQuotaRequest

type UpdateQuotaRequest struct {

	// contract_id is a global unique ID created by CBP
	ContractId string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// quota is a resource quota for cpu, memory, storage and so on.
	Quota *ContractQuota `protobuf:"bytes,2,opt,name=quota,proto3" json:"quota,omitempty"`
	// contains filtered or unexported fields
}

UpdateQuotaRequest is a request to update resource quota

for specific contract.

func (*UpdateQuotaRequest) Descriptor deprecated

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

Deprecated: Use UpdateQuotaRequest.ProtoReflect.Descriptor instead.

func (*UpdateQuotaRequest) GetContractId

func (x *UpdateQuotaRequest) GetContractId() string

func (*UpdateQuotaRequest) GetQuota

func (x *UpdateQuotaRequest) GetQuota() *ContractQuota

func (*UpdateQuotaRequest) ProtoMessage

func (*UpdateQuotaRequest) ProtoMessage()

func (*UpdateQuotaRequest) ProtoReflect

func (x *UpdateQuotaRequest) ProtoReflect() protoreflect.Message

func (*UpdateQuotaRequest) Reset

func (x *UpdateQuotaRequest) Reset()

func (*UpdateQuotaRequest) String

func (x *UpdateQuotaRequest) String() string

type UpdateQuotaResponse

type UpdateQuotaResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contract_id is a global unique ID created by CBP
	ContractId string `protobuf:"bytes,3,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// prev_quota is a quota before updating quota.
	PrevQuota *ContractQuota `protobuf:"bytes,4,opt,name=prev_quota,json=prevQuota,proto3" json:"prev_quota,omitempty"`
	// current_quota is a quota after updating.
	CurrentQuota *ContractQuota `protobuf:"bytes,5,opt,name=current_quota,json=currentQuota,proto3" json:"current_quota,omitempty"`
	// contains filtered or unexported fields
}

UpdateQuotaResponse is a response to the UpdateQuotaRequest from the contract service

func (*UpdateQuotaResponse) Descriptor deprecated

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

Deprecated: Use UpdateQuotaResponse.ProtoReflect.Descriptor instead.

func (*UpdateQuotaResponse) GetCode

func (x *UpdateQuotaResponse) GetCode() Code

func (*UpdateQuotaResponse) GetContractId

func (x *UpdateQuotaResponse) GetContractId() string

func (*UpdateQuotaResponse) GetCurrentQuota

func (x *UpdateQuotaResponse) GetCurrentQuota() *ContractQuota

func (*UpdateQuotaResponse) GetError

func (x *UpdateQuotaResponse) GetError() *Error

func (*UpdateQuotaResponse) GetPrevQuota

func (x *UpdateQuotaResponse) GetPrevQuota() *ContractQuota

func (*UpdateQuotaResponse) ProtoMessage

func (*UpdateQuotaResponse) ProtoMessage()

func (*UpdateQuotaResponse) ProtoReflect

func (x *UpdateQuotaResponse) ProtoReflect() protoreflect.Message

func (*UpdateQuotaResponse) Reset

func (x *UpdateQuotaResponse) Reset()

func (*UpdateQuotaResponse) String

func (x *UpdateQuotaResponse) String() string

type UpdateServicesRequest

type UpdateServicesRequest struct {

	// contract_id is a global unique ID created by CBP
	ContractId string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// availavle_services is a list of services constomer purchased.
	AvailableServices []string `protobuf:"bytes,2,rep,name=available_services,json=availableServices,proto3" json:"available_services,omitempty"`
	// contains filtered or unexported fields
}

UpdateServicesRequest is a request

to update available service list to the contract service.

The services currently provided are as below:

  • LMA(Logging Monitoring Alert)
  • service-mesh (Istio, jaeger, kiali)

func (*UpdateServicesRequest) Descriptor deprecated

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

Deprecated: Use UpdateServicesRequest.ProtoReflect.Descriptor instead.

func (*UpdateServicesRequest) GetAvailableServices

func (x *UpdateServicesRequest) GetAvailableServices() []string

func (*UpdateServicesRequest) GetContractId

func (x *UpdateServicesRequest) GetContractId() string

func (*UpdateServicesRequest) ProtoMessage

func (*UpdateServicesRequest) ProtoMessage()

func (*UpdateServicesRequest) ProtoReflect

func (x *UpdateServicesRequest) ProtoReflect() protoreflect.Message

func (*UpdateServicesRequest) Reset

func (x *UpdateServicesRequest) Reset()

func (*UpdateServicesRequest) String

func (x *UpdateServicesRequest) String() string

type UpdateServicesResponse

type UpdateServicesResponse struct {

	// code is a response code.
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pbgo.Code" json:"code,omitempty"`
	// error is a detailed error message.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contract_id is a global unique ID created by CBP
	ContractId string `protobuf:"bytes,3,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	// prev_services is a list of services before updating.
	PrevServices []string `protobuf:"bytes,4,rep,name=prev_services,json=prevServices,proto3" json:"prev_services,omitempty"`
	// current_services is a list of services after updating.
	CurrentServices []string `protobuf:"bytes,5,rep,name=current_services,json=currentServices,proto3" json:"current_services,omitempty"`
	// contains filtered or unexported fields
}

UpdateServicesResponse is a response

to the UpdateServicesRequest from the contract service.

func (*UpdateServicesResponse) Descriptor deprecated

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

Deprecated: Use UpdateServicesResponse.ProtoReflect.Descriptor instead.

func (*UpdateServicesResponse) GetCode

func (x *UpdateServicesResponse) GetCode() Code

func (*UpdateServicesResponse) GetContractId

func (x *UpdateServicesResponse) GetContractId() string

func (*UpdateServicesResponse) GetCurrentServices

func (x *UpdateServicesResponse) GetCurrentServices() []string

func (*UpdateServicesResponse) GetError

func (x *UpdateServicesResponse) GetError() *Error

func (*UpdateServicesResponse) GetPrevServices

func (x *UpdateServicesResponse) GetPrevServices() []string

func (*UpdateServicesResponse) ProtoMessage

func (*UpdateServicesResponse) ProtoMessage()

func (*UpdateServicesResponse) ProtoReflect

func (x *UpdateServicesResponse) ProtoReflect() protoreflect.Message

func (*UpdateServicesResponse) Reset

func (x *UpdateServicesResponse) Reset()

func (*UpdateServicesResponse) String

func (x *UpdateServicesResponse) String() string

Directories

Path Synopsis
Package mock_pbgo is a generated GoMock package.
Package mock_pbgo is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL