orchestrator

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

type ClientRunner interface {
	CheckHealth(ctx context.Context) error
	SubmitDeviceDecommisioningJob(ctx context.Context, req DecommissioningReq) error
	SubmitProvisionDeviceJob(ctx context.Context, req ProvisionDeviceReq) error
	SubmitUpdateDeviceStatusJob(ctx context.Context, req UpdateDeviceStatusReq) error
	SubmitDeviceLimitWarning(ctx context.Context, devWarn DeviceLimitWarning) error
	SubmitUpdateDeviceInventoryJob(ctx context.Context, req UpdateDeviceInventoryReq) error
	SubmitReindexReporting(c context.Context, device string) error
	SubmitReindexReportingBatch(c context.Context, devices []string) error
}

type Config struct {
	// Orchestrator host
	OrchestratorAddr string
	// Request timeout
	Timeout time.Duration
}

type DecommissioningReq struct {
	// Device ID
	DeviceId string `json:"device_id"`
	// Request ID
	RequestId string `json:"request_id"`
	// TenantID
	TenantID string `json:"tenant_id"`
}

type DeviceLimitWarning struct {
	RequestID string `json:"request_id"`

	RecipientEmail string `json:"to"`

	Subject          string `json:"subject"`
	Body             string `json:"body"`
	BodyHTML         string `json:"html"`
	RemainingDevices *uint  `json:"remaining_devices"`
}

type ProvisionDeviceReq struct {
	// Request ID
	RequestId string `json:"request_id"`
	// DeviceID
	DeviceID string `json:"device_id"`
	// TenantID
	TenantID string `json:"tenant_id"`

	Device *model.Device `json:"device"`
	Status string        `json:"status"`
}

type ReindexReportingWorkflow struct {
	RequestID string `json:"request_id"`
	TenantID  string `json:"tenant_id"`
	DeviceID  string `json:"device_id"`
	Service   string `json:"service"`
}

type UpdateDeviceInventoryReq struct {
	// Request ID
	RequestId string `json:"request_id"`
	// Tenant ID
	TenantId string `json:"tenant_id"`
	// Device ID
	DeviceId string `json:"device_id"`
	// Attributes scope
	Scope string `json:"scope"`
	// Device inventory attributes
	Attributes string `json:"attributes"`
}

type UpdateDeviceStatusReq struct {
	// Request ID
	RequestId string `json:"request_id"`
	// Device IDs
	Devices []model.DeviceInventoryUpdate `json:"devices"`
	// Tenant ID
	TenantId string `json:"tenant_id"`
	// new status
	Status string `json:"device_status"`
}