Versions in this module Expand all Collapse all v0 v0.2.0 Apr 23, 2026 Changes in this version + type CompleteInput struct + CommandID string + Result json.RawMessage + TenantID string + type CreateInput struct + AgentID string + ExpiresIn int + Payload json.RawMessage + Priority string + TenantID string + Type string + type ExpirationChecker struct + func NewExpirationChecker(commandRepo commanddom.Repository, pipelineService *pipeline.Service, ...) *ExpirationChecker + func (c *ExpirationChecker) Start() + func (c *ExpirationChecker) Stop() + type ExpirationCheckerConfig struct + CheckInterval time.Duration + type FailInput struct + CommandID string + ErrorMessage string + TenantID string + type ListInput struct + AgentID string + Page int + PerPage int + Priority string + Status string + TenantID string + Type string + type PollInput struct + AgentID string + Limit int + TenantID string + type Service struct + func NewService(repo commanddom.Repository, log *logger.Logger) *Service + func (s *Service) Acknowledge(ctx context.Context, tenantID, commandID string) (*commanddom.Command, error) + func (s *Service) CancelCommand(ctx context.Context, tenantID, commandID string) (*commanddom.Command, error) + func (s *Service) Complete(ctx context.Context, input CompleteInput) (*commanddom.Command, error) + func (s *Service) Create(ctx context.Context, input CreateInput) (*commanddom.Command, error) + func (s *Service) DeleteCommand(ctx context.Context, tenantID, commandID string) error + func (s *Service) ExpireOldCommands(ctx context.Context) (int64, error) + func (s *Service) Fail(ctx context.Context, input FailInput) (*commanddom.Command, error) + func (s *Service) Get(ctx context.Context, tenantID, commandID string) (*commanddom.Command, error) + func (s *Service) List(ctx context.Context, input ListInput) (pagination.Result[*commanddom.Command], error) + func (s *Service) Poll(ctx context.Context, input PollInput) ([]*commanddom.Command, error) + func (s *Service) Start(ctx context.Context, tenantID, commandID string) (*commanddom.Command, error)
Go to main page