synchronization_server

type DeleteAllStagesRequest struct {
	ProjectName string `json:"projectName"`
}

type DeleteAllStagesResponse struct {
	Err util.SerializableError `json:"err"`
}

type DeleteStagesBySignatureRequest struct {
	ProjectName string `json:"projectName"`
	Signature   string `json:"signature"`
}

type DeleteStagesBySignatureResponse struct {
	Err util.SerializableError `json:"err"`
}

type GetAllStagesRequest struct {
	ProjectName string `json:"projectName"`
}

type GetAllStagesResponse struct {
	Err    util.SerializableError `json:"err"`
	Found  bool                   `json:"found"`
	Stages []image.StageID        `json:"stages"`
}

type GetStagesBySignatureRequest struct {
	ProjectName string `json:"projectName"`
	Signature   string `json:"signature"`
}

type GetStagesBySignatureResponse struct {
	Err    util.SerializableError `json:"err"`
	Found  bool                   `json:"found"`
	Stages []image.StageID        `json:"stages"`
}

type HealthRequest struct {
	Echo string `json:"echo"`
}

type HealthResponse struct {
	Err    util.SerializableError `json:"err"`
	Echo   string                 `json:"echo"`
	Status string                 `json:"status"`
}

type NewClientIDRequest struct{}

type NewClientIDResponse struct {
	Err      util.SerializableError `json:"err"`
	ClientID string                 `json:"clientID"`
}

type StagesStorageCacheHttpClient struct {
	URL        string
	HttpClient *http.Client
}

type StagesStorageCacheHttpHandler struct {
	*http.ServeMux
	StagesStorageCache storage.StagesStorageCache
}

type StoreStagesBySignatureRequest struct {
	ProjectName string          `json:"projectName"`
	Signature   string          `json:"signature"`
	Stages      []image.StageID `json:"stages"`
}

type StoreStagesBySignatureResponse struct {
	Err util.SerializableError `json:"err"`
}

type SynchronizationClient struct {
	HttpClient *http.Client
	URL        string
}

type SynchronizationServerHandler struct {
	*http.ServeMux

	DistributedLockerBackendFactoryFunc func(clientID string) (distributed_locker.DistributedLockerBackend, error)
	StagesStorageCacheFactoryFunc       func(clientID string) (storage.StagesStorageCache, error)

	SynchronizationServerByClientID map[string]*SynchronizationServerHandlerByClientID
	// contains filtered or unexported fields
}

type SynchronizationServerHandlerByClientID struct {
	*http.ServeMux
	ClientID string

	DistributedLockerBackend distributed_locker.DistributedLockerBackend
	StagesStorageCache       storage.StagesStorageCache
}