ds2bq

type AEBackupEntityTypeInfo struct {
	Kind       string                            `json:"kind"`
	Properties []*AEBackupEntityTypeInfoProperty `json:"properties"`
}

type AEBackupEntityTypeInfoProperty struct {
	EmbeddedEntities []string `json:"embedded_entities"` // 型が不明だったので仮置き
	IsRepeated       bool     `json:"is_repeated"`
	Name             string   `json:"name"`
	PrimitiveTypes   []int    `json:"primitive_types"`
}

type AEBackupInformation struct {
	Kind string `goon:"kind,_AE_Backup_Information" json:"-"`
	// This kind does not have ParentKey rarely. maybe it comes from restore with backup of other app created.
	ParentKey     *datastore.Key `json:"-" datastore:"-" goon:"parent"` // AEDatastoreAdminOperation
	ID            int64          `datastore:"-" goon:"id"`
	ActiveJobs    []string       `datastore:"active_jobs"`
	CompleteTime  time.Time      `datastore:"complete_time"`
	CompletedJobs []string       `datastore:"completed_jobs"`
	Destination   string         `datastore:"destination"` // This field is string type maybe.
	Filesystem    string         `datastore:"filesystem"`
	GSHandle      string         `datastore:"gs_handle"`
	Kinds         []string       `datastore:"kinds"`
	Name          string         `datastore:"name"`
	OriginalApp   string         `datastore:"original_app"`
	StartTime     time.Time      `datastore:"start_time"`

	AEBackupInformationKindFilesList []*AEBackupInformationKindFiles `datastore:"-"`
}

type AEBackupInformationDeleteReq struct {
	Key string `json:"key"`
}

type AEBackupInformationKindFiles struct {
	Kind      string         `goon:"kind,_AE_Backup_Information_Kind_Files" json:"-"`
	ParentKey *datastore.Key `json:"-" datastore:"-" goon:"parent"` // AEBackupInformation
	ID        string         `datastore:"-" goon:"id"`
	Files     []string       `datastore:"files"`
}

type AEBackupInformationKindTypeInfo struct {
	Kind               string                  `goon:"kind,_AE_Backup_Information_Kind_Type_Info" json:"-"`
	ParentKey          *datastore.Key          `json:"-" datastore:"-" goon:"parent"` // AEBackupKind
	ID                 string                  `datastore:"-" goon:"id"`
	EntityTypeInfo     string                  `datastore:"entity_type_info" json:"-"`
	EntityTypeInfoJSON *AEBackupEntityTypeInfo `datastore:"-" json:"entityTypeInfo"`
	IsPartial          bool                    `datastore:"is_partial"`
}

type AEBackupInformationListLoader struct {
	List     []*AEBackupInformation
	Req      ReqListBase
	RespList *RespListBase
}

type AEBackupKind struct {
	Kind      string         `goon:"kind,Kind" json:"-"`
	ParentKey *datastore.Key `json:"-" datastore:"-" goon:"parent"` // AEBackupInformation
	ID        string         `datastore:"-" goon:"id"`

	AEBackupInformationKindTypeInfoList []*AEBackupInformationKindTypeInfo `datastore:"-"`
}

type AEDatastoreAdminOperation struct {
	Kind          string    `goon:"kind,_AE_DatastoreAdmin_Operation" json:"-"`
	ID            int64     `datastore:"-" goon:"id"`
	ActiveJobIDs  []string  `datastore:"active_job_ids"`
	ActiveJobs    int       `datastore:"active_jobs"`
	CompletedJobs int       `datastore:"completed_jobs"`
	Description   string    `datastore:"description"`
	LastUpdated   time.Time `datastore:"last_updated"`
	ServiceJobID  string    `datastore:"service_job_id"` // 型が不明だったので仮置き
	Status        string    `datastore:"status"`
	StatusInfo    string    `datastore:"status_info"`

	AEBackupInformationList []*AEBackupInformation `datastore:"-"`
	AEBackupKindList        []*AEBackupKind        `datastore:"-"`
}

type AEDatastoreAdminOperationListLoader struct {
	List     []*AEDatastoreAdminOperation
	Req      ReqListBase
	RespList *RespListBase
}

type AEDatastoreStore struct{}

type DatastoreExportService interface {
	Export(c context.Context, outputGCSPrefix string, entityFilter *EntityFilter) (*dsapi.GoogleLongrunningOperation, error)
}

type DatastoreManagementService interface {
	SetupWithUconSwagger(swPlugin *swagger.Plugin)
	HandlePostTQ(c context.Context, req *Noop) (*Noop, error)
	HandlePostDeleteList(c context.Context, r *http.Request, req *ReqListBase) (*Noop, error)
	HandleDeleteAEBackupInformation(c context.Context, r *http.Request, req *AEBackupInformationDeleteReq) (*Noop, error)
}

type EntityFilter struct {
	Kinds           []string `json:"kinds,omitempty"`
	NamespaceIds    []string `json:"namespaceIds,omitempty"`
	ForceSendFields []string `json:"-"`
	NullFields      []string `json:"-"`
}

type GCSHeader struct {
	ChannelID     string
	ClientToken   string
	ResourceID    string
	ResourceState string
	ResourceURI   string
}

type GCSObject struct {
	ID             string    `json:"id"`
	SelfLink       string    `json:"selfLink"`
	Name           string    `json:"name"`
	Bucket         string    `json:"bucket"`
	Generation     string    `json:"generation"`
	MetaGeneration string    `json:"metageneration"`
	ContentType    string    `json:"contentType"`
	Updated        time.Time `json:"updated"`
	Size           int64     `json:"size,string"`
	Md5Hash        string    `json:"md5Hash"`
	MediaLink      string    `json:"mediaLink"`
	Crc32c         string    `json:"crc32c"`
	Etag           string    `json:"etag"`
	TimeCreated    time.Time `json:"timeCreated"`
	TimeDeleted    time.Time `json:"timeDeleted"`
}

type GCSObjectToBQJobReq struct {
	Bucket      string    `json:"bucket"`
	FilePath    string    `json:"filePath"`
	KindName    string    `json:"kindName"`
	TimeCreated time.Time `json:"TimeCreated"`
}

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

type GCSWatcherService interface {
	SetupWithUcon()
	HandleOCN(c context.Context, r *http.Request, obj *GCSObject) error
	HandleBackupToBQJob(c context.Context, req *GCSObjectToBQJobReq) error
}

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

type Noop struct {
}

type Plugger interface {
	Plugin() Plugin
}

type Plugin interface {
	Init(typeName string)
	Ancestor(ancestor *datastore.Key)
	KeysOnly()
	Start(cur datastore.Cursor)
	Offset(offset int)
	Limit(limit int)
	Filter(name, op string, value interface{})
	Asc(name string)
	Desc(name string)
}

type QueryListLoader interface {
	LoadInstance(c context.Context, key *datastore.Key) (interface{}, error)
	Append(v interface{}) error
	PostProcess(c context.Context) error
	ReqListBase() ReqListBase
	RespListBase() *RespListBase
}

type ReqListBase struct {
	Limit  int    `json:"limit" endpoints:"d=10" swagger:",in=query,d=10"`
	Offset int    `json:"offset" swagger:",in=query"`
	Cursor string `json:"cursor" swagger:",in=query"`
}

type RespListBase struct {
	Cursor string `json:"cursor,omitempty" swagger:",in=query"`
}