manage

type CatalogCheckServiceInitRequest struct {
	ServiceType string

	Service *ServiceCommonRequest

	Admin       string
	AdminPasswd string

	// Redis specific fields.
	// TODO they should be moved to ServiceAttr.UserData.
	Shards           int64
	ReplicasPerShard int64
}

type CatalogCheckServiceInitResponse struct {
	Initialized   bool
	StatusMessage string
}

type CatalogConsulOptions struct {
	Replicas     int64
	VolumeSizeGB int64

	// https://www.consul.io/docs/agent/options.html#_datacenter
	// if not specified, use the current Region.
	Datacenter string

	// https://www.consul.io/docs/agent/options.html#_domain
	Domain string

	// https://www.consul.io/docs/agent/options.html#_encrypt
	// This key must be 16-bytes that are Base64-encoded.
	Encrypt string

	// TLS configs
	EnableTLS         bool
	CertFileContent   string
	KeyFileContent    string
	CACertFileContent string
	HTTPSPort         int64
}

type CatalogCouchDBOptions struct {
	Replicas     int64
	VolumeSizeGB int64

	// CouchDB admin username and password
	Admin       string
	AdminPasswd string

	// CouchDB Cors configs
	EnableCors  bool
	Credentials bool
	Origins     string
	Headers     string
	Methods     string

	// CouchDB SSL configs
	EnableSSL         bool
	CertFileContent   string
	KeyFileContent    string
	CACertFileContent string
}

type CatalogCreateCassandraRequest struct {
	Service  *ServiceCommonRequest
	Resource *common.Resources

	Replicas     int64
	VolumeSizeGB int64
}

type CatalogCreateConsulRequest struct {
	Service  *ServiceCommonRequest
	Resource *common.Resources
	Options  *CatalogConsulOptions
}

type CatalogCreateConsulResponse struct {
	ConsulServerIPs []string
}

type CatalogCreateCouchDBRequest struct {
	Service  *ServiceCommonRequest
	Resource *common.Resources
	Options  *CatalogCouchDBOptions
}

type CatalogCreateElasticSearchRequest struct {
	Service  *ServiceCommonRequest
	Resource *common.Resources
	Options  *CatalogElasticSearchOptions
}

type CatalogCreateKafkaRequest struct {
	Service  *ServiceCommonRequest
	Resource *common.Resources

	Replicas     int64
	VolumeSizeGB int64

	AllowTopicDel  bool
	RetentionHours int64
	// the existing ZooKeeper service that Kafka will use.
	ZkServiceName string
}

type CatalogCreateKibanaRequest struct {
	Service  *ServiceCommonRequest
	Resource *common.Resources
	Options  *CatalogKibanaOptions
}

type CatalogCreateLogstashRequest struct {
	Service  *ServiceCommonRequest
	Resource *common.Resources
	Options  *CatalogLogstashOptions
}

type CatalogCreateMongoDBRequest struct {
	Service  *ServiceCommonRequest
	Resource *common.Resources

	Replicas     int64
	VolumeSizeGB int64

	Admin       string
	AdminPasswd string
}

type CatalogCreatePostgreSQLRequest struct {
	Service  *ServiceCommonRequest
	Resource *common.Resources
	Options  *CatalogPostgreSQLOptions
}

type CatalogCreateRedisRequest struct {
	Service *ServiceCommonRequest

	// Resources.MaxMemoryMB should always be set.
	// if cluster mode is enabled (Shards >= 3), the actual redis memory will be
	// Resources.MaxMemoryMB - default output buffer for the slaves (512MB).
	Resource *common.Resources

	Options *CatalogRedisOptions
}

type CatalogCreateZooKeeperRequest struct {
	Service  *ServiceCommonRequest
	Resource *common.Resources

	Replicas     int64
	VolumeSizeGB int64
}

type CatalogElasticSearchOptions struct {
	Replicas     int64
	VolumeSizeGB int64

	DedicatedMasters       int64
	DisableDedicatedMaster bool
	DisableForceAwareness  bool
}

type CatalogKibanaOptions struct {
	Replicas     int64
	VolumeSizeGB int64

	// the ElasticSearch service that Kibana is used for
	ESServiceName string

	// specify a path to mount Kibana at if you are running behind a proxy.
	// This only affects the URLs generated by Kibana, your proxy is expected to remove the
	// basePath value before forwarding requests to Kibana. This setting cannot end in a slash (/).
	ProxyBasePath string

	EnableSSL bool
	SSLKey    string
	SSLCert   string
}

