clickhouse

package
v0.0.0-...-417428f Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2020 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

nolint

nolint

nolint

nolint

nolint

nolint

nolint

nolint

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BackupIterator 

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

func (*BackupIterator) Error 

func (it *BackupIterator) Error() error

func (*BackupIterator) Next 

func (it *BackupIterator) Next() bool

func (*BackupIterator) Value 

func (it *BackupIterator) Value() *clickhouse.Backup

type BackupServiceClient 

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

BackupServiceClient is a clickhouse.BackupServiceClient with lazy GRPC connection initialization.

func (*BackupServiceClient) BackupIterator 

func (c *BackupServiceClient) BackupIterator(ctx context.Context, folderId string, opts ...grpc.CallOption) *BackupIterator

func (*BackupServiceClient) Get 

func (c *BackupServiceClient) Get(ctx context.Context, in *clickhouse.GetBackupRequest, opts ...grpc.CallOption) (*clickhouse.Backup, error)

Get implements clickhouse.BackupServiceClient

func (*BackupServiceClient) List 

func (c *BackupServiceClient) List(ctx context.Context, in *clickhouse.ListBackupsRequest, opts ...grpc.CallOption) (*clickhouse.ListBackupsResponse, error)

List implements clickhouse.BackupServiceClient

type Clickhouse 

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

Clickhouse provides access to "clickhouse" component of Yandex.Cloud

func NewClickhouse 

func NewClickhouse(g func(ctx context.Context) (*grpc.ClientConn, error)) *Clickhouse

NewClickhouse creates instance of Clickhouse

func (*Clickhouse) Backup 

func (c *Clickhouse) Backup() *BackupServiceClient

Backup gets BackupService client

func (*Clickhouse) Cluster 

func (c *Clickhouse) Cluster() *ClusterServiceClient

Cluster gets ClusterService client

func (*Clickhouse) Database 

func (c *Clickhouse) Database() *DatabaseServiceClient

Database gets DatabaseService client

func (*Clickhouse) FormatSchema 

func (c *Clickhouse) FormatSchema() *FormatSchemaServiceClient

FormatSchema gets FormatSchemaService client

func (*Clickhouse) MlModel 

func (c *Clickhouse) MlModel() *MlModelServiceClient

MlModel gets MlModelService client

func (*Clickhouse) ResourcePreset 

func (c *Clickhouse) ResourcePreset() *ResourcePresetServiceClient

ResourcePreset gets ResourcePresetService client

func (*Clickhouse) User 

func (c *Clickhouse) User() *UserServiceClient

User gets UserService client

func (*Clickhouse) Versions 

func (c *Clickhouse) Versions() *VersionsServiceClient

Versions gets VersionsService client

type ClusterBackupsIterator 

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

func (*ClusterBackupsIterator) Error 

func (it *ClusterBackupsIterator) Error() error

func (*ClusterBackupsIterator) Next 

func (it *ClusterBackupsIterator) Next() bool

func (*ClusterBackupsIterator) Value 

func (it *ClusterBackupsIterator) Value() *clickhouse.Backup

type ClusterHostsIterator 

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

func (*ClusterHostsIterator) Error 

func (it *ClusterHostsIterator) Error() error

func (*ClusterHostsIterator) Next 

func (it *ClusterHostsIterator) Next() bool

func (*ClusterHostsIterator) Value 

func (it *ClusterHostsIterator) Value() *clickhouse.Host

type ClusterIterator 

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

func (*ClusterIterator) Error 

func (it *ClusterIterator) Error() error

func (*ClusterIterator) Next 

func (it *ClusterIterator) Next() bool

func (*ClusterIterator) Value 

func (it *ClusterIterator) Value() *clickhouse.Cluster

type ClusterLogsIterator 

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

func (*ClusterLogsIterator) Error 

func (it *ClusterLogsIterator) Error() error

func (*ClusterLogsIterator) Next 

func (it *ClusterLogsIterator) Next() bool

func (*ClusterLogsIterator) Value 

func (it *ClusterLogsIterator) Value() *clickhouse.LogRecord

type ClusterOperationsIterator 

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

func (*ClusterOperationsIterator) Error 

func (it *ClusterOperationsIterator) Error() error

func (*ClusterOperationsIterator) Next 

func (it *ClusterOperationsIterator) Next() bool

func (*ClusterOperationsIterator) Value 

func (it *ClusterOperationsIterator) Value() *operation.Operation

type ClusterServiceClient 

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

ClusterServiceClient is a clickhouse.ClusterServiceClient with lazy GRPC connection initialization.

func (*ClusterServiceClient) AddHosts 

