system

type ActiveRequestsSet struct {
	// ReqRecord holds data of ongoing requests
	ReqRecord map[string]interface{}
	// UpdateMu is the mutex for protecting OngoingReqs
	UpdateMu sync.Mutex
}

type AddResourceRequest struct {
	ManagerAddress   string            `json:"ManagerAddress"`
	UserName         string            `json:"UserName"`
	Password         string            `json:"Password"`
	ConnectionMethod *ConnectionMethod `json:"ConnectionMethod"`
}

type AggregationResetRequest struct {
	BatchSize                    int      `json:"BatchSize"`
	DelayBetweenBatchesInSeconds int      `json:"DelayBetweenBatchesInSeconds"`
	ResetType                    string   `json:"ResetType"`
	TargetURIs                   []string `json:"TargetURIs"`
}

type AggregationSetDefaultBootOrderRequest struct {
	Systems []OdataID `json:"Systems"`
}

type AggregationSource struct {
	HostName string `json:"HostName"`
	UserName string `json:"UserName"`
	Password string `json:"Password"`
	Links    *Links `json:"Links,omitempty"`
}

type ConnectionMethod struct {
	OdataID string `json:"@odata.id"`
}

type Device struct {
	ServerIP   string `json:"ServerIP"`
	Username   string `json:"Username"`
	DeviceUUID string `json:"device_UUID"`
}

type ExternalInterface struct {
	ContactClient            func(context.Context, string, string, string, string, interface{}, map[string]string) (*http.Response, error)
	Auth                     func(string, []string, []string) (response.RPC, error)
	GetSessionUserName       func(string) (string, error)
	CreateChildTask          func(context.Context, string, string) (string, error)
	CreateTask               func(context.Context, string) (string, error)
	UpdateTask               func(context.Context, common.TaskData) error
	CreateSubcription        func(context.Context, []string)
	PublishEvent             func(context.Context, []string, string)
	PublishEventMB           func(context.Context, string, string, string)
	GetPluginStatus          func(context.Context, agmodel.Plugin) bool
	SubscribeToEMB           func(string, []string) error
	EncryptPassword          func([]byte) ([]byte, error)
	DecryptPassword          func([]byte) ([]byte, error)
	DeleteComputeSystem      func(int, string) *errors.Error
	DeleteSystem             func(string) *errors.Error
	DeleteEventSubscription  func(string) (*eventsproto.EventSubResponse, error)
	EventNotification        func(context.Context, string, string, string)
	GetAllKeysFromTable      func(string) ([]string, error)
	GetConnectionMethod      func(string) (agmodel.ConnectionMethod, *errors.Error)
	UpdateConnectionMethod   func(agmodel.ConnectionMethod, string) *errors.Error
	GetPluginMgrAddr         func(string) (agmodel.Plugin, *errors.Error)
	GetAggregationSourceInfo func(string) (agmodel.AggregationSource, *errors.Error)
	GenericSave              func([]byte, string, string) error
	CheckActiveRequest       func(string) (bool, *errors.Error)
	DeleteActiveRequest      func(string) *errors.Error
	GetAllMatchingDetails    func(string, string, common.DbType) ([]string, *errors.Error)
	CheckMetricRequest       func(string) (bool, *errors.Error)
	DeleteMetricRequest      func(string) *errors.Error
	GetResource              func(string, string) (string, *errors.Error)
	Delete                   func(string, string, common.DbType) *errors.Error
}

type Links struct {
	ConnectionMethod *ConnectionMethod `json:"ConnectionMethod,omitempty"`
}

type OdataID struct {
	OdataID string `json:"@odata.id"`
}

type ResetRequest struct {
	BatchSize                    int    `json:"BatchSize"`
	DelayBetweenBatchesInSeconds int    `json:"DelayBetweenBatchesInSeconds"`
	ResetType                    string `json:"ResetType"`
}

type TaskData struct {
	TaskID          string
	TargetURI       string
	Resp            response.RPC
	TaskState       string
	TaskStatus      string
	PercentComplete int32
	HTTPMethod      string
}

type WildCard struct {
	Name   string
	Values []string
}