client

type AccessMode int

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

type AutoUploadableState struct {
	Active bool `json:"active"`

	StartTime *time.Time `json:"startTime"`
	EndTime   *time.Time `json:"endTime"`
}

type BrokerConfig struct {
	Broker   string `json:"broker,omitempty" def:"tcp://localhost:1883" descr:"Local MQTT broker address"`
	Username string `json:"username,omitempty" descr:"Username for authorized local client"`
	Password string `json:"password,omitempty" descr:"Password for authorized local client"`
	CaCert   string `json:"caCert,omitempty" descr:"A PEM encoded CA certificates 'file' for MQTT broker connection"`
	Cert     string `json:"cert,omitempty" descr:"A PEM encoded certificate 'file' for MQTT broker connection"`
	Key      string `json:"key,omitempty" descr:"A PEM encoded unencrypted private key 'file' for MQTT broker connection"`
}

type Duration time.Duration

type EdgeClient interface {
	Connect(client MQTT.Client, cfg *EdgeConfiguration)
	Disconnect()
}

type EdgeConfiguration struct {
	DeviceID string `json:"deviceId"`
	TenantID string `json:"tenantId"`
	PolicyID string `json:"policyId"`
}

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

type ErrorCode string

type ErrorResponse struct {
	Status    int       `json:"status"`
	ErrorCode ErrorCode `json:"error"`
	Message   string    `json:"message"`
}

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

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

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

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

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

type Upload interface {
	// contains filtered or unexported methods
}

type UploadCustomizer interface {
	// DoTrigger is responsible for starting file uploads (by calling UploadFiles).
	// Called when trigger operation is invoked from the backend.
	DoTrigger(correlationID string, options map[string]string) error

	// HandleOperation is called when unknown operation is invoked from the backend.
	// Used when extending AutoUploadable with new operations
	HandleOperation(operation string, payload []byte) *ErrorResponse

	// OnTick is called by the periodic executor. Handles AutoUploadable period tasks.
	OnTick()
}

type UploadStatus struct {
	CorrelationID string `json:"correlationId"`
	State         string `json:"state"`

	StartTime  time.Time `json:"startTime"`
	EndTime    time.Time `json:"endTime"`
	StatusCode string    `json:"statusCode"`
	Message    string    `json:"message"`

	Progress int `json:"progress"`

	Info map[string]string `json:"info"`
}

type UploadStatusListener interface {
	// contains filtered or unexported methods
}

type UploadableConfig struct {
	FeatureID string   `` /* 265-byte string literal not displayed */
	Context   string   `` /* 128-byte string literal not displayed */
	Type      string   `json:"type,omitempty" def:"file" descr:"Type of the files, uploaded by {feature} feature."`
	Period    Duration `` /* 243-byte string literal not displayed */

	Active     bool  `json:"active,omitempty" def:"false" descr:"Activate periodic {actions}"`
	ActiveFrom Xtime `` /* 236-byte string literal not displayed */
	ActiveTill Xtime `` /* 222-byte string literal not displayed */

	Delete       bool `json:"delete,omitempty" def:"false" descr:"Delete successfully uploaded files"`
	Checksum     bool `` /* 162-byte string literal not displayed */
	SingleUpload bool `` /* 180-byte string literal not displayed */

	StopTimeout Duration `` /* 306-byte string literal not displayed */
	ServerCert  string   `` /* 240-byte string literal not displayed */
}

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

type Xtime struct {
	Time *time.Time
}