func (c *ClusterServiceClient) AddHosts(ctx context.Context, in *clickhouse.AddClusterHostsRequest, opts ...grpc.CallOption) (*operation.Operation, error)

AddHosts implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) AddShard 

func (c *ClusterServiceClient) AddShard(ctx context.Context, in *clickhouse.AddClusterShardRequest, opts ...grpc.CallOption) (*operation.Operation, error)

AddShard implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) AddZookeeper 

func (c *ClusterServiceClient) AddZookeeper(ctx context.Context, in *clickhouse.AddClusterZookeeperRequest, opts ...grpc.CallOption) (*operation.Operation, error)

AddZookeeper implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) Backup 

func (c *ClusterServiceClient) Backup(ctx context.Context, in *clickhouse.BackupClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Backup implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) ClusterBackupsIterator 

func (c *ClusterServiceClient) ClusterBackupsIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *ClusterBackupsIterator

func (*ClusterServiceClient) ClusterHostsIterator 

func (c *ClusterServiceClient) ClusterHostsIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *ClusterHostsIterator

func (*ClusterServiceClient) ClusterIterator 

func (c *ClusterServiceClient) ClusterIterator(ctx context.Context, folderId string, opts ...grpc.CallOption) *ClusterIterator

func (*ClusterServiceClient) ClusterLogsIterator 

func (c *ClusterServiceClient) ClusterLogsIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *ClusterLogsIterator

func (*ClusterServiceClient) ClusterOperationsIterator 

func (c *ClusterServiceClient) ClusterOperationsIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *ClusterOperationsIterator

func (*ClusterServiceClient) ClusterShardGroupsIterator 

func (c *ClusterServiceClient) ClusterShardGroupsIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *ClusterShardGroupsIterator

func (*ClusterServiceClient) ClusterShardsIterator 

func (c *ClusterServiceClient) ClusterShardsIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *ClusterShardsIterator

func (*ClusterServiceClient) Create 

func (c *ClusterServiceClient) Create(ctx context.Context, in *clickhouse.CreateClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) CreateExternalDictionary 

func (c *ClusterServiceClient) CreateExternalDictionary(ctx context.Context, in *clickhouse.CreateClusterExternalDictionaryRequest, opts ...grpc.CallOption) (*operation.Operation, error)

CreateExternalDictionary implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) CreateShardGroup 

func (c *ClusterServiceClient) CreateShardGroup(ctx context.Context, in *clickhouse.CreateClusterShardGroupRequest, opts ...grpc.CallOption) (*operation.Operation, error)

CreateShardGroup implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) Delete 

func (c *ClusterServiceClient) Delete(ctx context.Context, in *clickhouse.DeleteClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) DeleteExternalDictionary 

func (c *ClusterServiceClient) DeleteExternalDictionary(ctx context.Context, in *clickhouse.DeleteClusterExternalDictionaryRequest, opts ...grpc.CallOption) (*operation.Operation, error)

DeleteExternalDictionary implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) DeleteHosts 

func (c *ClusterServiceClient) DeleteHosts(ctx context.Context, in *clickhouse.DeleteClusterHostsRequest, opts ...grpc.CallOption) (*operation.Operation, error)

DeleteHosts implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) DeleteShard 

func (c *ClusterServiceClient) DeleteShard(ctx context.Context, in *clickhouse.DeleteClusterShardRequest, opts ...grpc.CallOption) (*operation.Operation, error)

DeleteShard implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) DeleteShardGroup 

func (c *ClusterServiceClient) DeleteShardGroup(ctx context.Context, in *clickhouse.DeleteClusterShardGroupRequest, opts ...grpc.CallOption) (*operation.Operation, error)

DeleteShardGroup implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) Get 

func (c *ClusterServiceClient) Get(ctx context.Context, in *clickhouse.GetClusterRequest, opts ...grpc.CallOption) (*clickhouse.Cluster, error)

Get implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) GetShard 

func (c *ClusterServiceClient) GetShard(ctx context.Context, in *clickhouse.GetClusterShardRequest, opts ...grpc.CallOption) (*clickhouse.Shard, error)

GetShard implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) GetShardGroup 

func (c *ClusterServiceClient) GetShardGroup(ctx context.Context, in *clickhouse.GetClusterShardGroupRequest, opts ...grpc.CallOption) (*clickhouse.ShardGroup, error)

GetShardGroup implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) List 

func (c *ClusterServiceClient) List(ctx context.Context, in *clickhouse.ListClustersRequest, opts ...grpc.CallOption) (*clickhouse.ListClustersResponse, error)

List implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) ListBackups 

func (c *ClusterServiceClient) ListBackups(ctx context.Context, in *clickhouse.ListClusterBackupsRequest, opts ...grpc.CallOption) (*clickhouse.ListClusterBackupsResponse, error)

ListBackups implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) ListHosts 

func (c *ClusterServiceClient) ListHosts(ctx context.Context, in *clickhouse.ListClusterHostsRequest, opts ...grpc.CallOption) (*clickhouse.ListClusterHostsResponse, error)

ListHosts implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) ListLogs 

func (c *ClusterServiceClient) ListLogs(ctx context.Context, in *clickhouse.ListClusterLogsRequest, opts ...grpc.CallOption) (*clickhouse.ListClusterLogsResponse, error)

ListLogs implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) ListOperations 

func (c *ClusterServiceClient) ListOperations(ctx context.Context, in *clickhouse.ListClusterOperationsRequest, opts ...grpc.CallOption) (*clickhouse.ListClusterOperationsResponse, error)

ListOperations implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) ListShardGroups 

func (c *ClusterServiceClient) ListShardGroups(ctx context.Context, in *clickhouse.ListClusterShardGroupsRequest, opts ...grpc.CallOption) (*clickhouse.ListClusterShardGroupsResponse, error)

ListShardGroups implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) ListShards 

func (c *ClusterServiceClient) ListShards(ctx context.Context, in *clickhouse.ListClusterShardsRequest, opts ...grpc.CallOption) (*clickhouse.ListClusterShardsResponse, error)

ListShards implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) Move 

func (c *ClusterServiceClient) Move(ctx context.Context, in *clickhouse.MoveClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Move implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) RescheduleMaintenance 

func (c *ClusterServiceClient) RescheduleMaintenance(ctx context.Context, in *clickhouse.RescheduleMaintenanceRequest, opts ...grpc.CallOption) (*operation.Operation, error)

RescheduleMaintenance implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) Restore 

func (c *ClusterServiceClient) Restore(ctx context.Context, in *clickhouse.RestoreClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Restore implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) Start 

func (c *ClusterServiceClient) Start(ctx context.Context, in *clickhouse.StartClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Start implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) Stop 

func (c *ClusterServiceClient) Stop(ctx context.Context, in *clickhouse.StopClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Stop implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) StreamLogs 

func (c *ClusterServiceClient) StreamLogs(ctx context.Context, in *clickhouse.StreamClusterLogsRequest, opts ...grpc.CallOption) (clickhouse.ClusterService_StreamLogsClient, error)

StreamLogs implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) Update 

func (c *ClusterServiceClient) Update(ctx context.Context, in *clickhouse.UpdateClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Update implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) UpdateShard 

func (c *ClusterServiceClient) UpdateShard(ctx context.Context, in *clickhouse.UpdateClusterShardRequest, opts ...grpc.CallOption) (*operation.Operation, error)

UpdateShard implements clickhouse.ClusterServiceClient

func (*ClusterServiceClient) UpdateShardGroup 

func (c *ClusterServiceClient) UpdateShardGroup(ctx context.Context, in *clickhouse.UpdateClusterShardGroupRequest, opts ...grpc.CallOption) (*operation.Operation, error)

UpdateShardGroup implements clickhouse.ClusterServiceClient

type ClusterShardGroupsIterator 

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

func (*ClusterShardGroupsIterator) Error 

func (it *ClusterShardGroupsIterator) Error() error

func (*ClusterShardGroupsIterator) Next 

func (it *ClusterShardGroupsIterator) Next() bool

func (*ClusterShardGroupsIterator) Value 

func (it *ClusterShardGroupsIterator) Value() *clickhouse.ShardGroup

type ClusterShardsIterator 

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

func (*ClusterShardsIterator) Error 

func (it *ClusterShardsIterator) Error() error

func (*ClusterShardsIterator) Next 

func (it *ClusterShardsIterator) Next() bool

func (*ClusterShardsIterator) Value 

func (it *ClusterShardsIterator) Value() *clickhouse.Shard

type DatabaseIterator 

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

func (*DatabaseIterator) Error 

func (it *DatabaseIterator) Error() error

func (*DatabaseIterator) Next 

func (it *DatabaseIterator) Next() bool

func (*DatabaseIterator) Value 

func (it *DatabaseIterator) Value() *clickhouse.Database

type DatabaseServiceClient 

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

DatabaseServiceClient is a clickhouse.DatabaseServiceClient with lazy GRPC connection initialization.

func (*DatabaseServiceClient) Create 

