Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

client

package

Go to main page

Versions in this module

v0

v0.9.6

May 8, 2018

Changes in this version

type ManageClient

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

v0.9.5

Apr 6, 2018

Changes in this version

type ManageClient

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

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

+ func (c *ManageClient) CatalogUpdateKafkaService(ctx context.Context, r *manage.CatalogUpdateKafkaRequest) error

+ func (c *ManageClient) CatalogUpdateZooKeeperService(ctx context.Context, r *manage.CatalogUpdateZooKeeperRequest) error

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

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

v0.9.4

Feb 28, 2018

Changes in this version

type ManageClient

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

+ func (c *ManageClient) CatalogUpdateRedisService(ctx context.Context, r *manage.CatalogUpdateRedisRequest) error

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

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

v0.9.3

Feb 5, 2018

v0.9.2

Jan 1, 2018

Changes in this version

type ManageClient

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

+ func (c *ManageClient) CatalogUpdateCassandraService(ctx context.Context, r *manage.CatalogUpdateCassandraRequest) error

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

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

v0.9.1

Dec 6, 2017

v0.8.1

Oct 27, 2017

Changes in this version

type ManageClient

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

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

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

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

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

v0.7.1

Sep 9, 2017

Changes in this version

+ type ManageClient struct

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

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

+ func (c *ManageClient) CatalogCreateCassandraService(ctx context.Context, r *manage.CatalogCreateCassandraRequest) error

+ func (c *ManageClient) CatalogCreateKafkaService(ctx context.Context, r *manage.CatalogCreateKafkaRequest) error

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

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

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

+ func (c *ManageClient) CatalogCreateZooKeeperService(ctx context.Context, r *manage.CatalogCreateZooKeeperRequest) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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