Documentation
¶
Index ¶
- func NewIncrementalRegister() identityapi.RegisterClient
- func NewRetryAfterRegister() identityapi.RegisterClient
- func NewRetryBackoffRegister() identityapi.RegisterClient
- type EmptyRegisterClient
- func (icc *EmptyRegisterClient) RegisterBatchEntities(agentEntityID entity.ID, entities []entity.Fields) (r []identityapi.RegisterEntityResponse, err error)
- func (icc *EmptyRegisterClient) RegisterEntitiesRemoveMe(agentEntityID entity.ID, entities []identityapi.RegisterEntity) (r []identityapi.RegisterEntityResponse, retryAfter time.Duration, err error)
- func (icc *EmptyRegisterClient) RegisterEntity(agentEntityID entity.ID, entity entity.Fields) (resp identityapi.RegisterEntityResponse, err error)
- type IncrementalRegister
- func (r *IncrementalRegister) RegisterBatchEntities(agentEntityID entity.ID, entities []entity.Fields) (batchResponse []identityapi.RegisterEntityResponse, err error)
- func (r *IncrementalRegister) RegisterEntitiesRemoveMe(agentEntityID entity.ID, entities []identityapi.RegisterEntity) (responseKeys []identityapi.RegisterEntityResponse, retryAfter time.Duration, ...)
- func (r *IncrementalRegister) RegisterEntity(agentEntityID entity.ID, ent entity.Fields) (identityapi.RegisterEntityResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewIncrementalRegister ¶
func NewIncrementalRegister() identityapi.RegisterClient
func NewRetryAfterRegister ¶
func NewRetryAfterRegister() identityapi.RegisterClient
func NewRetryBackoffRegister ¶
func NewRetryBackoffRegister() identityapi.RegisterClient
Types ¶
type EmptyRegisterClient ¶
type EmptyRegisterClient struct{}
func (*EmptyRegisterClient) RegisterBatchEntities ¶
func (icc *EmptyRegisterClient) RegisterBatchEntities(agentEntityID entity.ID, entities []entity.Fields) (r []identityapi.RegisterEntityResponse, err error)
func (*EmptyRegisterClient) RegisterEntitiesRemoveMe ¶
func (icc *EmptyRegisterClient) RegisterEntitiesRemoveMe(agentEntityID entity.ID, entities []identityapi.RegisterEntity) (r []identityapi.RegisterEntityResponse, retryAfter time.Duration, err error)
func (*EmptyRegisterClient) RegisterEntity ¶
func (icc *EmptyRegisterClient) RegisterEntity(agentEntityID entity.ID, entity entity.Fields) (resp identityapi.RegisterEntityResponse, err error)
type IncrementalRegister ¶
type IncrementalRegister struct {
// contains filtered or unexported fields
}
func (*IncrementalRegister) RegisterBatchEntities ¶
func (r *IncrementalRegister) RegisterBatchEntities(agentEntityID entity.ID, entities []entity.Fields) (batchResponse []identityapi.RegisterEntityResponse, err error)
func (*IncrementalRegister) RegisterEntitiesRemoveMe ¶
func (r *IncrementalRegister) RegisterEntitiesRemoveMe(agentEntityID entity.ID, entities []identityapi.RegisterEntity) (responseKeys []identityapi.RegisterEntityResponse, retryAfter time.Duration, err error)
func (*IncrementalRegister) RegisterEntity ¶
func (r *IncrementalRegister) RegisterEntity(agentEntityID entity.ID, ent entity.Fields) (identityapi.RegisterEntityResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.