devices

package
v1.0.0-alpha.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 19, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TypeWireless string = "Wireless"
	TypeTLS      string = "TLS"
	TypeWired    string = "Wired"
)
View Source 
const (
	HeaderByteSize             = 9
	ContentLengthPadding       = 8
	RedirectSessionLengthBytes = 13
	RedirectionSessionReply    = 4
)
View Source 
const (
	RedirectionCommandsStartRedirectionSession      = 16
	RedirectionCommandsStartRedirectionSessionReply = 17
	RedirectionCommandsEndRedirectionSession        = 18
	RedirectionCommandsAuthenticateSession          = 19
	RedirectionCommandsAuthenticateSessionReply     = 20
	StartRedirectionSessionReplyStatusSuccess       = 0
	StartRedirectionSessionReplyStatusUnknown       = 1
	StartRedirectionSessionReplyStatusBusy          = 2
	StartRedirectionSessionReplyStatusUnsupported   = 3
	StartRedirectionSessionReplyStatusError         = 0xFF
	AuthenticationTypeQuery                         = 0
	AuthenticationTypeUserPass                      = 1
	AuthenticationTypeKerberos                      = 2
	AuthenticationTypeBadDigest                     = 3
	AuthenticationTypeDigest                        = 4
	AuthenticationStatusSuccess                     = 0
	AuthenticationStatusFail                        = 1
	AuthenticationStatusNotSupported                = 2

	// MinAMTVersion - minimum AMT version required for certain features in power capabilities.
	MinAMTVersion = 9
)

Variables

View Source 
var (
	ErrDomainsUseCase = consoleerrors.CreateConsoleError("DevicesUseCase")
	ErrDatabase       = sqldb.DatabaseError{Console: consoleerrors.CreateConsoleError("DevicesUseCase")}
	ErrNotFound       = sqldb.NotFoundError{Console: consoleerrors.CreateConsoleError("DevicesUseCase")}
)
View Source 
var ErrAMT = AMTError{Console: consoleerrors.CreateConsoleError("DevicesUseCase")}

Functions

func RandomValueHex 

func RandomValueHex(length int) (string, error)

RandomValueHex generates a random hexadecimal string of the specified length.

Types

type AMTError 

type AMTError struct {
	Console consoleerrors.InternalError
}

func (AMTError) Error 

func (e AMTError) Error() string

func (AMTError) Wrap added in v1.0.1 

func (e AMTError) Wrap(call, function string, err error) error

type DeviceConnection 

type DeviceConnection struct {
	Conn *websocket.Conn

	Device    dto.Device
	Direct    bool
	Mode      string
	Challenge client.AuthChallenge
	// contains filtered or unexported fields
}

type ExplorerError added in v1.0.1 

type ExplorerError struct {
	Console consoleerrors.InternalError
}

func (ExplorerError) Error added in v1.0.1 

func (e ExplorerError) Error() string

func (ExplorerError) Wrap added in v1.0.1 

func (e ExplorerError) Wrap(call, function string, err error) error

type Feature 

