operations

type CancelOperationRequest struct {

	// The name of the operation resource to be cancelled.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type ClientOptions struct {
	Conn *conn.GrpcClientConn
}

type DeleteOperationRequest struct {

	// The name of the operation resource to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetOperationRequest struct {

	// The name of the operation resource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GrpcClient struct {
	OperationsClient
	// contains filtered or unexported fields
}

type ListOperationsRequest struct {

	// Optional. The name of the operation's parent resource. Not used at the moment.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. List operations on and after this date. Format is yyyymmdd. For example,
	// if you want to list all operations starting from June 01, 2021, set to `20210601`.
	// If not set, defaults to the first day of the current UTC month.
	AsOf string `protobuf:"bytes,2,opt,name=asOf,proto3" json:"asOf,omitempty"`
	// Optional. If true, include all operations that are marked as done. Exclude by
	// default.
	IncludeDone bool `protobuf:"varint,3,opt,name=includeDone,proto3" json:"includeDone,omitempty"`
	// contains filtered or unexported fields
}

type OperationsClient interface {
	// Lists long-running operations.
	ListOperations(ctx context.Context, in *ListOperationsRequest, opts ...grpc.CallOption) (Operations_ListOperationsClient, error)
	// Gets the latest state of a long-running operation. You can use this method to
	// poll the operation result at intervals.
	GetOperation(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*protos.Operation, error)
	// Deletes a long-running operation. This method indicates that the client is no
	// longer interested in the operation result. It does not cancel the operation.
	DeleteOperation(ctx context.Context, in *DeleteOperationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Starts asynchronous cancellation on a long-running operation. The server makes
	// a best effort to cancel the operation, but success is not guaranteed. On successful
	// cancellation, the operation is not deleted; instead, it becomes an operation with
	// a value of [google.rpc.Status.code][google.rpc.Status.code] 1, corresponding
	// to `Code.CANCELLED`.
	CancelOperation(ctx context.Context, in *CancelOperationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Waits for the specified long-running operation until it is done or reaches
	// at most a specified timeout, returning the latest state. If the operation
	// is already done, the latest state is immediately returned. If the timeout
	// specified is greater than the default HTTP/RPC timeout, the HTTP/RPC
	// timeout is used. If the server does not support this method, it returns
	// `google.rpc.Code.UNIMPLEMENTED`.
	// Note that this method is on a best-effort basis. It may return the latest
	// state before the specified timeout (including immediately), meaning, even an
	// immediate response is no guarantee that the operation is done.
	// At the moment, Blue's default RPC timeout is around one hour.
	WaitOperation(ctx context.Context, in *WaitOperationRequest, opts ...grpc.CallOption) (*protos.Operation, error)
}

type OperationsServer interface {
	// Lists long-running operations.
	ListOperations(*ListOperationsRequest, Operations_ListOperationsServer) error
	// Gets the latest state of a long-running operation. You can use this method to
	// poll the operation result at intervals.
	GetOperation(context.Context, *GetOperationRequest) (*protos.Operation, error)
	// Deletes a long-running operation. This method indicates that the client is no
	// longer interested in the operation result. It does not cancel the operation.
	DeleteOperation(context.Context, *DeleteOperationRequest) (*emptypb.Empty, error)
	// Starts asynchronous cancellation on a long-running operation. The server makes
	// a best effort to cancel the operation, but success is not guaranteed. On successful
	// cancellation, the operation is not deleted; instead, it becomes an operation with
	// a value of [google.rpc.Status.code][google.rpc.Status.code] 1, corresponding
	// to `Code.CANCELLED`.
	CancelOperation(context.Context, *CancelOperationRequest) (*emptypb.Empty, error)
	// Waits for the specified long-running operation until it is done or reaches
	// at most a specified timeout, returning the latest state. If the operation
	// is already done, the latest state is immediately returned. If the timeout
	// specified is greater than the default HTTP/RPC timeout, the HTTP/RPC
	// timeout is used. If the server does not support this method, it returns
	// `google.rpc.Code.UNIMPLEMENTED`.
	// Note that this method is on a best-effort basis. It may return the latest
	// state before the specified timeout (including immediately), meaning, even an
	// immediate response is no guarantee that the operation is done.
	// At the moment, Blue's default RPC timeout is around one hour.
	WaitOperation(context.Context, *WaitOperationRequest) (*protos.Operation, error)
	// contains filtered or unexported methods
}

type Operations_ListOperationsClient interface {
	Recv() (*protos.Operation, error)
	grpc.ClientStream
}

type Operations_ListOperationsServer interface {
	Send(*protos.Operation) error
	grpc.ServerStream
}

type UnimplementedOperationsServer struct {
}

type UnsafeOperationsServer interface {
	// contains filtered or unexported methods
}

type WaitOperationRequest struct {

	// The name of the operation resource to wait on.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The maximum duration to wait before timing out. If left blank, the wait
	// will be at most the time permitted by the underlying HTTP/RPC protocol.
	// If RPC context deadline is also specified, the shorter one will be used.
	Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}