v1

package
v0.0.0-...-7648494 Latest Latest
Warning

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

 Go to latest Published: Aug 9, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	OperationState_name = map[int32]string{
		0: "ENQUEUED",
		1: "PROCESSING",
		2: "DONE",
		3: "FAILED",
	}
	OperationState_value = map[string]int32{
		"ENQUEUED":   0,
		"PROCESSING": 1,
		"DONE":       2,
		"FAILED":     3,
	}
)

Enum value maps for OperationState.

View Source 
var File_tinkoff_cloud_longrunning_v1_longrunning_proto protoreflect.FileDescriptor
View Source 
var Operations_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tinkoff.cloud.longrunning.v1.Operations",
	HandlerType: (*OperationsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOperation",
			Handler:    _Operations_GetOperation_Handler,
		},
		{
			MethodName: "WaitOperation",
			Handler:    _Operations_WaitOperation_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _Operations_ListOperations_Handler,
		},
		{
			MethodName: "DeleteOperation",
			Handler:    _Operations_DeleteOperation_Handler,
		},
		{
			MethodName: "CancelOperation",
			Handler:    _Operations_CancelOperation_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchOperations",
			Handler:       _Operations_WatchOperations_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "tinkoff/cloud/longrunning/v1/longrunning.proto",
}

Operations_ServiceDesc is the grpc.ServiceDesc for Operations service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOperationsServer 

func RegisterOperationsServer(s grpc.ServiceRegistrar, srv OperationsServer)

Types

type CancelOperationRequest 

type CancelOperationRequest struct {

	// Operation filter
	Filter *OperationFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelOperationRequest) Descriptor deprecated 

func (*CancelOperationRequest) Descriptor() ([]byte, []int)

Deprecated: Use CancelOperationRequest.ProtoReflect.Descriptor instead.

func (*CancelOperationRequest) GetFilter 

func (x *CancelOperationRequest) GetFilter() *OperationFilter

func (*CancelOperationRequest) ProtoMessage 

func (*CancelOperationRequest) ProtoMessage()

func (*CancelOperationRequest) ProtoReflect 

func (x *CancelOperationRequest) ProtoReflect() protoreflect.Message

func (*CancelOperationRequest) Reset 

func (x *CancelOperationRequest) Reset()

func (*CancelOperationRequest) String 

func (x *CancelOperationRequest) String() string

type DeleteOperationRequest 

type DeleteOperationRequest struct {

	// Operation filter
	Filter *OperationFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteOperationRequest) Descriptor deprecated 