type Feature interface {
	// Repository/Database Calls
	GetCount(context.Context, string) (int, error)
	Get(ctx context.Context, top, skip int, tenantID string) ([]dto.Device, error)
	GetByID(ctx context.Context, guid, tenantID string) (*dto.Device, error)
	GetDistinctTags(ctx context.Context, tenantID string) ([]string, error)
	GetByTags(ctx context.Context, tags, method string, limit, offset int, tenantID string) ([]dto.Device, error)
	Delete(ctx context.Context, guid, tenantID string) error
	Update(ctx context.Context, d *dto.Device) (*dto.Device, error)
	Insert(ctx context.Context, d *dto.Device) (*dto.Device, error)
	GetByColumn(ctx context.Context, columnName, queryValue, tenantID string) ([]dto.Device, error)
	// Management Calls
	GetVersion(ctx context.Context, guid string) (map[string]interface{}, error)
	GetFeatures(ctx context.Context, guid string) (dto.Features, error)
	SetFeatures(ctx context.Context, guid string, features dto.Features) (dto.Features, error)
	GetAlarmOccurrences(ctx context.Context, guid string) ([]dto.AlarmClockOccurrence, error)
	CreateAlarmOccurrences(ctx context.Context, guid string, alarm dto.AlarmClockOccurrence) (dto.AddAlarmOutput, error)
	DeleteAlarmOccurrences(ctx context.Context, guid, instanceID string) error
	GetHardwareInfo(ctx context.Context, guid string) (interface{}, error)
	GetPowerState(ctx context.Context, guid string) (map[string]interface{}, error)
	GetPowerCapabilities(ctx context.Context, guid string) (map[string]interface{}, error)
	GetGeneralSettings(ctx context.Context, guid string) (interface{}, error)
	CancelUserConsent(ctx context.Context, guid string) (interface{}, error)
	GetUserConsentCode(ctx context.Context, guid string) (map[string]interface{}, error)
	SendConsentCode(ctx context.Context, code dto.UserConsent, guid string) (interface{}, error)
	SendPowerAction(ctx context.Context, guid string, action int) (power.PowerActionResponse, error)
	SetBootOptions(ctx context.Context, guid string, bootSetting dto.BootSetting) (power.PowerActionResponse, error)
	GetAuditLog(ctx context.Context, startIndex int, guid string) (dto.AuditLog, error)
	GetEventLog(ctx context.Context, guid string) ([]dto.EventLog, error)
	Redirect(ctx context.Context, conn *websocket.Conn, guid, mode string) error
	GetNetworkSettings(c context.Context, guid string) (interface{}, error)
	GetCertificates(c context.Context, guid string) (dto.SecuritySettings, error)
}

type Redirection 

type Redirection interface {
	SetupWsmanClient(device dto.Device, isRedirection, logMessages bool) wsman.Messages
	RedirectConnect(ctx context.Context, deviceConnection *DeviceConnection) error
	RedirectClose(ctx context.Context, deviceConnection *DeviceConnection) error
	RedirectListen(ctx context.Context, deviceConnection *DeviceConnection) ([]byte, error)
	RedirectSend(ctx context.Context, deviceConnection *DeviceConnection, message []byte) error
}

type Redirector 

type Redirector struct{}

func NewRedirector 

func NewRedirector() *Redirector

func (*Redirector) RedirectClose 

func (g *Redirector) RedirectClose(_ context.Context, deviceConnection *DeviceConnection) error

func (*Redirector) RedirectConnect 

func (g *Redirector) RedirectConnect(_ context.Context, deviceConnection *DeviceConnection) error

func (*Redirector) RedirectListen 

func (g *Redirector) RedirectListen(_ context.Context, deviceConnection *DeviceConnection) ([]byte, error)

func (*Redirector) RedirectSend 

func (g *Redirector) RedirectSend(_ context.Context, deviceConnection *DeviceConnection, data []byte) error

func (*Redirector) SetupWsmanClient 

func (g *Redirector) SetupWsmanClient(device dto.Device, isRedirection, logAMTMessages bool) wsman.Messages

type Repository 

type Repository interface {
	GetCount(context.Context, string) (int, error)
	Get(ctx context.Context, top, skip int, tenantID string) ([]entity.Device, error)
	GetByID(ctx context.Context, guid, tenantID string) (*entity.Device, error)
	GetDistinctTags(ctx context.Context, tenantID string) ([]string, error)
	GetByTags(ctx context.Context, tags []string, method string, limit, offset int, tenantID string) ([]entity.Device, error)
	Delete(ctx context.Context, guid, tenantID string) (bool, error)
	Update(ctx context.Context, d *entity.Device) (bool, error)
	Insert(ctx context.Context, d *entity.Device) (string, error)
	GetByColumn(ctx context.Context, columnName, queryValue, tenantID string) ([]entity.Device, error)
}

type UseCase 

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

UseCase -.

func New 

func New(r Repository, d WSMAN, redirection Redirection, log logger.Interface) *UseCase

New -.

func (*UseCase) CancelUserConsent 

func (uc *UseCase) CancelUserConsent(c context.Context, guid string) (interface{}, error)

func (*UseCase) CreateAlarmOccurrences 

func (uc *UseCase) CreateAlarmOccurrences(c context.Context, guid string, alarm dto.AlarmClockOccurrence) (dto.AddAlarmOutput, error)

func (*UseCase) Delete 

func (uc *UseCase) Delete(ctx context.Context, guid, tenantID string) error

