service

Documentation

Index

• type Service
  • func New(superSpec *supervisor.Spec, store storage.Storage) *Service
  • func (s *Service) DeleteIngressSpec(ingressName string)
  • func (s *Service) DeleteServiceSpec(serviceName string)
  • func (s *Service) DeleteTenantSpec(tenantName string)
  • func (s *Service) GetGlobalCanaryHeaders() *spec.GlobalCanaryHeaders
  • func (s *Service) GetGlobalCanaryHeadersWithInfo() (*spec.GlobalCanaryHeaders, *mvccpb.KeyValue)
  • func (s *Service) GetIngressSpec(ingressName string) *spec.Ingress
  • func (s *Service) GetIngressSpecWithInfo(ingressName string) (*spec.Ingress, *mvccpb.KeyValue)
  • func (s *Service) GetServiceInstanceSpec(serviceName, instanceID string) *spec.ServiceInstanceSpec
  • func (s *Service) GetServiceSpec(serviceName string) *spec.Service
  • func (s *Service) GetServiceSpecWithInfo(serviceName string) (*spec.Service, *mvccpb.KeyValue)
  • func (s *Service) GetTenantSpec(tenantName string) *spec.Tenant
  • func (s *Service) GetTenantSpecWithInfo(tenantName string) (*spec.Tenant, *mvccpb.KeyValue)
  • func (s *Service) ListAllServiceInstanceSpecs() []*spec.ServiceInstanceSpec
  • func (s *Service) ListAllServiceInstanceStatuses() []*spec.ServiceInstanceStatus
  • func (s *Service) ListIngressSpecs() []*spec.Ingress
  • func (s *Service) ListServiceInstanceSpecs(serviceName string) []*spec.ServiceInstanceSpec
  • func (s *Service) ListServiceInstanceStatuses(serviceName string) []*spec.ServiceInstanceStatus
  • func (s *Service) ListServiceSpecs() []*spec.Service
  • func (s *Service) ListTenantSpecs() []*spec.Tenant
  • func (s *Service) Lock()
  • func (s *Service) PutGlobalCanaryHeaders(globalCanaryHeaders *spec.GlobalCanaryHeaders)
  • func (s *Service) PutIngressSpec(ingressSpec *spec.Ingress)
  • func (s *Service) PutServiceInstanceSpec(_spec *spec.ServiceInstanceSpec)
  • func (s *Service) PutServiceSpec(serviceSpec *spec.Service)
  • func (s *Service) PutTenantSpec(tenantSpec *spec.Tenant)
  • func (s *Service) Unlock()

Types

type Service

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

Service is the business layer between mesh and store. It is not concurrently safe, the users need to do it by themselves.

func New

func New(superSpec *supervisor.Spec, store storage.Storage) *Service

func (*Service) DeleteIngressSpec

func (s *Service) DeleteIngressSpec(ingressName string)

func (*Service) DeleteServiceSpec

func (s *Service) DeleteServiceSpec(serviceName string)

func (*Service) DeleteTenantSpec

func (s *Service) DeleteTenantSpec(tenantName string)

func (*Service) GetGlobalCanaryHeaders

func (s *Service) GetGlobalCanaryHeaders() *spec.GlobalCanaryHeaders

func (*Service) GetGlobalCanaryHeadersWithInfo

func (s *Service) GetGlobalCanaryHeadersWithInfo() (*spec.GlobalCanaryHeaders, *mvccpb.KeyValue)

func (*Service) GetIngressSpec

func (s *Service) GetIngressSpec(ingressName string) *spec.Ingress

func (*Service) GetIngressSpecWithInfo

func (s *Service) GetIngressSpecWithInfo(ingressName string) (*spec.Ingress, *mvccpb.KeyValue)

func (*Service) GetServiceInstanceSpec

func (s *Service) GetServiceInstanceSpec(serviceName, instanceID string) *spec.ServiceInstanceSpec

func (*Service) GetServiceSpec

func (s *Service) GetServiceSpec(serviceName string) *spec.Service

func (*Service) GetServiceSpecWithInfo

func (s *Service) GetServiceSpecWithInfo(serviceName string) (*spec.Service, *mvccpb.KeyValue)

func (*Service) GetTenantSpec

func (s *Service) GetTenantSpec(tenantName string) *spec.Tenant

func (*Service) GetTenantSpecWithInfo

func (s *Service) GetTenantSpecWithInfo(tenantName string) (*spec.Tenant, *mvccpb.KeyValue)

func (*Service) ListAllServiceInstanceSpecs

func (s *Service) ListAllServiceInstanceSpecs() []*spec.ServiceInstanceSpec

func (*Service) ListAllServiceInstanceStatuses

func (s *Service) ListAllServiceInstanceStatuses() []*spec.ServiceInstanceStatus

func (*Service) ListIngressSpecs

func (s *Service) ListIngressSpecs() []*spec.Ingress

func (*Service) ListServiceInstanceSpecs

func (s *Service) ListServiceInstanceSpecs(serviceName string) []*spec.ServiceInstanceSpec

func (*Service) ListServiceInstanceStatuses

func (s *Service) ListServiceInstanceStatuses(serviceName string) []*spec.ServiceInstanceStatus

func (*Service) ListServiceSpecs

func (s *Service) ListServiceSpecs() []*spec.Service

func (*Service) ListTenantSpecs

func (s *Service) ListTenantSpecs() []*spec.Tenant

func (*Service) Lock

func (s *Service) Lock()

Lock locks all store, it will do cluster panic if failed.

func (*Service) PutGlobalCanaryHeaders

func (s *Service) PutGlobalCanaryHeaders(globalCanaryHeaders *spec.GlobalCanaryHeaders)

func (*Service) PutIngressSpec

func (s *Service) PutIngressSpec(ingressSpec *spec.Ingress)

func (*Service) PutServiceInstanceSpec

func (s *Service) PutServiceInstanceSpec(_spec *spec.ServiceInstanceSpec)

func (*Service) PutServiceSpec

func (s *Service) PutServiceSpec(serviceSpec *spec.Service)

func (*Service) PutTenantSpec

func (s *Service) PutTenantSpec(tenantSpec *spec.Tenant)

func (*Service) Unlock

func (s *Service) Unlock()

Lock unlocks all store, it will do cluster panic if failed.