func (*DeleteOperationRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteOperationRequest.ProtoReflect.Descriptor instead.

func (*DeleteOperationRequest) GetFilter 

func (x *DeleteOperationRequest) GetFilter() *OperationFilter

func (*DeleteOperationRequest) ProtoMessage 

func (*DeleteOperationRequest) ProtoMessage()

func (*DeleteOperationRequest) ProtoReflect 

func (x *DeleteOperationRequest) ProtoReflect() protoreflect.Message

func (*DeleteOperationRequest) Reset 

func (x *DeleteOperationRequest) Reset()

func (*DeleteOperationRequest) String 

func (x *DeleteOperationRequest) String() string

type GetOperationRequest 

type GetOperationRequest struct {

	// Operation ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationRequest) Descriptor deprecated 

func (*GetOperationRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetOperationRequest.ProtoReflect.Descriptor instead.

func (*GetOperationRequest) GetId 

func (x *GetOperationRequest) GetId() string

func (*GetOperationRequest) ProtoMessage 

func (*GetOperationRequest) ProtoMessage()

func (*GetOperationRequest) ProtoReflect 

func (x *GetOperationRequest) ProtoReflect() protoreflect.Message

func (*GetOperationRequest) Reset 

func (x *GetOperationRequest) Reset()

func (*GetOperationRequest) String 

func (x *GetOperationRequest) String() string

type ListOperationsRequest 

type ListOperationsRequest struct {

	// Operation filter
	Filter *OperationFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// Page size
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOperationsRequest) Descriptor deprecated 

func (*ListOperationsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListOperationsRequest) GetFilter 

func (x *ListOperationsRequest) GetFilter() *OperationFilter

func (*ListOperationsRequest) GetPageSize 

func (x *ListOperationsRequest) GetPageSize() int32

func (*ListOperationsRequest) GetPageToken 

func (x *ListOperationsRequest) GetPageToken() string

func (*ListOperationsRequest) ProtoMessage 

func (*ListOperationsRequest) ProtoMessage()

func (*ListOperationsRequest) ProtoReflect 

func (x *ListOperationsRequest) ProtoReflect() protoreflect.Message

func (*ListOperationsRequest) Reset 

func (x *ListOperationsRequest) Reset()

func (*ListOperationsRequest) String 

func (x *ListOperationsRequest) String() string

type ListOperationsResponse 

type ListOperationsResponse struct {

	// Operations for current page
	Operations []*Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Next page token
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOperationsResponse) Descriptor deprecated 

func (*ListOperationsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListOperationsResponse) GetNextPageToken 

func (x *ListOperationsResponse) GetNextPageToken() string

func (*ListOperationsResponse) GetOperations 

func (x *ListOperationsResponse) GetOperations() []*Operation

func (*ListOperationsResponse) ProtoMessage 

func (*ListOperationsResponse) ProtoMessage()

func (*ListOperationsResponse) ProtoReflect 

func (x *ListOperationsResponse) ProtoReflect() protoreflect.Message

func (*ListOperationsResponse) Reset 

func (x *ListOperationsResponse) Reset()

func (*ListOperationsResponse) String 

func (x *ListOperationsResponse) String() string

type Operation 

type Operation struct {

	// Operation ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Operation group
	Group string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	// Service-specific metadata associated with the operation.
	Metadata *anypb.Any `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Operation state
	State OperationState `protobuf:"varint,4,opt,name=state,proto3,enum=tinkoff.cloud.longrunning.v1.OperationState" json:"state,omitempty"`
	// This can either be the result of finished operation or an error.
	//
	// Types that are assignable to Result:
	//	*Operation_Error
	//	*Operation_Response
	Result isOperation_Result `protobuf_oneof:"result"`
	// This field contains optional client request id, which can be passed via 'x-client-request-id' HTTP header to the method that created the operation (e.g. LongRunningRecognize).
	XClientRequestId string `protobuf:"bytes,7,opt,name=x_client_request_id,json=xClientRequestId,proto3" json:"x_client_request_id,omitempty"`
	// contains filtered or unexported fields
}

A message that represents long-running operation and its state. This message also encapsulates any service-specific results of the operation and its metadata.

func (*Operation) Descriptor deprecated 

func (*Operation) Descriptor() ([]byte, []int)

Deprecated: Use Operation.ProtoReflect.Descriptor instead.

func (*Operation) GetError 

func (x *Operation) GetError() *status.Status

func (*Operation) GetGroup 

func (x *Operation) GetGroup() string

func (*Operation) GetId 

func (x *Operation) GetId() string

func (*Operation) GetMetadata 

func (x *Operation) GetMetadata() *anypb.Any

func (*Operation) GetResponse 

func (x *Operation) GetResponse() *anypb.Any

func (*Operation) GetResult 

func (m *Operation) GetResult() isOperation_Result

func (*Operation) GetState 

func (x *Operation) GetState() OperationState

func (*Operation) GetXClientRequestId 

func (x *Operation) GetXClientRequestId() string

func (*Operation) ProtoMessage 

func (*Operation) ProtoMessage()

func (*Operation) ProtoReflect 

func (x *Operation) ProtoReflect() protoreflect.Message

func (*Operation) Reset 

func (x *Operation) Reset()

func (*Operation) String 

func (x *Operation) String() string

type OperationFilter 

type OperationFilter struct {

	// Service ID filter. Use this field to filter the list of operations by service identifier.
	//
	// Types that are assignable to ServiceId:
	//	*OperationFilter_ExactServiceId
	//	*OperationFilter_AnyServiceId
	ServiceId isOperationFilter_ServiceId `protobuf_oneof:"service_id"`
	// Operation ID filter
	//
	// Types that are assignable to Id:
	//	*OperationFilter_ExactId
	//	*OperationFilter_AnyId
	Id isOperationFilter_Id `protobuf_oneof:"id"`
	// Operation group filer
	//
	// Types that are assignable to Group:
	//	*OperationFilter_ExactGroup
	//	*OperationFilter_AnyGroup
	Group isOperationFilter_Group `protobuf_oneof:"group"`
	// Operation state filter; all operations if empty
	State []OperationState `protobuf:"varint,7,rep,packed,name=state,proto3,enum=tinkoff.cloud.longrunning.v1.OperationState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

OperationFilter message can be used to filter the long list of operations in the methods which support it.

func (*OperationFilter) Descriptor deprecated 

func (*OperationFilter) Descriptor() ([]byte, []int)

Deprecated: Use OperationFilter.ProtoReflect.Descriptor instead.

func (*OperationFilter) GetAnyGroup 

func (x *OperationFilter) GetAnyGroup() *emptypb.Empty

func (*OperationFilter) GetAnyId 

func (x *OperationFilter) GetAnyId() *emptypb.Empty

func (*OperationFilter) GetAnyServiceId 

func (x *OperationFilter) GetAnyServiceId() *emptypb.Empty

func (*OperationFilter) GetExactGroup 

func (x *OperationFilter) GetExactGroup() string

func (*OperationFilter) GetExactId 

func (x *OperationFilter) GetExactId() string

func (*OperationFilter) GetExactServiceId 

func (x *OperationFilter) GetExactServiceId() string

func (*OperationFilter) GetGroup 

func (m *OperationFilter) GetGroup() isOperationFilter_Group

func (*OperationFilter) GetId 

func (m *OperationFilter) GetId() isOperationFilter_Id

func (*OperationFilter) GetServiceId 

func (m *OperationFilter) GetServiceId() isOperationFilter_ServiceId

func (*OperationFilter) GetState 

func (x *OperationFilter) GetState() []OperationState

func (*OperationFilter) ProtoMessage 

func (*OperationFilter) ProtoMessage()

func (*OperationFilter) ProtoReflect 

func (x *OperationFilter) ProtoReflect() protoreflect.Message

func (*OperationFilter) Reset 

func (x *OperationFilter) Reset()

func (*OperationFilter) String 

func (x *OperationFilter) String() string

type OperationFilter_AnyGroup 

type OperationFilter_AnyGroup struct {
	// For any value
	AnyGroup *emptypb.Empty `protobuf:"bytes,6,opt,name=any_group,json=anyGroup,proto3,oneof"`
}

type OperationFilter_AnyId 

type OperationFilter_AnyId struct {
	// For any value
	AnyId *emptypb.Empty `protobuf:"bytes,4,opt,name=any_id,json=anyId,proto3,oneof"`
}

type OperationFilter_AnyServiceId 

type OperationFilter_AnyServiceId struct {
	// Set this field to get results with any service id.
	AnyServiceId *emptypb.Empty `protobuf:"bytes,2,opt,name=any_service_id,json=anyServiceId,proto3,oneof"`
}

type OperationFilter_ExactGroup 

type OperationFilter_ExactGroup struct {
	// For single specific value
	ExactGroup string `protobuf:"bytes,5,opt,name=exact_group,json=exactGroup,proto3,oneof"`
}

type OperationFilter_ExactId 

type OperationFilter_ExactId struct {
	// For single specific value
	ExactId string `protobuf:"bytes,3,opt,name=exact_id,json=exactId,proto3,oneof"`
}

type OperationFilter_ExactServiceId 

type OperationFilter_ExactServiceId struct {
	// Set this field to get only those results which have service id equal to the string specified.
	ExactServiceId string `protobuf:"bytes,1,opt,name=exact_service_id,json=exactServiceId,proto3,oneof"`
}

type OperationState 

type OperationState int32
const (
	// Operation enqueued by service
	OperationState_ENQUEUED OperationState = 0
	// Processing started
	OperationState_PROCESSING OperationState = 1
	// Operation finished successfully
	OperationState_DONE OperationState = 2
	// Operation finished with error
	OperationState_FAILED OperationState = 3
)

func (OperationState) Descriptor 

func (OperationState) Descriptor() protoreflect.EnumDescriptor

func (OperationState) Enum 

func (x OperationState) Enum() *OperationState

func (OperationState) EnumDescriptor deprecated 

func (OperationState) EnumDescriptor() ([]byte, []int)

Deprecated: Use OperationState.Descriptor instead.

func (OperationState) Number 

func (x OperationState) Number() protoreflect.EnumNumber

func (OperationState) String 

func (x OperationState) String() string

func (OperationState) Type 

func (OperationState) Type() protoreflect.EnumType

type Operation_Error 

type Operation_Error struct {
	// Operation status if any error occurred
	Error *status.Status `protobuf:"bytes,5,opt,name=error,proto3,oneof"`
}

type Operation_Response 

type Operation_Response struct {
	// Operation response if the operation successfully finished
	Response *anypb.Any `protobuf:"bytes,6,opt,name=response,proto3,oneof"`
}

type OperationsClient 

type OperationsClient interface {
	// Starts polling for operation statuses
	// Returns operation status
	GetOperation(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*Operation, error)
	// Wait for operation update
	WaitOperation(ctx context.Context, in *WaitOperationRequest, opts ...grpc.CallOption) (*Operation, error)
	// List operations
	ListOperations(ctx context.Context, in *ListOperationsRequest, opts ...grpc.CallOption) (*ListOperationsResponse, error)
	// Watch operations
	WatchOperations(ctx context.Context, in *WatchOperationsRequest, opts ...grpc.CallOption) (Operations_WatchOperationsClient, error)
	// Deletes specified operations
	DeleteOperation(ctx context.Context, in *DeleteOperationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Cancels specified operations
	CancelOperation(ctx context.Context, in *CancelOperationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

OperationsClient is the client API for Operations service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOperationsClient 

func NewOperationsClient(cc grpc.ClientConnInterface) OperationsClient

type OperationsInitialState 

type OperationsInitialState struct {

	// Operations
	Operations []*Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationsInitialState) Descriptor deprecated 

func (*OperationsInitialState) Descriptor() ([]byte, []int)

Deprecated: Use OperationsInitialState.ProtoReflect.Descriptor instead.

func (*OperationsInitialState) GetOperations 

func (x *OperationsInitialState) GetOperations() []*Operation

func (*OperationsInitialState) ProtoMessage 

func (*OperationsInitialState) ProtoMessage()

func (*OperationsInitialState) ProtoReflect 

func (x *OperationsInitialState) ProtoReflect() protoreflect.Message

func (*OperationsInitialState) Reset 

func (x *OperationsInitialState) Reset()

func (*OperationsInitialState) String 

func (x *OperationsInitialState) String() string

type OperationsServer 

type OperationsServer interface {
	// Starts polling for operation statuses
	// Returns operation status
	GetOperation(context.Context, *GetOperationRequest) (*Operation, error)
	// Wait for operation update
	WaitOperation(context.Context, *WaitOperationRequest) (*Operation, error)
	// List operations
	ListOperations(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error)
	// Watch operations
	WatchOperations(*WatchOperationsRequest, Operations_WatchOperationsServer) error
	// Deletes specified operations
	DeleteOperation(context.Context, *DeleteOperationRequest) (*emptypb.Empty, error)
	// Cancels specified operations
	CancelOperation(context.Context, *CancelOperationRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

OperationsServer is the server API for Operations service. All implementations must embed UnimplementedOperationsServer for forward compatibility

type OperationsUpdate 

type OperationsUpdate struct {

	// Operations
	Operations []*Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationsUpdate) Descriptor deprecated 

func (*OperationsUpdate) Descriptor() ([]byte, []int)

Deprecated: Use OperationsUpdate.ProtoReflect.Descriptor instead.

func (*OperationsUpdate) GetOperations 

func (x *OperationsUpdate) GetOperations() []*Operation

func (*OperationsUpdate) ProtoMessage 

func (*OperationsUpdate) ProtoMessage()

func (*OperationsUpdate) ProtoReflect 

func (x *OperationsUpdate) ProtoReflect() protoreflect.Message

func (*OperationsUpdate) Reset 

func (x *OperationsUpdate) Reset()

func (*OperationsUpdate) String 

func (x *OperationsUpdate) String() string

type Operations_WatchOperationsClient 

type Operations_WatchOperationsClient interface {
	Recv() (*WatchOperationsResponse, error)
	grpc.ClientStream
}

type Operations_WatchOperationsServer 

type Operations_WatchOperationsServer interface {
	Send(*WatchOperationsResponse) error
	grpc.ServerStream
}

type UnimplementedOperationsServer 

type UnimplementedOperationsServer struct {
}

UnimplementedOperationsServer must be embedded to have forward compatible implementations.

func (UnimplementedOperationsServer) CancelOperation 

func (UnimplementedOperationsServer) CancelOperation(context.Context, *CancelOperationRequest) (*emptypb.Empty, error)

func (UnimplementedOperationsServer) DeleteOperation 

func (UnimplementedOperationsServer) DeleteOperation(context.Context, *DeleteOperationRequest) (*emptypb.Empty, error)

func (UnimplementedOperationsServer) GetOperation 

func (UnimplementedOperationsServer) GetOperation(context.Context, *GetOperationRequest) (*Operation, error)

func (UnimplementedOperationsServer) ListOperations 

func (UnimplementedOperationsServer) ListOperations(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error)

func (UnimplementedOperationsServer) WaitOperation 

func (UnimplementedOperationsServer) WaitOperation(context.Context, *WaitOperationRequest) (*Operation, error)

func (UnimplementedOperationsServer) WatchOperations 

func (UnimplementedOperationsServer) WatchOperations(*WatchOperationsRequest, Operations_WatchOperationsServer) error

type UnsafeOperationsServer 

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

UnsafeOperationsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OperationsServer will result in compilation errors.

type WaitOperationRequest 

type WaitOperationRequest struct {

	// Operation ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,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.
	Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitOperationRequest) Descriptor deprecated 

func (*WaitOperationRequest) Descriptor() ([]byte, []int)

Deprecated: Use WaitOperationRequest.ProtoReflect.Descriptor instead.

func (*WaitOperationRequest) GetId 

func (x *WaitOperationRequest) GetId() string

func (*WaitOperationRequest) GetTimeout 

func (x *WaitOperationRequest) GetTimeout() *durationpb.Duration

func (*WaitOperationRequest) ProtoMessage 

func (*WaitOperationRequest) ProtoMessage()

func (*WaitOperationRequest) ProtoReflect 

func (x *WaitOperationRequest) ProtoReflect() protoreflect.Message

func (*WaitOperationRequest) Reset 

func (x *WaitOperationRequest) Reset()

func (*WaitOperationRequest) String 

func (x *WaitOperationRequest) String() string

type WatchOperationsRequest 

type WatchOperationsRequest struct {

	// Operation filter
	Filter *OperationFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// Flag to enable keeping gRPC stream and listening for updates
	ListenForUpdates bool `protobuf:"varint,2,opt,name=listen_for_updates,json=listenForUpdates,proto3" json:"listen_for_updates,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchOperationsRequest) Descriptor deprecated 

func (*WatchOperationsRequest) Descriptor() ([]byte, []int)

Deprecated: Use WatchOperationsRequest.ProtoReflect.Descriptor instead.

func (*WatchOperationsRequest) GetFilter 

func (x *WatchOperationsRequest) GetFilter() *OperationFilter

func (*WatchOperationsRequest) GetListenForUpdates 

func (x *WatchOperationsRequest) GetListenForUpdates() bool

func (*WatchOperationsRequest) ProtoMessage 

func (*WatchOperationsRequest) ProtoMessage()

func (*WatchOperationsRequest) ProtoReflect 

func (x *WatchOperationsRequest) ProtoReflect() protoreflect.Message

func (*WatchOperationsRequest) Reset 

func (x *WatchOperationsRequest) Reset()

func (*WatchOperationsRequest) String 

func (x *WatchOperationsRequest) String() string

type WatchOperationsResponse 

type WatchOperationsResponse struct {

	// Types that are assignable to Operations:
	//	*WatchOperationsResponse_InitialState
	//	*WatchOperationsResponse_InitFinished
	//	*WatchOperationsResponse_Update
	Operations isWatchOperationsResponse_Operations `protobuf_oneof:"operations"`
	// contains filtered or unexported fields
}

func (*WatchOperationsResponse) Descriptor deprecated 

func (*WatchOperationsResponse) Descriptor() ([]byte, []int)

Deprecated: Use WatchOperationsResponse.ProtoReflect.Descriptor instead.

func (*WatchOperationsResponse) GetInitFinished 

func (x *WatchOperationsResponse) GetInitFinished() *emptypb.Empty

func (*WatchOperationsResponse) GetInitialState 

func (x *WatchOperationsResponse) GetInitialState() *OperationsInitialState

func (*WatchOperationsResponse) GetOperations 

func (m *WatchOperationsResponse) GetOperations() isWatchOperationsResponse_Operations

func (*WatchOperationsResponse) GetUpdate 

func (x *WatchOperationsResponse) GetUpdate() *OperationsUpdate

func (*WatchOperationsResponse) ProtoMessage 

func (*WatchOperationsResponse) ProtoMessage()

func (*WatchOperationsResponse) ProtoReflect 

func (x *WatchOperationsResponse) ProtoReflect() protoreflect.Message

func (*WatchOperationsResponse) Reset 

func (x *WatchOperationsResponse) Reset()

func (*WatchOperationsResponse) String 

func (x *WatchOperationsResponse) String() string

type WatchOperationsResponse_InitFinished 

type WatchOperationsResponse_InitFinished struct {
	// Init finished
	InitFinished *emptypb.Empty `protobuf:"bytes,2,opt,name=init_finished,json=initFinished,proto3,oneof"`
}

type WatchOperationsResponse_InitialState 

type WatchOperationsResponse_InitialState struct {
	// Initial state
	InitialState *OperationsInitialState `protobuf:"bytes,1,opt,name=initial_state,json=initialState,proto3,oneof"`
}

type WatchOperationsResponse_Update 

type WatchOperationsResponse_Update struct {
	// Update
	Update *OperationsUpdate `protobuf:"bytes,3,opt,name=update,proto3,oneof"`
}

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.