protos

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"`
	// 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 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 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"`
	// 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 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 DeleteTaskHubRequest struct {
	// contains filtered or unexported fields
}

type DeleteTaskHubResponse struct {
	// 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 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"`
	CorrelationData         *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=correlationData,proto3" json:"correlationData,omitempty"`
	// contains filtered or unexported fields
}

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

type GenericEvent struct {
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,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 GetWorkItemsRequest 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
	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_ExecutionStarted struct {
	ExecutionStarted *ExecutionStartedEvent `protobuf:"bytes,3,opt,name=executionStarted,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
}

type InstanceQuery struct {
	RuntimeStatus         []OrchestrationStatus     `protobuf:"varint,1,rep,packed,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
	CreatedTimeFrom       *timestamppb.Timestamp    `protobuf:"bytes,2,opt,name=createdTimeFrom,proto3" json:"createdTimeFrom,omitempty"`
	CreatedTimeTo         *timestamppb.Timestamp    `protobuf:"bytes,3,opt,name=createdTimeTo,proto3" json:"createdTimeTo,omitempty"`
	TaskHubNames          []*wrapperspb.StringValue `protobuf:"bytes,4,rep,name=taskHubNames,proto3" json:"taskHubNames,omitempty"`
	MaxInstanceCount      int32                     `protobuf:"varint,5,opt,name=maxInstanceCount,proto3" json:"maxInstanceCount,omitempty"`
	ContinuationToken     *wrapperspb.StringValue   `protobuf:"bytes,6,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	InstanceIdPrefix      *wrapperspb.StringValue   `protobuf:"bytes,7,opt,name=instanceIdPrefix,proto3" json:"instanceIdPrefix,omitempty"`
	FetchInputsAndOutputs bool                      `protobuf:"varint,8,opt,name=fetchInputsAndOutputs,proto3" json:"fetchInputsAndOutputs,omitempty"`
	// contains filtered or unexported fields
}

type OrchestrationInstance struct {
	InstanceId  string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	// contains filtered or unexported fields
}

type OrchestrationState 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"`
	OrchestrationStatus     OrchestrationStatus     `protobuf:"varint,4,opt,name=orchestrationStatus,proto3,enum=OrchestrationStatus" json:"orchestrationStatus,omitempty"`
	ScheduledStartTimestamp *timestamppb.Timestamp  `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	CreatedTimestamp        *timestamppb.Timestamp  `protobuf:"bytes,6,opt,name=createdTimestamp,proto3" json:"createdTimestamp,omitempty"`
	LastUpdatedTimestamp    *timestamppb.Timestamp  `protobuf:"bytes,7,opt,name=lastUpdatedTimestamp,proto3" json:"lastUpdatedTimestamp,omitempty"`
	Input                   *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=input,proto3" json:"input,omitempty"`
	Output                  *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=output,proto3" json:"output,omitempty"`
	CustomStatus            *wrapperspb.StringValue `protobuf:"bytes,10,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	FailureDetails          *TaskFailureDetails     `protobuf:"bytes,11,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

type OrchestrationStatus int32

type OrchestratorAction struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to OrchestratorActionType:
	//	*OrchestratorAction_ScheduleTask
	//	*OrchestratorAction_CreateSubOrchestration
	//	*OrchestratorAction_CreateTimer
	//	*OrchestratorAction_SendEvent
	//	*OrchestratorAction_CompleteOrchestration
	OrchestratorActionType isOrchestratorAction_OrchestratorActionType `protobuf_oneof:"orchestratorActionType"`
	// contains filtered or unexported fields
}

type OrchestratorAction_CompleteOrchestration struct {
	CompleteOrchestration *CompleteOrchestrationAction `protobuf:"bytes,6,opt,name=completeOrchestration,proto3,oneof"`
}

type OrchestratorAction_CreateSubOrchestration struct {
	CreateSubOrchestration *CreateSubOrchestrationAction `protobuf:"bytes,3,opt,name=createSubOrchestration,proto3,oneof"`
}

type OrchestratorAction_CreateTimer struct {
	CreateTimer *CreateTimerAction `protobuf:"bytes,4,opt,name=createTimer,proto3,oneof"`
}

type OrchestratorAction_ScheduleTask struct {
	ScheduleTask *ScheduleTaskAction `protobuf:"bytes,2,opt,name=scheduleTask,proto3,oneof"`
}

type OrchestratorAction_SendEvent struct {
	SendEvent *SendEventAction `protobuf:"bytes,5,opt,name=sendEvent,proto3,oneof"`
}

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

type OrchestratorRequest struct {
	InstanceId  string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	PastEvents  []*HistoryEvent         `protobuf:"bytes,3,rep,name=pastEvents,proto3" json:"pastEvents,omitempty"`
	NewEvents   []*HistoryEvent         `protobuf:"bytes,4,rep,name=newEvents,proto3" json:"newEvents,omitempty"`
	// contains filtered or unexported fields
}

type OrchestratorResponse struct {
	InstanceId   string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Actions      []*OrchestratorAction   `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	CustomStatus *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	// contains filtered or unexported fields
}

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

type ParentInstanceInfo struct {
	TaskScheduledId       int32                   `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	Name                  *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version               *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	OrchestrationInstance *OrchestrationInstance  `protobuf:"bytes,4,opt,name=orchestrationInstance,proto3" json:"orchestrationInstance,omitempty"`
	// contains filtered or unexported fields
}

type PurgeInstanceFilter struct {
	CreatedTimeFrom *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=createdTimeFrom,proto3" json:"createdTimeFrom,omitempty"`
	CreatedTimeTo   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=createdTimeTo,proto3" json:"createdTimeTo,omitempty"`
	RuntimeStatus   []OrchestrationStatus  `protobuf:"varint,3,rep,packed,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
	// contains filtered or unexported fields
}

type PurgeInstancesRequest struct {

	// Types that are assignable to Request:
	//	*PurgeInstancesRequest_InstanceId
	//	*PurgeInstancesRequest_PurgeInstanceFilter
	Request isPurgeInstancesRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type PurgeInstancesRequest_InstanceId struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof"`
}

type PurgeInstancesRequest_PurgeInstanceFilter struct {
	PurgeInstanceFilter *PurgeInstanceFilter `protobuf:"bytes,2,opt,name=purgeInstanceFilter,proto3,oneof"`
}

type PurgeInstancesResponse struct {
	DeletedInstanceCount int32 `protobuf:"varint,1,opt,name=deletedInstanceCount,proto3" json:"deletedInstanceCount,omitempty"`
	// contains filtered or unexported fields
}

type QueryInstancesRequest struct {
	Query *InstanceQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

type QueryInstancesResponse struct {
	OrchestrationState []*OrchestrationState   `protobuf:"bytes,1,rep,name=orchestrationState,proto3" json:"orchestrationState,omitempty"`
	ContinuationToken  *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	// contains filtered or unexported fields
}

type RaiseEventRequest 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 RaiseEventResponse struct {
	// contains filtered or unexported fields
}

type ScheduleTaskAction 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"`
	// contains filtered or unexported fields
}

type SendEventAction struct {
	Instance *OrchestrationInstance  `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	Name     string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Data     *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type SubOrchestrationInstanceCompletedEvent struct {
	TaskScheduledId int32                   `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	Result          *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type SubOrchestrationInstanceCreatedEvent 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 SubOrchestrationInstanceFailedEvent struct {
	TaskScheduledId int32               `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	FailureDetails  *TaskFailureDetails `protobuf:"bytes,2,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

type TaskCompletedEvent struct {
	TaskScheduledId int32                   `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	Result          *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type TaskFailedEvent struct {
	TaskScheduledId int32               `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	FailureDetails  *TaskFailureDetails `protobuf:"bytes,2,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

type TaskFailureDetails struct {
	ErrorType      string                  `protobuf:"bytes,1,opt,name=errorType,proto3" json:"errorType,omitempty"`
	ErrorMessage   string                  `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	StackTrace     *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=stackTrace,proto3" json:"stackTrace,omitempty"`
	InnerFailure   *TaskFailureDetails     `protobuf:"bytes,4,opt,name=innerFailure,proto3" json:"innerFailure,omitempty"`
	IsNonRetriable bool                    `protobuf:"varint,5,opt,name=isNonRetriable,proto3" json:"isNonRetriable,omitempty"`
	// contains filtered or unexported fields
}

type TaskHubSidecarServiceClient interface {
	// Sends a hello request to the sidecar service.
	Hello(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Starts a new orchestration instance.
	StartInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	// Gets the status of an existing orchestration instance.
	GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Waits for an orchestration instance to reach a running or completion state.
	WaitForInstanceStart(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).
	WaitForInstanceCompletion(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Raises an event to a running orchestration instance.
	RaiseEvent(ctx context.Context, in *RaiseEventRequest, opts ...grpc.CallOption) (*RaiseEventResponse, error)
	// Terminates a running orchestration instance
	TerminateInstance(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
	// rpc DeleteInstance(DeleteInstanceRequest) returns (DeleteInstanceResponse);
	QueryInstances(ctx context.Context, in *QueryInstancesRequest, opts ...grpc.CallOption) (*QueryInstancesResponse, error)
	PurgeInstances(ctx context.Context, in *PurgeInstancesRequest, opts ...grpc.CallOption) (*PurgeInstancesResponse, error)
	GetWorkItems(ctx context.Context, in *GetWorkItemsRequest, opts ...grpc.CallOption) (TaskHubSidecarService_GetWorkItemsClient, error)
	CompleteActivityTask(ctx context.Context, in *ActivityResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	CompleteOrchestratorTask(ctx context.Context, in *OrchestratorResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	// Deletes and Creates the necessary resources for the orchestration service and the instance store
	CreateTaskHub(ctx context.Context, in *CreateTaskHubRequest, opts ...grpc.CallOption) (*CreateTaskHubResponse, error)
	// Deletes the resources for the orchestration service and optionally the instance store
	DeleteTaskHub(ctx context.Context, in *DeleteTaskHubRequest, opts ...grpc.CallOption) (*DeleteTaskHubResponse, error)
}

type TaskHubSidecarServiceServer interface {
	// Sends a hello request to the sidecar service.
	Hello(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// Starts a new orchestration instance.
	StartInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	// Gets the status of an existing orchestration instance.
	GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Waits for an orchestration instance to reach a running or completion state.
	WaitForInstanceStart(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).
	WaitForInstanceCompletion(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Raises an event to a running orchestration instance.
	RaiseEvent(context.Context, *RaiseEventRequest) (*RaiseEventResponse, error)
	// Terminates a running orchestration instance
	TerminateInstance(context.Context, *TerminateRequest) (*TerminateResponse, error)
	// rpc DeleteInstance(DeleteInstanceRequest) returns (DeleteInstanceResponse);
	QueryInstances(context.Context, *QueryInstancesRequest) (*QueryInstancesResponse, error)
	PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)
	GetWorkItems(*GetWorkItemsRequest, TaskHubSidecarService_GetWorkItemsServer) error
	CompleteActivityTask(context.Context, *ActivityResponse) (*CompleteTaskResponse, error)
	CompleteOrchestratorTask(context.Context, *OrchestratorResponse) (*CompleteTaskResponse, error)
	// Deletes and Creates the necessary resources for the orchestration service and the instance store
	CreateTaskHub(context.Context, *CreateTaskHubRequest) (*CreateTaskHubResponse, error)
	// Deletes the resources for the orchestration service and optionally the instance store
	DeleteTaskHub(context.Context, *DeleteTaskHubRequest) (*DeleteTaskHubResponse, error)
	// contains filtered or unexported methods
}

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

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

type TaskScheduledEvent 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"`
	// contains filtered or unexported fields
}

type TerminateRequest struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Output     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

type UnimplementedTaskHubSidecarServiceServer struct {
}

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

type WorkItem struct {

	// Types that are assignable to Request:
	//	*WorkItem_OrchestratorRequest
	//	*WorkItem_ActivityRequest
	Request isWorkItem_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type WorkItem_ActivityRequest struct {
	ActivityRequest *ActivityRequest `protobuf:"bytes,2,opt,name=activityRequest,proto3,oneof"`
}

type WorkItem_OrchestratorRequest struct {
	OrchestratorRequest *OrchestratorRequest `protobuf:"bytes,1,opt,name=orchestratorRequest,proto3,oneof"`
}