etcd

Documentation

Index

• Variables
• func GetLeaseID(ctx context.Context, domainProject string, serviceID string, instanceID string) (int64, error)
• func HeartbeatUtil(ctx context.Context, domainProject string, serviceID string, instanceID string) (leaseID int64, ttl int64, _ *scerr.Error)
• func KeepAliveLease(ctx context.Context, domainProject, serviceID, instanceID string, ...) (ttl int64, err error)
• type DataSource
  • func NewDataSource(opts ms.Options) *DataSource
  • func (ds *DataSource) AddRule()
  • func (ds *DataSource) AddTag()
  • func (ds *DataSource) DeleteRule()
  • func (ds *DataSource) DeleteSchema()
  • func (ds *DataSource) DeleteServicePri(ctx context.Context, serviceID string, force bool) (*pb.Response, error)
  • func (ds *DataSource) DeleteTag()
  • func (ds *DataSource) ExistSchema(ctx context.Context, request *pb.GetExistenceRequest) (*pb.GetExistenceResponse, error)
  • func (ds *DataSource) ExistService(ctx context.Context, request *pb.GetExistenceRequest) (*pb.GetExistenceResponse, error)
  • func (ds *DataSource) GetDeleteServiceFunc(ctx context.Context, serviceID string, force bool, ...) func(context.Context)
  • func (ds *DataSource) GetRule()
  • func (ds *DataSource) GetSchema()
  • func (ds *DataSource) GetService(ctx context.Context, request *pb.GetServiceRequest) (*pb.GetServiceResponse, error)
  • func (ds *DataSource) GetServices(ctx context.Context, request *pb.GetServicesRequest) (*pb.GetServicesResponse, error)
  • func (ds *DataSource) GetTag()
  • func (ds *DataSource) Heartbeat(ctx context.Context, request *pb.HeartbeatRequest) (*pb.HeartbeatResponse, error)
  • func (ds *DataSource) ModifySchema(ctx context.Context, request *pb.ModifySchemaRequest) (*pb.ModifySchemaResponse, error)
  • func (ds *DataSource) ModifySchemas(ctx context.Context, request *pb.ModifySchemasRequest) (*pb.ModifySchemasResponse, error)
  • func (ds *DataSource) RegisterInstance(ctx context.Context, request *pb.RegisterInstanceRequest) (*pb.RegisterInstanceResponse, error)
  • func (ds *DataSource) RegisterService(ctx context.Context, request *pb.CreateServiceRequest) (*pb.CreateServiceResponse, error)
  • func (ds *DataSource) SearchInstance()
  • func (ds *DataSource) UnRegisterInstance()
  • func (ds *DataSource) UnregisterService(ctx context.Context, request *pb.DeleteServiceRequest) (*pb.DeleteServiceResponse, error)
  • func (ds *DataSource) UpdateInstance()
  • func (ds *DataSource) UpdateRule()
  • func (ds *DataSource) UpdateService(ctx context.Context, request *pb.UpdateServicePropsRequest) (*pb.UpdateServicePropsResponse, error)
  • func (ds *DataSource) UpdateTag()

Variables

var (
	ErrLeaseIDNotExist = errors.New("leaseId not exist, instance not exist")
)

Functions

func GetLeaseID

func GetLeaseID(ctx context.Context, domainProject string, serviceID string, instanceID string) (int64, error)

heartbeat util

func HeartbeatUtil

func HeartbeatUtil(ctx context.Context, domainProject string, serviceID string, instanceID string) (leaseID int64, ttl int64, _ *scerr.Error)

instance util

func KeepAliveLease

func KeepAliveLease(ctx context.Context, domainProject, serviceID, instanceID string, leaseID int64) (
	ttl int64, err error)

Types

type DataSource

type DataSource struct {
	// schemaEditable determines whether schema modification is allowed for
	SchemaEditable bool
	// contains filtered or unexported fields
}

func NewDataSource

func NewDataSource(opts ms.Options) *DataSource

func (*DataSource) AddRule

func (ds *DataSource) AddRule()

func (*DataSource) AddTag

func (ds *DataSource) AddTag()

func (*DataSource) DeleteRule

func (ds *DataSource) DeleteRule()

func (*DataSource) DeleteSchema

func (ds *DataSource) DeleteSchema()

func (*DataSource) DeleteServicePri

func (ds *DataSource) DeleteServicePri(ctx context.Context, serviceID string, force bool) (*pb.Response, error)

func (*DataSource) DeleteTag

func (ds *DataSource) DeleteTag()

func (*DataSource) ExistSchema

func (ds *DataSource) ExistSchema(ctx context.Context, request *pb.GetExistenceRequest) (
	*pb.GetExistenceResponse, error)

func (*DataSource) ExistService

func (ds *DataSource) ExistService(ctx context.Context, request *pb.GetExistenceRequest) (*pb.GetExistenceResponse,
	error)

func (*DataSource) GetDeleteServiceFunc

func (ds *DataSource) GetDeleteServiceFunc(ctx context.Context, serviceID string, force bool,
	serviceRespChan chan<- *pb.DelServicesRspInfo) func(context.Context)

func (*DataSource) GetRule

func (ds *DataSource) GetRule()

func (*DataSource) GetSchema

func (ds *DataSource) GetSchema()

func (*DataSource) GetService

func (ds *DataSource) GetService(ctx context.Context, request *pb.GetServiceRequest) (
	*pb.GetServiceResponse, error)

func (*DataSource) GetServices

func (ds *DataSource) GetServices(ctx context.Context, request *pb.GetServicesRequest) (
	*pb.GetServicesResponse, error)

func (*DataSource) GetTag

func (ds *DataSource) GetTag()

func (*DataSource) Heartbeat

func (ds *DataSource) Heartbeat(ctx context.Context, request *pb.HeartbeatRequest) (*pb.HeartbeatResponse, error)

func (*DataSource) ModifySchema

func (ds *DataSource) ModifySchema(ctx context.Context, request *pb.ModifySchemaRequest) (
	*pb.ModifySchemaResponse, error)

func (*DataSource) ModifySchemas

func (ds *DataSource) ModifySchemas(ctx context.Context, request *pb.ModifySchemasRequest) (
	*pb.ModifySchemasResponse, error)

func (*DataSource) RegisterInstance

func (ds *DataSource) RegisterInstance(ctx context.Context, request *pb.RegisterInstanceRequest) (
	*pb.RegisterInstanceResponse, error)

func (*DataSource) RegisterService

func (ds *DataSource) RegisterService(ctx context.Context, request *pb.CreateServiceRequest) (
	*pb.CreateServiceResponse, error)

RegisterService() implement: 1. capsule request to etcd kv format 2. invoke etcd client to store data 3. check etcd-client response && construct createServiceResponse

func (*DataSource) SearchInstance

func (ds *DataSource) SearchInstance()

func (*DataSource) UnRegisterInstance

func (ds *DataSource) UnRegisterInstance()

func (*DataSource) UnregisterService

func (ds *DataSource) UnregisterService(ctx context.Context, request *pb.DeleteServiceRequest) (
	*pb.DeleteServiceResponse, error)

func (*DataSource) UpdateInstance

func (ds *DataSource) UpdateInstance()

func (*DataSource) UpdateRule

func (ds *DataSource) UpdateRule()

func (*DataSource) UpdateService

func (ds *DataSource) UpdateService(ctx context.Context, request *pb.UpdateServicePropsRequest) (
	*pb.UpdateServicePropsResponse, error)

func (*DataSource) UpdateTag

func (ds *DataSource) UpdateTag()