pb

type ComputeRequest struct {
	Request       *pb.CapabilityRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	RuntimeConfig *RuntimeConfig        `protobuf:"bytes,2,opt,name=runtimeConfig,proto3" json:"runtimeConfig,omitempty"`
	// contains filtered or unexported fields
}

type ComputeResponse struct {
	Response *pb.CapabilityResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

type EmitMessageRequest struct {
	Message   string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Labels    *pb1.Map `protobuf:"bytes,2,opt,name=labels,proto3" json:"labels,omitempty"`
	RequestId string   `protobuf:"bytes,3,opt,name=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

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

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

type FetchRequest struct {
	Url        string                `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Method     string                `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Headers    *pb1.Map              `protobuf:"bytes,3,opt,name=headers,proto3" json:"headers,omitempty"`
	Body       []byte                `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	TimeoutMs  uint32                `protobuf:"varint,5,opt,name=timeoutMs,proto3" json:"timeoutMs,omitempty"`
	Id         string                `protobuf:"bytes,6,opt,name=id,proto3" json:"id,omitempty"`
	Metadata   *FetchRequestMetadata `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
	MaxRetries uint32                `protobuf:"varint,8,opt,name=maxRetries,proto3" json:"maxRetries,omitempty"`
	// contains filtered or unexported fields
}

type FetchRequestMetadata struct {
	WorkflowId          string `protobuf:"bytes,1,opt,name=workflowId,proto3" json:"workflowId,omitempty"`
	WorkflowName        string `protobuf:"bytes,2,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	WorkflowOwner       string `protobuf:"bytes,3,opt,name=workflowOwner,proto3" json:"workflowOwner,omitempty"`
	WorkflowExecutionId string `protobuf:"bytes,4,opt,name=workflowExecutionId,proto3" json:"workflowExecutionId,omitempty"`
	DecodedWorkflowName string `protobuf:"bytes,5,opt,name=decodedWorkflowName,proto3" json:"decodedWorkflowName,omitempty"`
	// contains filtered or unexported fields
}

type FetchResponse struct {
	ExecutionError bool   `protobuf:"varint,1,opt,name=executionError,proto3" json:"executionError,omitempty"`
	ErrorMessage   string `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// NOTE: this is actually a uint8, but proto doesn't support this.
	StatusCode uint32   `protobuf:"varint,3,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Headers    *pb1.Map `protobuf:"bytes,4,opt,name=headers,proto3" json:"headers,omitempty"`
	Body       []byte   `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type Request struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Config []byte `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// Types that are valid to be assigned to Message:
	//
	//	*Request_ComputeRequest
	//	*Request_SpecRequest
	Message isRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type Request_ComputeRequest struct {
	ComputeRequest *ComputeRequest `protobuf:"bytes,3,opt,name=computeRequest,proto3,oneof"`
}

type Request_SpecRequest struct {
	SpecRequest *emptypb.Empty `protobuf:"bytes,4,opt,name=specRequest,proto3,oneof"`
}

type Response struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	// Types that are valid to be assigned to Message:
	//
	//	*Response_ComputeResponse
	//	*Response_SpecResponse
	Message isResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type Response_ComputeResponse struct {
	ComputeResponse *ComputeResponse `protobuf:"bytes,3,opt,name=computeResponse,proto3,oneof"`
}

type Response_SpecResponse struct {
	SpecResponse *WorkflowSpec `protobuf:"bytes,4,opt,name=specResponse,proto3,oneof"`
}

type RuntimeConfig struct {
	MaxResponseSizeBytes int64 `protobuf:"varint,1,opt,name=maxResponseSizeBytes,proto3" json:"maxResponseSizeBytes,omitempty"`
	// contains filtered or unexported fields
}

type StepDefinition struct {
	Id             string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Ref            string      `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	Inputs         *StepInputs `protobuf:"bytes,3,opt,name=inputs,proto3" json:"inputs,omitempty"`
	Config         *pb1.Map    `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	CapabilityType string      `protobuf:"bytes,5,opt,name=capabilityType,proto3" json:"capabilityType,omitempty"`
	// contains filtered or unexported fields
}

type StepInputs struct {
	OutputRef string   `protobuf:"bytes,1,opt,name=outputRef,proto3" json:"outputRef,omitempty"`
	Mapping   *pb1.Map `protobuf:"bytes,2,opt,name=mapping,proto3" json:"mapping,omitempty"`
	// contains filtered or unexported fields
}

type WorkflowSpec struct {
	Name      string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Owner     string            `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	Triggers  []*StepDefinition `protobuf:"bytes,3,rep,name=triggers,proto3" json:"triggers,omitempty"`
	Actions   []*StepDefinition `protobuf:"bytes,4,rep,name=actions,proto3" json:"actions,omitempty"`
	Consensus []*StepDefinition `protobuf:"bytes,5,rep,name=consensus,proto3" json:"consensus,omitempty"`
	Targets   []*StepDefinition `protobuf:"bytes,6,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}