client

package
v0.9.6 Latest Latest
Warning

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

 Go to latest Published: May 8, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ManageClient 

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

ManageClient is the client to talk with the management service.

func NewManageClient 

func NewManageClient(serverURL string, tlsConf *tls.Config) *ManageClient

NewManageClient creates a new ManageClient instance. Example serverURL: https://firecamp-manageserver.cluster-firecamp.com:27040/

func (*ManageClient) CatalogCheckServiceInit 

func (c *ManageClient) CatalogCheckServiceInit(ctx context.Context, r *manage.CatalogCheckServiceInitRequest) (initialized bool, statusMsg string, err error)

CatalogCheckServiceInit checks if a catalog service is initialized.

func (*ManageClient) CatalogCreateCassandraService 

func (c *ManageClient) CatalogCreateCassandraService(ctx context.Context, r *manage.CatalogCreateCassandraRequest) (jmxUser string, jmxPasswd string, err error)

CatalogCreateCassandraService creates a new catalog Cassandra service.

func (*ManageClient) CatalogCreateConsulService added in v0.8.1 

func (c *ManageClient) CatalogCreateConsulService(ctx context.Context, r *manage.CatalogCreateConsulRequest) (serverIPs []string, err error)

CatalogCreateConsulService creates a new catalog Consul service. return the consul server ips.

func (*ManageClient) CatalogCreateCouchDBService added in v0.8.1 

func (c *ManageClient) CatalogCreateCouchDBService(ctx context.Context, r *manage.CatalogCreateCouchDBRequest) error

CatalogCreateCouchDBService creates a new catalog CouchDB service.

func (*ManageClient) CatalogCreateElasticSearchService added in v0.8.1 

func (c *ManageClient) CatalogCreateElasticSearchService(ctx context.Context, r *manage.CatalogCreateElasticSearchRequest) error

CatalogCreateElasticSearchService creates a new catalog ElasticSearch service.

func (*ManageClient) CatalogCreateKafkaManagerService added in v0.9.4 

func (c *ManageClient) CatalogCreateKafkaManagerService(ctx context.Context, r *manage.CatalogCreateKafkaManagerRequest) error

CatalogCreateKafkaManagerService creates a new catalog Kafka Manager service.

func (*ManageClient) CatalogCreateKafkaService 

func (c *ManageClient) CatalogCreateKafkaService(ctx context.Context, r *manage.CatalogCreateKafkaRequest) (jmxUser string, jmxPasswd string, err error)

CatalogCreateKafkaService creates a new catalog Kafka service.

func (*ManageClient) CatalogCreateKafkaSinkESService added in v0.9.5 

func (c *ManageClient) CatalogCreateKafkaSinkESService(ctx context.Context, r *manage.CatalogCreateKafkaSinkESRequest) error

CatalogCreateKafkaSinkESService creates a new catalog Kafka sink elasticsearch service.

func (*ManageClient) CatalogCreateKibanaService added in v0.8.1 

func (c *ManageClient) CatalogCreateKibanaService(ctx context.Context, r *manage.CatalogCreateKibanaRequest) error

CatalogCreateKibanaService creates a new catalog Kibana service.

func (*ManageClient) CatalogCreateLogstashService added in v0.8.1 

func (c *ManageClient) CatalogCreateLogstashService(ctx context.Context, r *manage.CatalogCreateLogstashRequest) error

CatalogCreateLogstashService creates a new catalog Logstash service.

func (*ManageClient) CatalogCreateMongoDBService 

func (c *ManageClient) CatalogCreateMongoDBService(ctx context.Context, r *manage.CatalogCreateMongoDBRequest) (keyfileContent string, err error)

CatalogCreateMongoDBService creates a new catalog MongoDB ReplicaSet service.

func (*ManageClient) CatalogCreatePostgreSQLService 

func (c *ManageClient) CatalogCreatePostgreSQLService(ctx context.Context, r *manage.CatalogCreatePostgreSQLRequest) error

CatalogCreatePostgreSQLService creates a new catalog PostgreSQL service.

func (*ManageClient) CatalogCreateRedisService 

func (c *ManageClient) CatalogCreateRedisService(ctx context.Context, r *manage.CatalogCreateRedisRequest) error

CatalogCreateRedisService creates a new catalog Redis service.

func (*ManageClient) CatalogCreateTelegrafService added in v0.9.5 

func (c *ManageClient) CatalogCreateTelegrafService(ctx context.Context, r *manage.CatalogCreateTelegrafRequest) error

CatalogCreateTelegrafService creates a new catalog Telegraf service.

func (*ManageClient) CatalogCreateZooKeeperService 

func (c *ManageClient) CatalogCreateZooKeeperService(ctx context.Context, r *manage.CatalogCreateZooKeeperRequest) (jmxUser string, jmxPasswd string, err error)

CatalogCreateZooKeeperService creates a new catalog ZooKeeper service.

