Documentation ¶
Index ¶
- Constants
- func AddDependenciesReqValidator() *validate.Validator
- func AddRulesReqValidator() *validate.Validator
- func AddTagsReqValidator() *validate.Validator
- func AssembleResources() (proto.ServiceCtrlServer, proto.ServiceInstanceCtrlServerEx)
- func BatchFindInstanceReqValidator() *validate.Validator
- func CommitSchemaInfo(domainProject string, serviceID string, schema *pb.Schema) []registry.PluginOp
- func CreateDependenciesReqValidator() *validate.Validator
- func CreateServiceReqValidator() *validate.Validator
- func DeleteRulesReqValidator() *validate.Validator
- func DeleteTagReqValidator() *validate.Validator
- func ExistenceReqValidator() *validate.Validator
- func FindInstanceReqValidator() *validate.Validator
- func GetInstanceReqValidator() *validate.Validator
- func GetRulesReqValidator() *validate.Validator
- func GetSchemaReqValidator() *validate.Validator
- func GetSchemasFromDatabase(ctx context.Context, domainProject string, serviceID string) ([]*pb.Schema, error)
- func GetServiceReqValidator() *validate.Validator
- func GetTagsReqValidator() *validate.Validator
- func HeartbeatReqValidator() *validate.Validator
- func MicroServiceKeyValidator() *validate.Validator
- func ModifySchemaReqValidator() *validate.Validator
- func ModifySchemasReqValidator() *validate.Validator
- func RegisterInstanceReqValidator() *validate.Validator
- func UpdateInstancePropsReqValidator() *validate.Validator
- func UpdateInstanceReqValidator() *validate.Validator
- func UpdateRuleReqValidator() *validate.Validator
- func UpdateServicePropsReqValidator() *validate.Validator
- func UpdateTagReqValidator() *validate.Validator
- func Validate(v interface{}) error
- func ValidateAccountLogin(a *rbacframe.Account) error
- func ValidateChangePWD(a *rbacframe.Account) error
- func ValidateCreateAccount(a *rbacframe.Account) error
- type InstanceService
- func (s *InstanceService) BatchFind(ctx context.Context, in *pb.BatchFindInstancesRequest) (*pb.BatchFindInstancesResponse, error)
- func (s *InstanceService) ClusterHealth(ctx context.Context) (*pb.GetInstancesResponse, error)
- func (s *InstanceService) Find(ctx context.Context, in *pb.FindInstancesRequest) (*pb.FindInstancesResponse, error)
- func (s *InstanceService) GetInstances(ctx context.Context, in *pb.GetInstancesRequest) (*pb.GetInstancesResponse, error)
- func (s *InstanceService) GetOneInstance(ctx context.Context, in *pb.GetOneInstanceRequest) (*pb.GetOneInstanceResponse, error)
- func (s *InstanceService) Heartbeat(ctx context.Context, in *pb.HeartbeatRequest) (*pb.HeartbeatResponse, error)
- func (s *InstanceService) HeartbeatSet(ctx context.Context, in *pb.HeartbeatSetRequest) (*pb.HeartbeatSetResponse, error)
- func (s *InstanceService) Register(ctx context.Context, in *pb.RegisterInstanceRequest) (*pb.RegisterInstanceResponse, error)
- func (s *InstanceService) Unregister(ctx context.Context, in *pb.UnregisterInstanceRequest) (*pb.UnregisterInstanceResponse, error)
- func (s *InstanceService) UpdateInstanceProperties(ctx context.Context, in *pb.UpdateInstancePropsRequest) (*pb.UpdateInstancePropsResponse, error)
- func (s *InstanceService) UpdateStatus(ctx context.Context, in *pb.UpdateInstanceStatusRequest) (*pb.UpdateInstanceStatusResponse, error)
- func (s *InstanceService) Watch(in *pb.WatchInstanceRequest, stream proto.ServiceInstanceCtrl_WatchServer) error
- func (s *InstanceService) WatchPreOpera(ctx context.Context, in *pb.WatchInstanceRequest) error
- func (s *InstanceService) WebSocketListAndWatch(ctx context.Context, in *pb.WatchInstanceRequest, conn *websocket.Conn)
- func (s *InstanceService) WebSocketWatch(ctx context.Context, in *pb.WatchInstanceRequest, conn *websocket.Conn)
- type MicroServiceService
- func (s *MicroServiceService) AddDependenciesForMicroServices(ctx context.Context, in *pb.AddDependenciesRequest) (*pb.AddDependenciesResponse, error)
- func (s *MicroServiceService) AddOrUpdateDependencies(ctx context.Context, dependencyInfos []*pb.ConsumerDependency, override bool) (*pb.Response, error)
- func (s *MicroServiceService) AddRule(ctx context.Context, in *pb.AddServiceRulesRequest) (*pb.AddServiceRulesResponse, error)
- func (s *MicroServiceService) AddTags(ctx context.Context, in *pb.AddServiceTagsRequest) (*pb.AddServiceTagsResponse, error)
- func (s *MicroServiceService) Create(ctx context.Context, in *pb.CreateServiceRequest) (*pb.CreateServiceResponse, error)
- func (s *MicroServiceService) CreateDependenciesForMicroServices(ctx context.Context, in *pb.CreateDependenciesRequest) (*pb.CreateDependenciesResponse, error)
- func (s *MicroServiceService) CreateServiceEx(ctx context.Context, in *pb.CreateServiceRequest, serviceID string) (*pb.CreateServiceResponse, error)
- func (s *MicroServiceService) CreateServicePri(ctx context.Context, in *pb.CreateServiceRequest) (*pb.CreateServiceResponse, error)
- func (s *MicroServiceService) Delete(ctx context.Context, in *pb.DeleteServiceRequest) (*pb.DeleteServiceResponse, error)
- func (s *MicroServiceService) DeleteRule(ctx context.Context, in *pb.DeleteServiceRulesRequest) (*pb.DeleteServiceRulesResponse, error)
- func (s *MicroServiceService) DeleteSchema(ctx context.Context, in *pb.DeleteSchemaRequest) (*pb.DeleteSchemaResponse, error)
- func (s *MicroServiceService) DeleteServicePri(ctx context.Context, serviceID string, force bool) (*pb.Response, error)
- func (s *MicroServiceService) DeleteServices(ctx context.Context, request *pb.DelServicesRequest) (*pb.DelServicesResponse, error)
- func (s *MicroServiceService) DeleteTags(ctx context.Context, in *pb.DeleteServiceTagsRequest) (*pb.DeleteServiceTagsResponse, error)
- func (s *MicroServiceService) Exist(ctx context.Context, in *pb.GetExistenceRequest) (*pb.GetExistenceResponse, error)
- func (s *MicroServiceService) GetAllSchemaInfo(ctx context.Context, in *pb.GetAllSchemaRequest) (*pb.GetAllSchemaResponse, error)
- func (s *MicroServiceService) GetConsumerDependencies(ctx context.Context, in *pb.GetDependenciesRequest) (*pb.GetConDependenciesResponse, error)
- func (s *MicroServiceService) GetOne(ctx context.Context, in *pb.GetServiceRequest) (*pb.GetServiceResponse, error)
- func (s *MicroServiceService) GetProviderDependencies(ctx context.Context, in *pb.GetDependenciesRequest) (*pb.GetProDependenciesResponse, error)
- func (s *MicroServiceService) GetRule(ctx context.Context, in *pb.GetServiceRulesRequest) (*pb.GetServiceRulesResponse, error)
- func (s *MicroServiceService) GetSchemaInfo(ctx context.Context, in *pb.GetSchemaRequest) (*pb.GetSchemaResponse, error)
- func (s *MicroServiceService) GetServices(ctx context.Context, in *pb.GetServicesRequest) (*pb.GetServicesResponse, error)
- func (s *MicroServiceService) GetTags(ctx context.Context, in *pb.GetServiceTagsRequest) (*pb.GetServiceTagsResponse, error)
- func (s *MicroServiceService) ModifySchema(ctx context.Context, request *pb.ModifySchemaRequest) (*pb.ModifySchemaResponse, error)
- func (s *MicroServiceService) ModifySchemas(ctx context.Context, in *pb.ModifySchemasRequest) (*pb.ModifySchemasResponse, error)
- func (s *MicroServiceService) UpdateProperties(ctx context.Context, in *pb.UpdateServicePropsRequest) (*pb.UpdateServicePropsResponse, error)
- func (s *MicroServiceService) UpdateRule(ctx context.Context, in *pb.UpdateServiceRuleRequest) (*pb.UpdateServiceRuleResponse, error)
- func (s *MicroServiceService) UpdateTag(ctx context.Context, in *pb.UpdateServiceTagRequest) (*pb.UpdateServiceTagResponse, error)
Constants ¶
const ( ExistTypeMicroservice = "microservice" ExistTypeSchema = "schema" )
Variables ¶
This section is empty.
Functions ¶
func AddRulesReqValidator ¶
func AddTagsReqValidator ¶
func AssembleResources ¶
func AssembleResources() (proto.ServiceCtrlServer, proto.ServiceInstanceCtrlServerEx)
func CommitSchemaInfo ¶
func DeleteRulesReqValidator ¶
func DeleteTagReqValidator ¶
func ExistenceReqValidator ¶
func GetInstanceReqValidator ¶
func GetRulesReqValidator ¶
func GetSchemaReqValidator ¶
func GetSchemasFromDatabase ¶
func GetServiceReqValidator ¶
func GetTagsReqValidator ¶
func HeartbeatReqValidator ¶
func UpdateRuleReqValidator ¶
func UpdateTagReqValidator ¶
func ValidateAccountLogin ¶
func ValidateChangePWD ¶
func ValidateCreateAccount ¶
Types ¶
type InstanceService ¶
type InstanceService struct { }
func (*InstanceService) BatchFind ¶
func (s *InstanceService) BatchFind(ctx context.Context, in *pb.BatchFindInstancesRequest) (*pb.BatchFindInstancesResponse, error)
func (*InstanceService) ClusterHealth ¶
func (s *InstanceService) ClusterHealth(ctx context.Context) (*pb.GetInstancesResponse, error)
func (*InstanceService) Find ¶
func (s *InstanceService) Find(ctx context.Context, in *pb.FindInstancesRequest) (*pb.FindInstancesResponse, error)
func (*InstanceService) GetInstances ¶
func (s *InstanceService) GetInstances(ctx context.Context, in *pb.GetInstancesRequest) (*pb.GetInstancesResponse, error)
func (*InstanceService) GetOneInstance ¶
func (s *InstanceService) GetOneInstance(ctx context.Context, in *pb.GetOneInstanceRequest) (*pb.GetOneInstanceResponse, error)
func (*InstanceService) Heartbeat ¶
func (s *InstanceService) Heartbeat(ctx context.Context, in *pb.HeartbeatRequest) (*pb.HeartbeatResponse, error)
func (*InstanceService) HeartbeatSet ¶
func (s *InstanceService) HeartbeatSet(ctx context.Context, in *pb.HeartbeatSetRequest) (*pb.HeartbeatSetResponse, error)
func (*InstanceService) Register ¶
func (s *InstanceService) Register(ctx context.Context, in *pb.RegisterInstanceRequest) (*pb.RegisterInstanceResponse, error)
func (*InstanceService) Unregister ¶
func (s *InstanceService) Unregister(ctx context.Context, in *pb.UnregisterInstanceRequest) (*pb.UnregisterInstanceResponse, error)
func (*InstanceService) UpdateInstanceProperties ¶
func (s *InstanceService) UpdateInstanceProperties(ctx context.Context, in *pb.UpdateInstancePropsRequest) (*pb.UpdateInstancePropsResponse, error)
func (*InstanceService) UpdateStatus ¶
func (s *InstanceService) UpdateStatus(ctx context.Context, in *pb.UpdateInstanceStatusRequest) (*pb.UpdateInstanceStatusResponse, error)
func (*InstanceService) Watch ¶
func (s *InstanceService) Watch(in *pb.WatchInstanceRequest, stream proto.ServiceInstanceCtrl_WatchServer) error
func (*InstanceService) WatchPreOpera ¶
func (s *InstanceService) WatchPreOpera(ctx context.Context, in *pb.WatchInstanceRequest) error
func (*InstanceService) WebSocketListAndWatch ¶
func (s *InstanceService) WebSocketListAndWatch(ctx context.Context, in *pb.WatchInstanceRequest, conn *websocket.Conn)
func (*InstanceService) WebSocketWatch ¶
func (s *InstanceService) WebSocketWatch(ctx context.Context, in *pb.WatchInstanceRequest, conn *websocket.Conn)
type MicroServiceService ¶
type MicroServiceService struct {
// contains filtered or unexported fields
}
func NewMicroServiceService ¶
func NewMicroServiceService(schemaEditable bool, instCtrlServer proto.ServiceInstanceCtrlServerEx) *MicroServiceService
func (*MicroServiceService) AddDependenciesForMicroServices ¶
func (s *MicroServiceService) AddDependenciesForMicroServices(ctx context.Context, in *pb.AddDependenciesRequest) (*pb.AddDependenciesResponse, error)
func (*MicroServiceService) AddOrUpdateDependencies ¶
func (s *MicroServiceService) AddOrUpdateDependencies(ctx context.Context, dependencyInfos []*pb.ConsumerDependency, override bool) (*pb.Response, error)
func (*MicroServiceService) AddRule ¶
func (s *MicroServiceService) AddRule(ctx context.Context, in *pb.AddServiceRulesRequest) (*pb.AddServiceRulesResponse, error)
func (*MicroServiceService) AddTags ¶
func (s *MicroServiceService) AddTags(ctx context.Context, in *pb.AddServiceTagsRequest) (*pb.AddServiceTagsResponse, error)
func (*MicroServiceService) Create ¶
func (s *MicroServiceService) Create(ctx context.Context, in *pb.CreateServiceRequest) (*pb.CreateServiceResponse, error)
func (*MicroServiceService) CreateDependenciesForMicroServices ¶
func (s *MicroServiceService) CreateDependenciesForMicroServices(ctx context.Context, in *pb.CreateDependenciesRequest) (*pb.CreateDependenciesResponse, error)
func (*MicroServiceService) CreateServiceEx ¶
func (s *MicroServiceService) CreateServiceEx(ctx context.Context, in *pb.CreateServiceRequest, serviceID string) (*pb.CreateServiceResponse, error)
func (*MicroServiceService) CreateServicePri ¶
func (s *MicroServiceService) CreateServicePri(ctx context.Context, in *pb.CreateServiceRequest) (*pb.CreateServiceResponse, error)
func (*MicroServiceService) Delete ¶
func (s *MicroServiceService) Delete(ctx context.Context, in *pb.DeleteServiceRequest) (*pb.DeleteServiceResponse, error)
func (*MicroServiceService) DeleteRule ¶
func (s *MicroServiceService) DeleteRule(ctx context.Context, in *pb.DeleteServiceRulesRequest) (*pb.DeleteServiceRulesResponse, error)
func (*MicroServiceService) DeleteSchema ¶
func (s *MicroServiceService) DeleteSchema(ctx context.Context, in *pb.DeleteSchemaRequest) (*pb.DeleteSchemaResponse, error)
func (*MicroServiceService) DeleteServicePri ¶
func (*MicroServiceService) DeleteServices ¶
func (s *MicroServiceService) DeleteServices(ctx context.Context, request *pb.DelServicesRequest) (*pb.DelServicesResponse, error)
func (*MicroServiceService) DeleteTags ¶
func (s *MicroServiceService) DeleteTags(ctx context.Context, in *pb.DeleteServiceTagsRequest) (*pb.DeleteServiceTagsResponse, error)
func (*MicroServiceService) Exist ¶
func (s *MicroServiceService) Exist(ctx context.Context, in *pb.GetExistenceRequest) (*pb.GetExistenceResponse, error)
func (*MicroServiceService) GetAllSchemaInfo ¶
func (s *MicroServiceService) GetAllSchemaInfo(ctx context.Context, in *pb.GetAllSchemaRequest) (*pb.GetAllSchemaResponse, error)
func (*MicroServiceService) GetConsumerDependencies ¶
func (s *MicroServiceService) GetConsumerDependencies(ctx context.Context, in *pb.GetDependenciesRequest) (*pb.GetConDependenciesResponse, error)
func (*MicroServiceService) GetOne ¶
func (s *MicroServiceService) GetOne(ctx context.Context, in *pb.GetServiceRequest) (*pb.GetServiceResponse, error)
func (*MicroServiceService) GetProviderDependencies ¶
func (s *MicroServiceService) GetProviderDependencies(ctx context.Context, in *pb.GetDependenciesRequest) (*pb.GetProDependenciesResponse, error)
func (*MicroServiceService) GetRule ¶
func (s *MicroServiceService) GetRule(ctx context.Context, in *pb.GetServiceRulesRequest) (*pb.GetServiceRulesResponse, error)
func (*MicroServiceService) GetSchemaInfo ¶
func (s *MicroServiceService) GetSchemaInfo(ctx context.Context, in *pb.GetSchemaRequest) (*pb.GetSchemaResponse, error)
func (*MicroServiceService) GetServices ¶
func (s *MicroServiceService) GetServices(ctx context.Context, in *pb.GetServicesRequest) (*pb.GetServicesResponse, error)
func (*MicroServiceService) GetTags ¶
func (s *MicroServiceService) GetTags(ctx context.Context, in *pb.GetServiceTagsRequest) (*pb.GetServiceTagsResponse, error)
func (*MicroServiceService) ModifySchema ¶
func (s *MicroServiceService) ModifySchema(ctx context.Context, request *pb.ModifySchemaRequest) (*pb.ModifySchemaResponse, error)
ModifySchema modifies a specific schema 1. When the service is in production environment and schema is not editable: If the request contains a new schemaID (the number of schemaIDs of the service is also required to be 0, or the request will be rejected), the new schemaID will be automatically added to the service information. Schema is only allowed to add. 2. Other cases: If the request contains a new schemaID, the new schemaID will be automatically added to the service information. Schema is allowed to add/modify.
func (*MicroServiceService) ModifySchemas ¶
func (s *MicroServiceService) ModifySchemas(ctx context.Context, in *pb.ModifySchemasRequest) (*pb.ModifySchemasResponse, error)
ModifySchemas covers all the schemas of a service. To cover the old schemas, ModifySchemas adds new schemas into, delete and modify the old schemas. 1. When the service is in production environment and schema is not editable: If the request contains a new schemaID (the number of schemaIDs of the service is also required to be 0, or the request will be rejected), the new schemaID will be automatically added to the service information. Schema is only allowed to add. 2. Other cases: If the request contains a new schemaID, the new schemaID will be automatically added to the service information. Schema is allowed to add/delete/modify.
func (*MicroServiceService) UpdateProperties ¶
func (s *MicroServiceService) UpdateProperties(ctx context.Context, in *pb.UpdateServicePropsRequest) (*pb.UpdateServicePropsResponse, error)
func (*MicroServiceService) UpdateRule ¶
func (s *MicroServiceService) UpdateRule(ctx context.Context, in *pb.UpdateServiceRuleRequest) (*pb.UpdateServiceRuleResponse, error)
func (*MicroServiceService) UpdateTag ¶
func (s *MicroServiceService) UpdateTag(ctx context.Context, in *pb.UpdateServiceTagRequest) (*pb.UpdateServiceTagResponse, error)
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements.
|
* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. |
Package kv supplies kv store
|
Package kv supplies kv store |
dao
Package rbac is dao layer API to help service center manage account, policy and role info
|
Package rbac is dao layer API to help service center manage account, policy and role info |
* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements.
|
* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. |