imageserver

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2019 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ResponseDefaultError = 500
)
View Source 
const (
	TimeFormatLayout = "2006-01-02 15:04:05"
)

Variables

This section is empty.

Functions

func ResponseFail 

func ResponseFail(code int, message string, writer io.Writer) error

func ResponseOK 

func ResponseOK(data interface{}, writer io.Writer) error

Types

type CreateDiskImageExecutor 

type CreateDiskImageExecutor struct {
	Sender      framework.MessageSender
	ImageServer *ImageManager
}

func (*CreateDiskImageExecutor) Execute 

func (executor *CreateDiskImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type CreateMediaImageExecutor 

type CreateMediaImageExecutor struct {
	Sender      framework.MessageSender
	ImageServer *ImageManager
}

func (*CreateMediaImageExecutor) Execute 

func (executor *CreateMediaImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type DeleteDiskImageExecutor 

type DeleteDiskImageExecutor struct {
	Sender      framework.MessageSender
	ImageServer *ImageManager
}

func (*DeleteDiskImageExecutor) Execute 

func (executor *DeleteDiskImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type DeleteMediaImageExecutor 

type DeleteMediaImageExecutor struct {
	Sender      framework.MessageSender
	ImageServer *ImageManager
}

func (*DeleteMediaImageExecutor) Execute 

func (executor *DeleteMediaImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type DiskConfig 

type DiskConfig struct {
	Name        string   `json:"name"`
	Owner       string   `json:"owner"`
	Group       string   `json:"group"`
	Description string   `json:"description,omitempty"`
	Tags        []string `json:"tags,omitempty"`
}

type DiskImageUpdateExecutor 

type DiskImageUpdateExecutor struct {
	Sender      framework.MessageSender
	ImageServer *ImageManager
}

func (*DiskImageUpdateExecutor) Execute 

func (executor *DiskImageUpdateExecutor) Execute(id framework.SessionID, event framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type DiskStatus 

type DiskStatus struct {
	DiskConfig
	ID         string `json:"id"`
	Format     string `json:"format"`
	Path       string `json:"path"`
	Size       uint   `json:"size"`
	Version    uint   `json:"version"`
	CheckSum   string `json:"check_sum,omitempty"`
	Locked     bool   `json:"-"`
	CreateTime string `json:"create_time,omitempty"`
	ModifyTime string `json:"modify_time,omitempty"`
	Created    bool   `json:"-"`
	Progress   uint   `json:"-"`
}

type GetDiskImageExecutor 

type GetDiskImageExecutor struct {
	Sender      framework.MessageSender
	ImageServer *ImageManager
}

func (*GetDiskImageExecutor) Execute 

func (executor *GetDiskImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetMediaImageExecutor 

type GetMediaImageExecutor struct {
	Sender      framework.MessageSender
	ImageServer *ImageManager
}

func (*GetMediaImageExecutor) Execute 

func (executor *GetMediaImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type HttpModule 

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

func CreateHttpModule 

func CreateHttpModule(configPath, dataPath, host string, image *ImageManager) (module *HttpModule, err error)

func (*HttpModule) CancelLockedDiskImage 

func (module *HttpModule) CancelLockedDiskImage(id string)

func (*HttpModule) CheckDiskImageFile 

func (module *HttpModule) CheckDiskImageFile(w http.ResponseWriter, r *http.Request, params httprouter.Params)

func (*HttpModule) CheckMediaImageFile 

func (module *HttpModule) CheckMediaImageFile(w http.ResponseWriter, r *http.Request, params httprouter.Params)

func (*HttpModule) DownloadMediaImageFile 

func (module *HttpModule) DownloadMediaImageFile(w http.ResponseWriter, r *http.Request, params httprouter.Params)

func (*HttpModule) GetCertFilePath 

func (module *HttpModule) GetCertFilePath() string

func (*HttpModule) GetHost 

func (module *HttpModule) GetHost() string

func (*HttpModule) GetKeyFilePath 

func (module *HttpModule) GetKeyFilePath() string

func (*HttpModule) GetPort 

func (module *HttpModule) GetPort() int

func (*HttpModule) HttpRoutine 

func (module *HttpModule) HttpRoutine(finished chan bool)

func (*HttpModule) ReadDiskImageFile 

func (module *HttpModule) ReadDiskImageFile(w http.ResponseWriter, r *http.Request, params httprouter.Params)

func (*HttpModule) RegisterHandler 

func (module *HttpModule) RegisterHandler(router *httprouter.Router)

func (*HttpModule) Routine 

func (module *HttpModule) Routine(c framework.RoutineController)

func (*HttpModule) Start 

func (module *HttpModule) Start() error

func (*HttpModule) Stop 

func (module *HttpModule) Stop() error

func (*HttpModule) UnlockMediaImage 

func (module *HttpModule) UnlockMediaImage(id string)

func (*HttpModule) UploadMediaImageFile 

func (module *HttpModule) UploadMediaImageFile(w http.ResponseWriter, r *http.Request, params httprouter.Params)

func (*HttpModule) WriteDiskImageFile 

func (module *HttpModule) WriteDiskImageFile(w http.ResponseWriter, r *http.Request, params httprouter.Params)

type ImageCommandType 

type ImageCommandType int

type ImageManager 

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

func CreateImageManager 

func CreateImageManager(dataPath string) (manager *ImageManager, err error)

func (*ImageManager) CreateDiskImage 

func (manager *ImageManager) CreateDiskImage(config DiskConfig, respChan chan ImageResult)

func (*ImageManager) CreateMediaImage 

func (manager *ImageManager) CreateMediaImage(config MediaConfig, respChan chan ImageResult)

func (*ImageManager) DeleteDiskImage 

func (manager *ImageManager) DeleteDiskImage(id string, respChan chan error)

func (*ImageManager) DeleteMediaImage 

func (manager *ImageManager) DeleteMediaImage(id string, respChan chan error)

func (*ImageManager) FinishDiskImage 

func (manager *ImageManager) FinishDiskImage(id, checksum string, respChan chan error)

func (*ImageManager) FinishMediaImage 

func (manager *ImageManager) FinishMediaImage(id string, respChan chan error)

func (*ImageManager) GetDiskImage 

func (manager *ImageManager) GetDiskImage(id string, respChan chan ImageResult)

func (*ImageManager) GetDiskImageFile 

func (manager *ImageManager) GetDiskImageFile(id string, respChan chan ImageResult)

func (*ImageManager) GetMediaImage 

func (manager *ImageManager) GetMediaImage(id string, respChan chan ImageResult)

func (*ImageManager) GetMediaImageFile 

func (manager *ImageManager) GetMediaImageFile(id string, respChan chan ImageResult)

func (*ImageManager) LoadData 

func (manager *ImageManager) LoadData() error

func (*ImageManager) LockDiskImageForUpdate 

func (manager *ImageManager) LockDiskImageForUpdate(id string, respChan chan ImageResult)

func (*ImageManager) LockMediaImageForUpdate 

func (manager *ImageManager) LockMediaImageForUpdate(id string, respChan chan ImageResult)

func (*ImageManager) ModifyDiskImage 

func (manager *ImageManager) ModifyDiskImage(id string, config DiskConfig, respChan chan error)

func (*ImageManager) ModifyMediaImage 

func (manager *ImageManager) ModifyMediaImage(id string, config MediaConfig, respChan chan error)

func (*ImageManager) QueryDiskImage 

func (manager *ImageManager) QueryDiskImage(owner, group string, tags []string, respChan chan ImageResult)

func (*ImageManager) QueryMediaImage 

func (manager *ImageManager) QueryMediaImage(owner, group string, respChan chan ImageResult)

func (*ImageManager) Routine 

func (manager *ImageManager) Routine(c framework.RoutineController)

func (*ImageManager) SaveData 

func (manager *ImageManager) SaveData() error

func (*ImageManager) Start 

func (manager *ImageManager) Start() error

func (*ImageManager) Stop 

func (manager *ImageManager) Stop() error

func (*ImageManager) UnlockDiskImage 

func (manager *ImageManager) UnlockDiskImage(id string, respChan chan error)

func (*ImageManager) UnlockMediaImage 

func (manager *ImageManager) UnlockMediaImage(id string, respChan chan error)

func (*ImageManager) UpdateDiskImageProgress 

func (manager *ImageManager) UpdateDiskImageProgress(id string, progress uint, respChan chan error)

type ImageResult 

type ImageResult struct {
	Error      error
	ID         string
	Path       string
	Size       uint
	CheckSum   string
	MediaList  []MediaStatus
	DiskList   []DiskStatus
	MediaImage MediaStatus
	DiskImage  DiskStatus
}

type ImageService 

type ImageService struct {
	framework.EndpointService //base class
	ConfigPath                string
	DataPath                  string
	// contains filtered or unexported fields
}

func (*ImageService) GetImageServiceAddress 

func (service *ImageService) GetImageServiceAddress() string

func (*ImageService) GetTLSFilePath 

func (service *ImageService) GetTLSFilePath() (cert, key string)

func (*ImageService) InitialEndpoint 

func (service *ImageService) InitialEndpoint() (err error)

func (*ImageService) OnDependencyReady 

func (service *ImageService) OnDependencyReady()

func (*ImageService) OnEndpointStarted 

func (service *ImageService) OnEndpointStarted() (err error)

func (*ImageService) OnEndpointStopped 

func (service *ImageService) OnEndpointStopped()

func (*ImageService) OnMessageReceived 

func (service *ImageService) OnMessageReceived(msg framework.Message)

func (*ImageService) OnServiceConnected 

func (service *ImageService) OnServiceConnected(nodeName string, t framework.ServiceType, address string)

func (*ImageService) OnServiceDisconnected 

func (service *ImageService) OnServiceDisconnected(name string, t framework.ServiceType, gracefully bool)

type ImageServiceConfig 

type ImageServiceConfig struct {
	CertFile string `json:"cert_file"`
	KeyFile  string `json:"key_file"`
}

type MediaConfig 

type MediaConfig struct {
	Name        string   `json:"name"`
	Owner       string   `json:"owner"`
	Group       string   `json:"group"`
	Description string   `json:"description"`
	Tags        []string `json:"tags"`
}

type MediaStatus 

type MediaStatus struct {
	MediaConfig
	ID         string `json:"id"`
	Format     string `json:"format"`
	Path       string `json:"path"`
	Size       uint   `json:"size"`
	Version    uint   `json:"version"`
	Locked     bool   `json:"-"`
	CreateTime string `json:"create_time,omitempty"`
	ModifyTime string `json:"modify_time,omitempty"`
}

type ModifyDiskImageExecutor 

type ModifyDiskImageExecutor struct {
	Sender      framework.MessageSender
	ImageServer *ImageManager
}

func (*ModifyDiskImageExecutor) Execute 

func (executor *ModifyDiskImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type ModifyMediaImageExecutor 

type ModifyMediaImageExecutor struct {
	Sender      framework.MessageSender
	ImageServer *ImageManager
}

func (*ModifyMediaImageExecutor) Execute 

func (executor *ModifyMediaImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type QueryDiskImageExecutor 

type QueryDiskImageExecutor struct {
	Sender      framework.MessageSender
	ImageServer *ImageManager
}

func (*QueryDiskImageExecutor) Execute 

func (executor *QueryDiskImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type QueryMediaImageExecutor 

type QueryMediaImageExecutor struct {
	Sender      framework.MessageSender
	ImageServer *ImageManager
}

func (*QueryMediaImageExecutor) Execute 

func (executor *QueryMediaImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type Response 

type Response struct {
	ErrorCode int         `json:"error_code"`
	Message   string      `json:"message"`
	Data      interface{} `json:"data"`
}

type TaskManager 

type TaskManager struct {
	*framework.TransactionEngine
}

func CreateTaskManager 

func CreateTaskManager(sender framework.MessageSender, imageManager *ImageManager) (*TaskManager, error)

Source Files

View all Source files

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.