func (*UseCase) DeleteAlarmOccurrences 

func (uc *UseCase) DeleteAlarmOccurrences(c context.Context, guid, instanceID string) error

func (*UseCase) Get 

func (uc *UseCase) Get(ctx context.Context, top, skip int, tenantID string) ([]dto.Device, error)

func (*UseCase) GetAlarmOccurrences 

func (uc *UseCase) GetAlarmOccurrences(c context.Context, guid string) ([]dto.AlarmClockOccurrence, error)

func (*UseCase) GetAuditLog 

func (uc *UseCase) GetAuditLog(c context.Context, startIndex int, guid string) (dto.AuditLog, error)

func (*UseCase) GetByColumn added in v1.0.1 

func (uc *UseCase) GetByColumn(ctx context.Context, columnName, queryValue, tenantID string) ([]dto.Device, error)

func (*UseCase) GetByID 

func (uc *UseCase) GetByID(ctx context.Context, guid, tenantID string) (*dto.Device, error)

func (*UseCase) GetByTags 

func (uc *UseCase) GetByTags(ctx context.Context, tags, method string, limit, offset int, tenantID string) ([]dto.Device, error)

func (*UseCase) GetCertificates added in v1.0.1 

func (uc *UseCase) GetCertificates(c context.Context, guid string) (dto.SecuritySettings, error)

func (*UseCase) GetCount 

func (uc *UseCase) GetCount(ctx context.Context, tenantID string) (int, error)

History - getting translate history from store.

func (*UseCase) GetDistinctTags 

func (uc *UseCase) GetDistinctTags(ctx context.Context, tenantID string) ([]string, error)

func (*UseCase) GetEventLog 

func (uc *UseCase) GetEventLog(c context.Context, guid string) ([]dto.EventLog, error)

func (*UseCase) GetFeatures 

func (uc *UseCase) GetFeatures(c context.Context, guid string) (dto.Features, error)

func (*UseCase) GetGeneralSettings 

func (uc *UseCase) GetGeneralSettings(c context.Context, guid string) (interface{}, error)

func (*UseCase) GetHardwareInfo 

func (uc *UseCase) GetHardwareInfo(c context.Context, guid string) (interface{}, error)

func (*UseCase) GetNetworkSettings 

func (uc *UseCase) GetNetworkSettings(c context.Context, guid string) (interface{}, error)

func (*UseCase) GetPowerCapabilities 

func (uc *UseCase) GetPowerCapabilities(c context.Context, guid string) (map[string]interface{}, error)

func (*UseCase) GetPowerState 

func (uc *UseCase) GetPowerState(c context.Context, guid string) (map[string]interface{}, error)

func (*UseCase) GetUserConsentCode 

func (uc *UseCase) GetUserConsentCode(c context.Context, guid string) (map[string]interface{}, error)

func (*UseCase) GetVersion 

func (uc *UseCase) GetVersion(c context.Context, guid string) (map[string]interface{}, error)

func (*UseCase) Insert 

func (uc *UseCase) Insert(ctx context.Context, d *dto.Device) (*dto.Device, error)

func (*UseCase) Redirect 

func (uc *UseCase) Redirect(c context.Context, conn *websocket.Conn, guid, mode string) error

func (*UseCase) SendConsentCode 

func (uc *UseCase) SendConsentCode(c context.Context, userConsent dto.UserConsent, guid string) (interface{}, error)

func (*UseCase) SendPowerAction 

func (uc *UseCase) SendPowerAction(c context.Context, guid string, action int) (power.PowerActionResponse, error)

func (*UseCase) SetBootOptions 

func (uc *UseCase) SetBootOptions(c context.Context, guid string, bootSetting dto.BootSetting) (power.PowerActionResponse, error)

func (*UseCase) SetFeatures 

func (uc *UseCase) SetFeatures(c context.Context, guid string, features dto.Features) (dto.Features, error)

func (*UseCase) Update 

func (uc *UseCase) Update(ctx context.Context, d *dto.Device) (*dto.Device, error)

type WSMAN added in v1.0.1 

type WSMAN interface {
	SetupWsmanClient(device dto.Device, isRedirection, logMessages bool) wsmanAPI.Management
	DestroyWsmanClient(device dto.Device)
	Worker()
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.