func (*ManageClient) CatalogScaleCassandraService added in v0.9.2 

func (c *ManageClient) CatalogScaleCassandraService(ctx context.Context, r *manage.CatalogScaleCassandraRequest) error

CatalogScaleCassandraService scales the Cassandra service.

func (*ManageClient) CreateService 

func (c *ManageClient) CreateService(ctx context.Context, r *manage.CreateServiceRequest) error

CreateService creates a new service

func (*ManageClient) DeleteService 

func (c *ManageClient) DeleteService(ctx context.Context, r *manage.DeleteServiceRequest) (volIDs []string, err error)

DeleteService deletes one service and returns the service's volume IDs

func (*ManageClient) DeleteTask 

func (c *ManageClient) DeleteTask(ctx context.Context, r *manage.DeleteTaskRequest) error

DeleteTask deletes the service task.

func (*ManageClient) GetConfigFile 

func (c *ManageClient) GetConfigFile(ctx context.Context, r *manage.GetConfigFileRequest) (*common.ConfigFile, error)

GetConfigFile gets the config file.

func (*ManageClient) GetServiceAttr 

func (c *ManageClient) GetServiceAttr(ctx context.Context, r *manage.ServiceCommonRequest) (*common.ServiceAttr, error)

GetServiceAttr gets the service details information

func (*ManageClient) GetServiceStatus 

func (c *ManageClient) GetServiceStatus(ctx context.Context, r *manage.ServiceCommonRequest) (*common.ServiceStatus, error)

GetServiceStatus gets the service running status.

func (*ManageClient) GetServiceTaskStatus added in v0.9.4 

func (c *ManageClient) GetServiceTaskStatus(ctx context.Context, r *manage.ServiceCommonRequest) (complete bool, statusMsg string, err error)

GetServiceTaskStatus gets the service management task status

func (*ManageClient) GetTaskStatus 

func (c *ManageClient) GetTaskStatus(ctx context.Context, r *manage.GetTaskStatusRequest) (*common.TaskStatus, error)

GetTaskStatus gets a task's status.

func (*ManageClient) InternalGetServiceTask 

func (c *ManageClient) InternalGetServiceTask(ctx context.Context, r *manage.InternalGetServiceTaskRequest) (taskID string, err error)

InternalGetServiceTask gets the service task ID.

func (*ManageClient) InternalListActiveServiceTasks 

func (c *ManageClient) InternalListActiveServiceTasks(ctx context.Context, r *manage.InternalListActiveServiceTasksRequest) (taskIDs map[string]bool, err error)

InternalListActiveServiceTasks lists the service active tasks.

func (*ManageClient) IsServiceInitialized 

func (c *ManageClient) IsServiceInitialized(ctx context.Context, r *manage.ServiceCommonRequest) (bool, error)

IsServiceInitialized checks whether the service is initialized

func (*ManageClient) ListService 

func (c *ManageClient) ListService(ctx context.Context, r *manage.ListServiceRequest) ([]*common.ServiceAttr, error)

ListService lists all services that match the required conditions

func (*ManageClient) ListServiceMember 

func (c *ManageClient) ListServiceMember(ctx context.Context, r *manage.ListServiceMemberRequest) ([]*common.ServiceMember, error)

ListServiceMember lists all serviceMembers of the service.

func (*ManageClient) RollingRestartService added in v0.9.4 

func (c *ManageClient) RollingRestartService(ctx context.Context, r *manage.ServiceCommonRequest) error

RollingRestartService rolling restarts the service containers

func (*ManageClient) RunTask 

func (c *ManageClient) RunTask(ctx context.Context, r *manage.RunTaskRequest) (taskID string, err error)

RunTask runs a task

func (*ManageClient) SetServiceInitialized 

func (c *ManageClient) SetServiceInitialized(ctx context.Context, r *manage.ServiceCommonRequest) error

SetServiceInitialized updates the service status to active

func (*ManageClient) StartService added in v0.9.2 

func (c *ManageClient) StartService(ctx context.Context, r *manage.ServiceCommonRequest) error

StartService starts the service containers

func (*ManageClient) StopService added in v0.9.2 

func (c *ManageClient) StopService(ctx context.Context, r *manage.ServiceCommonRequest) error

StopService stops the service containers

func (*ManageClient) UpdateServiceConfig added in v0.9.6 

func (c *ManageClient) UpdateServiceConfig(ctx context.Context, r *manage.UpdateServiceConfigRequest) error

UpdateServiceConfig updates the service config

func (*ManageClient) UpdateServiceResource added in v0.9.5 

func (c *ManageClient) UpdateServiceResource(ctx context.Context, r *manage.UpdateServiceResourceRequest) error

UpdateServiceResource updates the service resource

func (*ManageClient) UpgradeService added in v0.9.5 

func (c *ManageClient) UpgradeService(ctx context.Context, r *manage.ServiceCommonRequest) error

UpgradeService upgrades the service to the current release

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.