service

package
v1.4.8 Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2021 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ExistTypeMicroservice = "microservice"
	ExistTypeSchema       = "schema"
)

Variables

This section is empty.

Functions

func AddDependenciesReqValidator 

func AddDependenciesReqValidator() *validate.Validator

func AddRulesReqValidator 

func AddRulesReqValidator() *validate.Validator

func AddTagsReqValidator 

func AddTagsReqValidator() *validate.Validator

func AssembleResources 

func AssembleResources() (proto.ServiceCtrlServer, proto.ServiceInstanceCtrlServerEx)

func BatchFindInstanceReqValidator 

func BatchFindInstanceReqValidator() *validate.Validator

func CommitSchemaInfo 

func CommitSchemaInfo(domainProject string, serviceID string, schema *pb.Schema) []registry.PluginOp

func CreateDependenciesReqValidator 

func CreateDependenciesReqValidator() *validate.Validator

func CreateServiceReqValidator 

func CreateServiceReqValidator() *validate.Validator

func DeleteRulesReqValidator 

func DeleteRulesReqValidator() *validate.Validator

func DeleteTagReqValidator 

func DeleteTagReqValidator() *validate.Validator

func ExistenceReqValidator 

func ExistenceReqValidator() *validate.Validator

func FindInstanceReqValidator 

func FindInstanceReqValidator() *validate.Validator

func GetInstanceReqValidator 

func GetInstanceReqValidator() *validate.Validator

func GetRulesReqValidator 

func GetRulesReqValidator() *validate.Validator

func GetSchemaReqValidator 

func GetSchemaReqValidator() *validate.Validator

func GetSchemasFromDatabase 

func GetSchemasFromDatabase(ctx context.Context, domainProject string, serviceID string) ([]*pb.Schema, error)

func GetServiceReqValidator 

func GetServiceReqValidator() *validate.Validator

func GetTagsReqValidator 

func GetTagsReqValidator() *validate.Validator

func HeartbeatReqValidator 

func HeartbeatReqValidator() *validate.Validator

func MicroServiceKeyValidator 

func MicroServiceKeyValidator() *validate.Validator

func ModifySchemaReqValidator 

func ModifySchemaReqValidator() *validate.Validator

func ModifySchemasReqValidator 

func ModifySchemasReqValidator() *validate.Validator

func RegisterInstanceReqValidator 

func RegisterInstanceReqValidator() *validate.Validator

func UpdateInstancePropsReqValidator 

func UpdateInstancePropsReqValidator() *validate.Validator

func UpdateInstanceReqValidator 

func UpdateInstanceReqValidator() *validate.Validator

func UpdateRuleReqValidator 

func UpdateRuleReqValidator() *validate.Validator

func UpdateServicePropsReqValidator 

func UpdateServicePropsReqValidator() *validate.Validator

func UpdateTagReqValidator 

func UpdateTagReqValidator() *validate.Validator

func Validate 

func Validate(v interface{}) error

func ValidateAccountLogin 

func ValidateAccountLogin(a *rbacframe.Account) error

func ValidateChangePWD 

func ValidateChangePWD(a *rbacframe.Account) error

func ValidateCreateAccount 

func ValidateCreateAccount(a *rbacframe.Account) error

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 (s *MicroServiceService) DeleteServicePri(ctx context.Context, serviceID string, force bool) (*pb.Response, error)

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

View all Source files

Directories

Path Synopsis
etcd
dep
etcd
* 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
etcd
ms
etcd
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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.