type CatalogLogstashOptions struct {
	Replicas     int64
	VolumeSizeGB int64

	// The container image for the service, such as cloudstax/firecamp-logstash:version or cloudstax/firecamp-logstash-input-couchdb:version
	ContainerImage string

	// The internal queue model: "memory" or "persisted"
	QueueType             string
	EnableDeadLetterQueue bool

	// The pipeline configs.
	// There is no need to have multiple config file, as Logstash currently has a single event pipeline.
	// All configuration files are just concatenated (in order) as if you had written a single flat file.
	PipelineConfigs string

	// https://www.elastic.co/guide/en/logstash/5.6/tuning-logstash.html
	// The pipeline settings
	PipelineWorkers       int
	PipelineOutputWorkers int
	PipelineBatchSize     int
	PipelineBatchDelay    int
}

type CatalogPostgreSQLOptions struct {
	Replicas     int64
	VolumeSizeGB int64

	// The container image for the service, such as cloudstax/firecamp-postgres:version or cloudstax/firecamp-postgres-postgis:version
	ContainerImage string

	// the default admin user is: postgres
	AdminPasswd    string
	ReplUser       string
	ReplUserPasswd string
}

type CatalogRedisOptions struct {
	// The number of shards for Redis cluster, minimal 3.
	// Setting to 1 will disable cluster mode. 2 is invalid.
	Shards           int64
	ReplicasPerShard int64

	VolumeSizeGB int64

	// whether disable Redis "append only file", not recommended unless for cache only.
	DisableAOF bool
	// The AUTH password, recommended to set it for production environment. Empty string means disable it.
	AuthPass string
	// minimal 60s, not recommend to change unless necessary. see Redis Readme for details.
	ReplTimeoutSecs int64
	// how Redis will select what to remove when maxmemory is reached
	MaxMemPolicy string
	// rename the CONFIG command
	ConfigCmdName string
}

type CatalogSetRedisInitRequest struct {
	Region      string
	Cluster     string
	ServiceName string
	// The Redis node ids, format: "MemberName RedisNodeID Role(master/slave)"
	NodeIds []string
}

type CatalogSetServiceInitRequest struct {
	Region      string
	Cluster     string
	ServiceName string
	ServiceType string
}

type CreateServiceRequest struct {
	Service  *ServiceCommonRequest
	Resource *common.Resources

	ContainerImage string
	Replicas       int64
	VolumeSizeGB   int64
	ContainerPath  string // The mount path inside container
	PortMappings   []common.PortMapping
	Envkvs         []*common.EnvKeyValuePair

	RegisterDNS     bool
	RequireStaticIP bool
	ReplicaConfigs  []*ReplicaConfig
}

type DeleteTaskRequest struct {
	Service  *ServiceCommonRequest
	TaskType string
}

type GetConfigFileRequest struct {
	Region      string
	Cluster     string
	ServiceUUID string
	FileID      string
}

type GetConfigFileResponse struct {
	ConfigFile *common.ConfigFile
}

type GetServiceAttributesResponse struct {
	Service *common.ServiceAttr
}

type GetServiceStatusResponse struct {
	Status *common.ServiceStatus
}

type GetTaskStatusRequest struct {
	Service *ServiceCommonRequest
	TaskID  string
}

type GetTaskStatusResponse struct {
	Status *common.TaskStatus
}

type InternalGetServiceTaskRequest struct {
	Region              string
	Cluster             string
	ServiceName         string
	ContainerInstanceID string
}

type InternalGetServiceTaskResponse struct {
	ServiceTaskID string
}

type InternalListActiveServiceTasksRequest struct {
	Region      string
	Cluster     string
	ServiceName string
}

type InternalListActiveServiceTasksResponse struct {
	ServiceTaskIDs map[string]bool
}

type ListServiceMemberRequest struct {
	Service *ServiceCommonRequest
}

type ListServiceMemberResponse struct {
	ServiceMembers []*common.ServiceMember
}

type ListServiceRequest struct {
	// region, az and cluster are for the management service to verify
	// the request is sent to the correct server
	Region  string
	Cluster string

	// The prefix of the service name
	Prefix string
}

type ListServiceResponse struct {
	Services []*common.ServiceAttr
}

type ReplicaConfig struct {
	// The availability zone this replica should run.
	Zone string
	// The detail config files for this replica.
	Configs []*ReplicaConfigFile
}

type ReplicaConfigFile struct {
	FileName string
	FileMode uint32
	Content  string
}

type RunTaskRequest struct {
	Service        *ServiceCommonRequest
	Resource       *common.Resources
	ContainerImage string
	TaskType       string
	Envkvs         []*common.EnvKeyValuePair
}

type RunTaskResponse struct {
	TaskID string
}

type ServiceCommonRequest struct {
	Region      string
	Cluster     string
	ServiceName string
}