protos

type AbandonActivityWorkItemRequest struct {

	// The completion token that was provided when the work item was fetched.
	CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// contains filtered or unexported fields
}

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

type AbandonOrchestrationWorkItemRequest struct {

	// The completion token that was provided when the work item was fetched.
	CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// contains filtered or unexported fields
}

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

type ActivityRequest struct {
	Name                  string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version               *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input                 *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	OrchestrationInstance *OrchestrationInstance  `protobuf:"bytes,4,opt,name=orchestrationInstance,proto3" json:"orchestrationInstance,omitempty"`
	TaskId                int32                   `protobuf:"varint,5,opt,name=taskId,proto3" json:"taskId,omitempty"`
	ParentTraceContext    *TraceContext           `protobuf:"bytes,6,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	// contains filtered or unexported fields
}

type ActivityResponse struct {
	InstanceId     string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	TaskId         int32                   `protobuf:"varint,2,opt,name=taskId,proto3" json:"taskId,omitempty"`
	Result         *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	FailureDetails *TaskFailureDetails     `protobuf:"bytes,4,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

type AddEventRequest struct {

	// The ID of the orchestration to send an event to.
	Instance *OrchestrationInstance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	// The event to send to the orchestration.
	Event *HistoryEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

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

type BackendServiceClient interface {
	// Creates a new orchestration instance.
	CreateInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	// Sends an event to an orchestration instance. This RPC is used for raising external events to orchestrations
	// and for sending orchestration lifecycle events, such as terminate, suspend, resume, etc.
	AddEvent(ctx context.Context, in *AddEventRequest, opts ...grpc.CallOption) (*AddEventResponse, error)
	// Returns metadata about an orchestration instance.
	GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Returns metadata about multiple orchestration instances using a query.
	QueryInstances(ctx context.Context, in *QueryInstancesRequest, opts ...grpc.CallOption) (*QueryInstancesResponse, error)
	// Waits for an orchestration to reach a terminal state and then returns metadata for that orchestration.
	WaitForInstance(ctx context.Context, in *WaitForInstanceRequest, opts ...grpc.CallOption) (*WaitForInstanceResponse, error)
	// Purges the state of one or more orchestration instances.
	PurgeInstances(ctx context.Context, in *PurgeInstancesRequest, opts ...grpc.CallOption) (*PurgeInstancesResponse, error)
	// Starts a server stream for receiving work items
	GetWorkItems(ctx context.Context, in *GetWorkItemsRequest, opts ...grpc.CallOption) (BackendService_GetWorkItemsClient, error)
	// Gets orchestration runtime state (history, etc.) for a given orchestration instance.
	GetOrchestrationRuntimeState(ctx context.Context, in *GetOrchestrationRuntimeStateRequest, opts ...grpc.CallOption) (*GetOrchestrationRuntimeStateResponse, error)
	// Completes an outstanding activity work item and adds a new event to the target orchestration's inbox.
	CompleteActivityWorkItem(ctx context.Context, in *CompleteActivityWorkItemRequest, opts ...grpc.CallOption) (*CompleteActivityWorkItemResponse, error)
	// Abandons an outstanding activity work item. Abandoned work items will be delivered again after some delay.
	AbandonActivityWorkItem(ctx context.Context, in *AbandonActivityWorkItemRequest, opts ...grpc.CallOption) (*AbandonActivityWorkItemResponse, error)
	// Completes an outstanding orchestrator work item, and adds a new event to the target orchestration's inbox.
	CompleteOrchestrationWorkItem(ctx context.Context, in *CompleteOrchestrationWorkItemRequest, opts ...grpc.CallOption) (*CompleteOrchestrationWorkItemResponse, error)
	// Abandons an outstanding orchestrator work item. Abandoned work items will be delivered again after some delay.
	AbandonOrchestrationWorkItem(ctx context.Context, in *AbandonOrchestrationWorkItemRequest, opts ...grpc.CallOption) (*AbandonOrchestrationWorkItemResponse, error)
	// Sends a health check ping to the backend service.
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

type BackendServiceServer interface {
	// Creates a new orchestration instance.
	CreateInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	// Sends an event to an orchestration instance. This RPC is used for raising external events to orchestrations
	// and for sending orchestration lifecycle events, such as terminate, suspend, resume, etc.
	AddEvent(context.Context, *AddEventRequest) (*AddEventResponse, error)
	// Returns metadata about an orchestration instance.
	GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Returns metadata about multiple orchestration instances using a query.
	QueryInstances(context.Context, *QueryInstancesRequest) (*QueryInstancesResponse, error)
	// Waits for an orchestration to reach a terminal state and then returns metadata for that orchestration.
	WaitForInstance(context.Context, *WaitForInstanceRequest) (*WaitForInstanceResponse, error)
	// Purges the state of one or more orchestration instances.
	PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)
	// Starts a server stream for receiving work items
	GetWorkItems(*GetWorkItemsRequest, BackendService_GetWorkItemsServer) error
	// Gets orchestration runtime state (history, etc.) for a given orchestration instance.
	GetOrchestrationRuntimeState(context.Context, *GetOrchestrationRuntimeStateRequest) (*GetOrchestrationRuntimeStateResponse, error)
	// Completes an outstanding activity work item and adds a new event to the target orchestration's inbox.
	CompleteActivityWorkItem(context.Context, *CompleteActivityWorkItemRequest) (*CompleteActivityWorkItemResponse, error)
	// Abandons an outstanding activity work item. Abandoned work items will be delivered again after some delay.
	AbandonActivityWorkItem(context.Context, *AbandonActivityWorkItemRequest) (*AbandonActivityWorkItemResponse, error)
	// Completes an outstanding orchestrator work item, and adds a new event to the target orchestration's inbox.
	CompleteOrchestrationWorkItem(context.Context, *CompleteOrchestrationWorkItemRequest) (*CompleteOrchestrationWorkItemResponse, error)
	// Abandons an outstanding orchestrator work item. Abandoned work items will be delivered again after some delay.
	AbandonOrchestrationWorkItem(context.Context, *AbandonOrchestrationWorkItemRequest) (*AbandonOrchestrationWorkItemResponse, error)
	// Sends a health check ping to the backend service.
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// contains filtered or unexported methods
}

type BackendService_GetWorkItemsClient interface {
	Recv() (*WorkItem, error)
	grpc.ClientStream
}

type BackendService_GetWorkItemsServer interface {
	Send(*WorkItem) error
	grpc.ServerStream
}

type CleanEntityStorageRequest struct {
	ContinuationToken    *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	RemoveEmptyEntities  bool                    `protobuf:"varint,2,opt,name=removeEmptyEntities,proto3" json:"removeEmptyEntities,omitempty"`
	ReleaseOrphanedLocks bool                    `protobuf:"varint,3,opt,name=releaseOrphanedLocks,proto3" json:"releaseOrphanedLocks,omitempty"`
	// contains filtered or unexported fields
}

type CleanEntityStorageResponse struct {
	ContinuationToken     *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	EmptyEntitiesRemoved  int32                   `protobuf:"varint,2,opt,name=emptyEntitiesRemoved,proto3" json:"emptyEntitiesRemoved,omitempty"`
	OrphanedLocksReleased int32                   `protobuf:"varint,3,opt,name=orphanedLocksReleased,proto3" json:"orphanedLocksReleased,omitempty"`
	// contains filtered or unexported fields
}

type CompleteActivityWorkItemRequest struct {

	// The completion token that was provided when the work item was fetched.
	CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// The response event that will be sent to the orchestrator.
	// This must be either a TaskCompleted event or a TaskFailed event.
	ResponseEvent *HistoryEvent `protobuf:"bytes,2,opt,name=responseEvent,proto3" json:"responseEvent,omitempty"`
	// contains filtered or unexported fields
}

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

type CompleteOrchestrationAction struct {
	OrchestrationStatus OrchestrationStatus     `protobuf:"varint,1,opt,name=orchestrationStatus,proto3,enum=OrchestrationStatus" json:"orchestrationStatus,omitempty"`
	Result              *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Details             *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	NewVersion          *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=newVersion,proto3" json:"newVersion,omitempty"`
	CarryoverEvents     []*HistoryEvent         `protobuf:"bytes,5,rep,name=carryoverEvents,proto3" json:"carryoverEvents,omitempty"`
	FailureDetails      *TaskFailureDetails     `protobuf:"bytes,6,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

type CompleteOrchestrationWorkItemRequest struct {

	// The completion token that was provided when the work item was fetched.
	CompletionToken string                  `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	NewExecutionId  *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=newExecutionId,proto3" json:"newExecutionId,omitempty"`
	RuntimeStatus   OrchestrationStatus     `protobuf:"varint,3,opt,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
	CustomStatus    *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	NewHistory      []*HistoryEvent         `protobuf:"bytes,5,rep,name=newHistory,proto3" json:"newHistory,omitempty"`
	NewTasks        []*HistoryEvent         `protobuf:"bytes,6,rep,name=newTasks,proto3" json:"newTasks,omitempty"`
	NewTimers       []*HistoryEvent         `protobuf:"bytes,7,rep,name=newTimers,proto3" json:"newTimers,omitempty"`
	NewMessages     []*OrchestratorMessage  `protobuf:"bytes,8,rep,name=newMessages,proto3" json:"newMessages,omitempty"`
	// contains filtered or unexported fields
}

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

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

type ContinueAsNewEvent struct {
	Input *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

type CreateInstanceRequest struct {
	InstanceId                 string                      `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name                       string                      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version                    *wrapperspb.StringValue     `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input                      *wrapperspb.StringValue     `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledStartTimestamp    *timestamppb.Timestamp      `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	OrchestrationIdReusePolicy *OrchestrationIdReusePolicy `protobuf:"bytes,6,opt,name=orchestrationIdReusePolicy,proto3" json:"orchestrationIdReusePolicy,omitempty"`
	ExecutionId                *wrapperspb.StringValue     `protobuf:"bytes,7,opt,name=executionId,proto3" json:"executionId,omitempty"`
	Tags                       map[string]string           `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CreateInstanceResponse struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// contains filtered or unexported fields
}

type CreateOrchestrationAction int32

type CreateSubOrchestrationAction struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name       string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input      *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

type CreateTaskHubRequest struct {
	RecreateIfExists bool `protobuf:"varint,1,opt,name=recreateIfExists,proto3" json:"recreateIfExists,omitempty"`
	// contains filtered or unexported fields
}

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

type CreateTimerAction struct {
	FireAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=fireAt,proto3" json:"fireAt,omitempty"`
	// contains filtered or unexported fields
}

type CreateWorkflowInstanceRequest struct {
	StartEvent *HistoryEvent               `protobuf:"bytes,1,opt,name=startEvent,proto3" json:"startEvent,omitempty"`
	Policy     *OrchestrationIdReusePolicy `protobuf:"bytes,2,opt,name=policy,proto3,oneof" json:"policy,omitempty"`
	// contains filtered or unexported fields
}

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

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

type DurableTimer struct {
	TimerEvent *HistoryEvent `protobuf:"bytes,1,opt,name=timerEvent,proto3" json:"timerEvent,omitempty"`
	Generation uint64        `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

type EntityBatchRequest struct {
	InstanceId  string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	EntityState *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=entityState,proto3" json:"entityState,omitempty"`
	Operations  []*OperationRequest     `protobuf:"bytes,3,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

type EntityBatchResult struct {
	Results        []*OperationResult      `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	Actions        []*OperationAction      `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	EntityState    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=entityState,proto3" json:"entityState,omitempty"`
	FailureDetails *TaskFailureDetails     `protobuf:"bytes,4,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

type EntityMetadata struct {
	InstanceId       string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	LastModifiedTime *timestamppb.Timestamp  `protobuf:"bytes,2,opt,name=lastModifiedTime,proto3" json:"lastModifiedTime,omitempty"`
	BacklogQueueSize int32                   `protobuf:"varint,3,opt,name=backlogQueueSize,proto3" json:"backlogQueueSize,omitempty"`
	LockedBy         *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=lockedBy,proto3" json:"lockedBy,omitempty"`
	SerializedState  *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=serializedState,proto3" json:"serializedState,omitempty"`
	// contains filtered or unexported fields
}

type EntityQuery struct {
	InstanceIdStartsWith *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=instanceIdStartsWith,proto3" json:"instanceIdStartsWith,omitempty"`
	LastModifiedFrom     *timestamppb.Timestamp  `protobuf:"bytes,2,opt,name=lastModifiedFrom,proto3" json:"lastModifiedFrom,omitempty"`
	LastModifiedTo       *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=lastModifiedTo,proto3" json:"lastModifiedTo,omitempty"`
	IncludeState         bool                    `protobuf:"varint,4,opt,name=includeState,proto3" json:"includeState,omitempty"`
	IncludeTransient     bool                    `protobuf:"varint,5,opt,name=includeTransient,proto3" json:"includeTransient,omitempty"`
	PageSize             *wrapperspb.Int32Value  `protobuf:"bytes,6,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	ContinuationToken    *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	// contains filtered or unexported fields
}

type EventRaisedEvent struct {
	Name  string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Input *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

type EventSentEvent struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name       string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Input      *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

type ExecutionCompletedEvent struct {
	OrchestrationStatus OrchestrationStatus     `protobuf:"varint,1,opt,name=orchestrationStatus,proto3,enum=OrchestrationStatus" json:"orchestrationStatus,omitempty"`
	Result              *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	FailureDetails      *TaskFailureDetails     `protobuf:"bytes,3,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

type ExecutionResumedEvent struct {
	Input *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

type ExecutionStartedEvent struct {
	Name                    string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version                 *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input                   *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	OrchestrationInstance   *OrchestrationInstance  `protobuf:"bytes,4,opt,name=orchestrationInstance,proto3" json:"orchestrationInstance,omitempty"`
	ParentInstance          *ParentInstanceInfo     `protobuf:"bytes,5,opt,name=parentInstance,proto3" json:"parentInstance,omitempty"`
	ScheduledStartTimestamp *timestamppb.Timestamp  `protobuf:"bytes,6,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	ParentTraceContext      *TraceContext           `protobuf:"bytes,7,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	OrchestrationSpanID     *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=orchestrationSpanID,proto3" json:"orchestrationSpanID,omitempty"`
	// contains filtered or unexported fields
}

type ExecutionSuspendedEvent struct {
	Input *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

type ExecutionTerminatedEvent struct {
	Input   *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	Recurse bool                    `protobuf:"varint,2,opt,name=recurse,proto3" json:"recurse,omitempty"`
	// contains filtered or unexported fields
}

type GenericEvent struct {
	Data *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type GetEntityRequest struct {
	InstanceId   string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	IncludeState bool   `protobuf:"varint,2,opt,name=includeState,proto3" json:"includeState,omitempty"`
	// contains filtered or unexported fields
}

type GetEntityResponse struct {
	Exists bool            `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	Entity *EntityMetadata `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

type GetInstanceRequest struct {
	InstanceId          string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	GetInputsAndOutputs bool   `protobuf:"varint,2,opt,name=getInputsAndOutputs,proto3" json:"getInputsAndOutputs,omitempty"`
	// contains filtered or unexported fields
}

type GetInstanceResponse struct {
	Exists             bool                `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	OrchestrationState *OrchestrationState `protobuf:"bytes,2,opt,name=orchestrationState,proto3" json:"orchestrationState,omitempty"`
	// contains filtered or unexported fields
}

type GetOrchestrationRuntimeStateRequest struct {

	// The ID of the target orchestration instance.
	Instance *OrchestrationInstance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

type GetOrchestrationRuntimeStateResponse struct {

	// The existing history events for the target orchestration instance.
	History []*HistoryEvent `protobuf:"bytes,1,rep,name=history,proto3" json:"history,omitempty"`
	// contains filtered or unexported fields
}

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

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

type HistoryEvent struct {
	EventId   int32                  `protobuf:"varint,1,opt,name=eventId,proto3" json:"eventId,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are assignable to EventType:
	//
	//	*HistoryEvent_ExecutionStarted
	//	*HistoryEvent_ExecutionCompleted
	//	*HistoryEvent_ExecutionTerminated
	//	*HistoryEvent_TaskScheduled
	//	*HistoryEvent_TaskCompleted
	//	*HistoryEvent_TaskFailed
	//	*HistoryEvent_SubOrchestrationInstanceCreated
	//	*HistoryEvent_SubOrchestrationInstanceCompleted
	//	*HistoryEvent_SubOrchestrationInstanceFailed
	//	*HistoryEvent_TimerCreated
	//	*HistoryEvent_TimerFired
	//	*HistoryEvent_OrchestratorStarted
	//	*HistoryEvent_OrchestratorCompleted
	//	*HistoryEvent_EventSent
	//	*HistoryEvent_EventRaised
	//	*HistoryEvent_GenericEvent
	//	*HistoryEvent_HistoryState
	//	*HistoryEvent_ContinueAsNew
	//	*HistoryEvent_ExecutionSuspended
	//	*HistoryEvent_ExecutionResumed
	EventType isHistoryEvent_EventType `protobuf_oneof:"eventType"`
	// contains filtered or unexported fields
}

type HistoryEvent_ContinueAsNew struct {
	ContinueAsNew *ContinueAsNewEvent `protobuf:"bytes,20,opt,name=continueAsNew,proto3,oneof"`
}

type HistoryEvent_EventRaised struct {
	EventRaised *EventRaisedEvent `protobuf:"bytes,17,opt,name=eventRaised,proto3,oneof"`
}

type HistoryEvent_EventSent struct {
	EventSent *EventSentEvent `protobuf:"bytes,16,opt,name=eventSent,proto3,oneof"`
}

type HistoryEvent_ExecutionCompleted struct {
	ExecutionCompleted *ExecutionCompletedEvent `protobuf:"bytes,4,opt,name=executionCompleted,proto3,oneof"`
}

type HistoryEvent_ExecutionResumed struct {
	ExecutionResumed *ExecutionResumedEvent `protobuf:"bytes,22,opt,name=executionResumed,proto3,oneof"`
}

type HistoryEvent_ExecutionStarted struct {
	ExecutionStarted *ExecutionStartedEvent `protobuf:"bytes,3,opt,name=executionStarted,proto3,oneof"`
}

type HistoryEvent_ExecutionSuspended struct {
	ExecutionSuspended *ExecutionSuspendedEvent `protobuf:"bytes,21,opt,name=executionSuspended,proto3,oneof"`
}

type HistoryEvent_ExecutionTerminated struct {
	ExecutionTerminated *ExecutionTerminatedEvent `protobuf:"bytes,5,opt,name=executionTerminated,proto3,oneof"`
}

type HistoryEvent_GenericEvent struct {
	GenericEvent *GenericEvent `protobuf:"bytes,18,opt,name=genericEvent,proto3,oneof"`
}

type HistoryEvent_HistoryState struct {
	HistoryState *HistoryStateEvent `protobuf:"bytes,19,opt,name=historyState,proto3,oneof"`
}

type HistoryEvent_OrchestratorCompleted struct {
	OrchestratorCompleted *OrchestratorCompletedEvent `protobuf:"bytes,15,opt,name=orchestratorCompleted,proto3,oneof"`
}

type HistoryEvent_OrchestratorStarted struct {
	OrchestratorStarted *OrchestratorStartedEvent `protobuf:"bytes,14,opt,name=orchestratorStarted,proto3,oneof"`
}

type HistoryEvent_SubOrchestrationInstanceCompleted struct {
	SubOrchestrationInstanceCompleted *SubOrchestrationInstanceCompletedEvent `protobuf:"bytes,10,opt,name=subOrchestrationInstanceCompleted,proto3,oneof"`
}

type HistoryEvent_SubOrchestrationInstanceCreated struct {
	SubOrchestrationInstanceCreated *SubOrchestrationInstanceCreatedEvent `protobuf:"bytes,9,opt,name=subOrchestrationInstanceCreated,proto3,oneof"`
}

type HistoryEvent_SubOrchestrationInstanceFailed struct {
	SubOrchestrationInstanceFailed *SubOrchestrationInstanceFailedEvent `protobuf:"bytes,11,opt,name=subOrchestrationInstanceFailed,proto3,oneof"`
}

type HistoryEvent_TaskCompleted struct {
	TaskCompleted *TaskCompletedEvent `protobuf:"bytes,7,opt,name=taskCompleted,proto3,oneof"`
}

type HistoryEvent_TaskFailed struct {
	TaskFailed *TaskFailedEvent `protobuf:"bytes,8,opt,name=taskFailed,proto3,oneof"`
}

type HistoryEvent_TaskScheduled struct {
	TaskScheduled *TaskScheduledEvent `protobuf:"bytes,6,opt,name=taskScheduled,proto3,oneof"`
}

type HistoryEvent_TimerCreated struct {
	TimerCreated *TimerCreatedEvent `protobuf:"bytes,12,opt,name=timerCreated,proto3,oneof"`
}

type HistoryEvent_TimerFired struct {
	TimerFired *TimerFiredEvent `protobuf:"bytes,13,opt,name=timerFired,proto3,oneof"`
}

type HistoryStateEvent struct {
	OrchestrationState *OrchestrationState `protobuf:"bytes,1,opt,name=orchestrationState,proto3" json:"orchestrationState,omitempty"`
	// contains filtered or unexported fields
}