func (c *DatabaseServiceClient) Create(ctx context.Context, in *clickhouse.CreateDatabaseRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements clickhouse.DatabaseServiceClient

func (*DatabaseServiceClient) DatabaseIterator 

func (c *DatabaseServiceClient) DatabaseIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *DatabaseIterator

func (*DatabaseServiceClient) Delete 

func (c *DatabaseServiceClient) Delete(ctx context.Context, in *clickhouse.DeleteDatabaseRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements clickhouse.DatabaseServiceClient

func (*DatabaseServiceClient) Get 

func (c *DatabaseServiceClient) Get(ctx context.Context, in *clickhouse.GetDatabaseRequest, opts ...grpc.CallOption) (*clickhouse.Database, error)

Get implements clickhouse.DatabaseServiceClient

func (*DatabaseServiceClient) List 

func (c *DatabaseServiceClient) List(ctx context.Context, in *clickhouse.ListDatabasesRequest, opts ...grpc.CallOption) (*clickhouse.ListDatabasesResponse, error)

List implements clickhouse.DatabaseServiceClient

type FormatSchemaIterator 

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

func (*FormatSchemaIterator) Error 

func (it *FormatSchemaIterator) Error() error

func (*FormatSchemaIterator) Next 

func (it *FormatSchemaIterator) Next() bool

func (*FormatSchemaIterator) Value 

func (it *FormatSchemaIterator) Value() *clickhouse.FormatSchema

type FormatSchemaServiceClient 

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

FormatSchemaServiceClient is a clickhouse.FormatSchemaServiceClient with lazy GRPC connection initialization.

func (*FormatSchemaServiceClient) Create 

func (c *FormatSchemaServiceClient) Create(ctx context.Context, in *clickhouse.CreateFormatSchemaRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements clickhouse.FormatSchemaServiceClient

func (*FormatSchemaServiceClient) Delete 

func (c *FormatSchemaServiceClient) Delete(ctx context.Context, in *clickhouse.DeleteFormatSchemaRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements clickhouse.FormatSchemaServiceClient

func (*FormatSchemaServiceClient) FormatSchemaIterator 

func (c *FormatSchemaServiceClient) FormatSchemaIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *FormatSchemaIterator

func (*FormatSchemaServiceClient) Get 

func (c *FormatSchemaServiceClient) Get(ctx context.Context, in *clickhouse.GetFormatSchemaRequest, opts ...grpc.CallOption) (*clickhouse.FormatSchema, error)

Get implements clickhouse.FormatSchemaServiceClient

func (*FormatSchemaServiceClient) List 

func (c *FormatSchemaServiceClient) List(ctx context.Context, in *clickhouse.ListFormatSchemasRequest, opts ...grpc.CallOption) (*clickhouse.ListFormatSchemasResponse, error)

List implements clickhouse.FormatSchemaServiceClient

func (*FormatSchemaServiceClient) Update 

func (c *FormatSchemaServiceClient) Update(ctx context.Context, in *clickhouse.UpdateFormatSchemaRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Update implements clickhouse.FormatSchemaServiceClient

type MlModelIterator 

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

func (*MlModelIterator) Error 

func (it *MlModelIterator) Error() error

func (*MlModelIterator) Next 

func (it *MlModelIterator) Next() bool

func (*MlModelIterator) Value 

func (it *MlModelIterator) Value() *clickhouse.MlModel

type MlModelServiceClient 

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

MlModelServiceClient is a clickhouse.MlModelServiceClient with lazy GRPC connection initialization.

func (*MlModelServiceClient) Create 

func (c *MlModelServiceClient) Create(ctx context.Context, in *clickhouse.CreateMlModelRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements clickhouse.MlModelServiceClient

func (*MlModelServiceClient) Delete 

func (c *MlModelServiceClient) Delete(ctx context.Context, in *clickhouse.DeleteMlModelRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements clickhouse.MlModelServiceClient

func (*MlModelServiceClient) Get 

func (c *MlModelServiceClient) Get(ctx context.Context, in *clickhouse.GetMlModelRequest, opts ...grpc.CallOption) (*clickhouse.MlModel, error)

Get implements clickhouse.MlModelServiceClient

func (*MlModelServiceClient) List 

func (c *MlModelServiceClient) List(ctx context.Context, in *clickhouse.ListMlModelsRequest, opts ...grpc.CallOption) (*clickhouse.ListMlModelsResponse, error)

List implements clickhouse.MlModelServiceClient

func (*MlModelServiceClient) MlModelIterator 

func (c *MlModelServiceClient) MlModelIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *MlModelIterator

func (*MlModelServiceClient) Update 

func (c *MlModelServiceClient) Update(ctx context.Context, in *clickhouse.UpdateMlModelRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Update implements clickhouse.MlModelServiceClient

type ResourcePresetIterator 

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

func (*ResourcePresetIterator) Error 

func (it *ResourcePresetIterator) Error() error

func (*ResourcePresetIterator) Next 

func (it *ResourcePresetIterator) Next() bool

func (*ResourcePresetIterator) Value 

func (it *ResourcePresetIterator) Value() *clickhouse.ResourcePreset

type ResourcePresetServiceClient 

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

ResourcePresetServiceClient is a clickhouse.ResourcePresetServiceClient with lazy GRPC connection initialization.

func (*ResourcePresetServiceClient) Get 

func (c *ResourcePresetServiceClient) Get(ctx context.Context, in *clickhouse.GetResourcePresetRequest, opts ...grpc.CallOption) (*clickhouse.ResourcePreset, error)

Get implements clickhouse.ResourcePresetServiceClient

func (*ResourcePresetServiceClient) List 

func (c *ResourcePresetServiceClient) List(ctx context.Context, in *clickhouse.ListResourcePresetsRequest, opts ...grpc.CallOption) (*clickhouse.ListResourcePresetsResponse, error)

List implements clickhouse.ResourcePresetServiceClient

func (*ResourcePresetServiceClient) ResourcePresetIterator 

func (c *ResourcePresetServiceClient) ResourcePresetIterator(ctx context.Context, opts ...grpc.CallOption) *ResourcePresetIterator

type UserIterator 

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

func (*UserIterator) Error 

func (it *UserIterator) Error() error

func (*UserIterator) Next 

func (it *UserIterator) Next() bool

func (*UserIterator) Value 

func (it *UserIterator) Value() *clickhouse.User

type UserServiceClient 

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

UserServiceClient is a clickhouse.UserServiceClient with lazy GRPC connection initialization.

func (*UserServiceClient) Create 

func (c *UserServiceClient) Create(ctx context.Context, in *clickhouse.CreateUserRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements clickhouse.UserServiceClient

func (*UserServiceClient) Delete 

func (c *UserServiceClient) Delete(ctx context.Context, in *clickhouse.DeleteUserRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements clickhouse.UserServiceClient

func (*UserServiceClient) Get 

func (c *UserServiceClient) Get(ctx context.Context, in *clickhouse.GetUserRequest, opts ...grpc.CallOption) (*clickhouse.User, error)

Get implements clickhouse.UserServiceClient

func (*UserServiceClient) GrantPermission 

func (c *UserServiceClient) GrantPermission(ctx context.Context, in *clickhouse.GrantUserPermissionRequest, opts ...grpc.CallOption) (*operation.Operation, error)

GrantPermission implements clickhouse.UserServiceClient

func (*UserServiceClient) List 

func (c *UserServiceClient) List(ctx context.Context, in *clickhouse.ListUsersRequest, opts ...grpc.CallOption) (*clickhouse.ListUsersResponse, error)

List implements clickhouse.UserServiceClient

func (*UserServiceClient) RevokePermission 

func (c *UserServiceClient) RevokePermission(ctx context.Context, in *clickhouse.RevokeUserPermissionRequest, opts ...grpc.CallOption) (*operation.Operation, error)

RevokePermission implements clickhouse.UserServiceClient

func (*UserServiceClient) Update 

func (c *UserServiceClient) Update(ctx context.Context, in *clickhouse.UpdateUserRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Update implements clickhouse.UserServiceClient

func (*UserServiceClient) UserIterator 

func (c *UserServiceClient) UserIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *UserIterator

type VersionsIterator 

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

func (*VersionsIterator) Error 

func (it *VersionsIterator) Error() error

func (*VersionsIterator) Next 

func (it *VersionsIterator) Next() bool

func (*VersionsIterator) Value 

func (it *VersionsIterator) Value() *clickhouse.Version

type VersionsServiceClient 

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

VersionsServiceClient is a clickhouse.VersionsServiceClient with lazy GRPC connection initialization.

func (*VersionsServiceClient) List 

func (c *VersionsServiceClient) List(ctx context.Context, in *clickhouse.ListVersionsRequest, opts ...grpc.CallOption) (*clickhouse.ListVersionsResponse, error)

List implements clickhouse.VersionsServiceClient

func (*VersionsServiceClient) VersionsIterator 

func (c *VersionsServiceClient) VersionsIterator(ctx context.Context, opts ...grpc.CallOption) *VersionsIterator

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.