Documentation
¶
Index ¶
- Constants
- type Client
- type Operation
- func (o *Operation) Client() Client
- func (o *Operation) CreatedAt() time.Time
- func (o *Operation) CreatedBy() string
- func (o *Operation) Description() string
- func (o *Operation) Done() bool
- func (o *Operation) Error() error
- func (o *Operation) ErrorStatus() *status.Status
- func (o *Operation) Failed() bool
- func (o *Operation) Id() string
- func (o *Operation) Metadata() map[string]string
- func (o *Operation) Ok() bool
- func (o *Operation) Poll(ctx context.Context, opts ...grpc.CallOption) error
- func (o *Operation) Proto() *Proto
- func (o *Operation) ResourceId() string
- func (o *Operation) Wait(ctx context.Context, opts ...grpc.CallOption) error
- func (o *Operation) WaitInterval(ctx context.Context, pollInterval time.Duration, opts ...grpc.CallOption) error
- type OperationServiceClient
- type Proto
Constants ¶
View Source
const ( CLICKHOUSE_OPERATION_PREFIX = "cho" KAFKA_OPERATION_PREFIX = "kfo" TRANSFER_OPERATION_PREFIX = "dtj" TRANSFER_ENDPOINTS_OPERATION_PREFIX = "dte" )
View Source
const DefaultPollInterval = time.Second
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client = OperationServiceClient
type Operation ¶
type Operation struct {
// contains filtered or unexported fields
}
func (*Operation) Description ¶
func (*Operation) ErrorStatus ¶
func (*Operation) Poll ¶
Poll gets new state of operation from operation client. On success the operation state is updated. Returns error if update request failed.
func (*Operation) ResourceId ¶
func (*Operation) WaitInterval ¶
type OperationServiceClient ¶
type OperationServiceClient interface {
}
Source Files
Click to show internal directories.
Click to hide internal directories.