pb

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2024 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_workflows_wasm_pb_wasm_proto protoreflect.FileDescriptor

Functions

func ProtoToWorkflowSpec 

func ProtoToWorkflowSpec(spec *WorkflowSpec) (*sdk.WorkflowSpec, error)

Types

type ComputeRequest 

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
}

func (*ComputeRequest) Descriptor deprecated 

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

Deprecated: Use ComputeRequest.ProtoReflect.Descriptor instead.

func (*ComputeRequest) GetRequest 

func (x *ComputeRequest) GetRequest() *pb.CapabilityRequest

func (*ComputeRequest) GetRuntimeConfig 

func (x *ComputeRequest) GetRuntimeConfig() *RuntimeConfig

func (*ComputeRequest) ProtoMessage 

func (*ComputeRequest) ProtoMessage()

func (*ComputeRequest) ProtoReflect 

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

func (*ComputeRequest) Reset 

func (x *ComputeRequest) Reset()

func (*ComputeRequest) String 

func (x *ComputeRequest) String() string

type ComputeResponse 

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

func (*ComputeResponse) Descriptor deprecated 

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

Deprecated: Use ComputeResponse.ProtoReflect.Descriptor instead.

func (*ComputeResponse) GetResponse 

func (x *ComputeResponse) GetResponse() *pb.CapabilityResponse

func (*ComputeResponse) ProtoMessage 

func (*ComputeResponse) ProtoMessage()

func (*ComputeResponse) ProtoReflect 

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

func (*ComputeResponse) Reset 

func (x *ComputeResponse) Reset()

func (*ComputeResponse) String 

func (x *ComputeResponse) String() string

type EmitMessageRequest added in v0.1.1 

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

func (*EmitMessageRequest) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use EmitMessageRequest.ProtoReflect.Descriptor instead.

func (*EmitMessageRequest) GetLabels added in v0.1.1 

func (x *EmitMessageRequest) GetLabels() *pb1.Map

func (*EmitMessageRequest) GetMessage added in v0.1.1 

func (x *EmitMessageRequest) GetMessage() string

func (*EmitMessageRequest) ProtoMessage added in v0.1.1 

func (*EmitMessageRequest) ProtoMessage()

func (*EmitMessageRequest) ProtoReflect added in v0.1.1 

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

func (*EmitMessageRequest) Reset added in v0.1.1 

func (x *EmitMessageRequest) Reset()

func (*EmitMessageRequest) String added in v0.1.1 

func (x *EmitMessageRequest) String() string

type EmitMessageResponse added in v0.1.1 

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

func (*EmitMessageResponse) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use EmitMessageResponse.ProtoReflect.Descriptor instead.

func (*EmitMessageResponse) GetError added in v0.1.1 

func (x *EmitMessageResponse) GetError() *Error

func (*EmitMessageResponse) ProtoMessage added in v0.1.1 

func (*EmitMessageResponse) ProtoMessage()

func (*EmitMessageResponse) ProtoReflect added in v0.1.1 

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

func (*EmitMessageResponse) Reset added in v0.1.1 

func (x *EmitMessageResponse) Reset()

func (*EmitMessageResponse) String added in v0.1.1 

func (x *EmitMessageResponse) String() string

type Error added in v0.1.1 

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

func (*Error) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetMessage added in v0.1.1 

func (x *Error) GetMessage() string

func (*Error) ProtoMessage added in v0.1.1 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect added in v0.1.1 

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

func (*Error) Reset added in v0.1.1 

func (x *Error) Reset()

func (*Error) String added in v0.1.1 

func (x *Error) String() string

type FetchRequest 

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

func (*FetchRequest) Descriptor deprecated 

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

Deprecated: Use FetchRequest.ProtoReflect.Descriptor instead.

func (*FetchRequest) GetBody 

func (x *FetchRequest) GetBody() []byte

func (*FetchRequest) GetHeaders 

func (x *FetchRequest) GetHeaders() *pb1.Map

func (*FetchRequest) GetMethod 

func (x *FetchRequest) GetMethod() string

func (*FetchRequest) GetTimeoutMs 

func (x *FetchRequest) GetTimeoutMs() uint32

func (*FetchRequest) GetUrl 

func (x *FetchRequest) GetUrl() string

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) ProtoReflect 

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

func (*FetchRequest) Reset 

func (x *FetchRequest) Reset()

func (*FetchRequest) String 

func (x *FetchRequest) String() string

type FetchResponse 

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
}

func (*FetchResponse) Descriptor deprecated 

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

Deprecated: Use FetchResponse.ProtoReflect.Descriptor instead.

func (*FetchResponse) GetBody 

func (x *FetchResponse) GetBody() []byte

func (*FetchResponse) GetErrorMessage 

func (x *FetchResponse) GetErrorMessage() string

func (*FetchResponse) GetExecutionError added in v0.1.1 

func (x *FetchResponse) GetExecutionError() bool

func (*FetchResponse) GetHeaders 

func (x *FetchResponse) GetHeaders() *pb1.Map

func (*FetchResponse) GetStatusCode 

func (x *FetchResponse) GetStatusCode() uint32

func (*FetchResponse) ProtoMessage 

func (*FetchResponse) ProtoMessage()

func (*FetchResponse) ProtoReflect 

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

func (*FetchResponse) Reset 

func (x *FetchResponse) Reset()

func (*FetchResponse) String 

func (x *FetchResponse) String() string

type Request 

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 assignable to Message:
	//
	//	*Request_ComputeRequest
	//	*Request_SpecRequest
	Message isRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetComputeRequest 

func (x *Request) GetComputeRequest() *ComputeRequest

func (*Request) GetConfig 

func (x *Request) GetConfig() []byte

func (*Request) GetId 

func (x *Request) GetId() string

func (*Request) GetMessage 

func (m *Request) GetMessage() isRequest_Message

func (*Request) GetSpecRequest 

func (x *Request) GetSpecRequest() *emptypb.Empty

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Request_ComputeRequest 

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

type Request_SpecRequest 

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

type Response 

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 assignable to Message:
	//
	//	*Response_ComputeResponse
	//	*Response_SpecResponse
	Message isResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetComputeResponse 

func (x *Response) GetComputeResponse() *ComputeResponse

func (*Response) GetErrMsg 

func (x *Response) GetErrMsg() string

func (*Response) GetId 

func (x *Response) GetId() string

func (*Response) GetMessage 

func (m *Response) GetMessage() isResponse_Message

func (*Response) GetSpecResponse 

func (x *Response) GetSpecResponse() *WorkflowSpec

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Response_ComputeResponse 

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

type Response_SpecResponse 

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

type RuntimeConfig 

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

func (*RuntimeConfig) Descriptor deprecated 

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

Deprecated: Use RuntimeConfig.ProtoReflect.Descriptor instead.

func (*RuntimeConfig) GetMaxFetchResponseSizeBytes 

func (x *RuntimeConfig) GetMaxFetchResponseSizeBytes() int64

func (*RuntimeConfig) ProtoMessage 

func (*RuntimeConfig) ProtoMessage()

func (*RuntimeConfig) ProtoReflect 

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

func (*RuntimeConfig) Reset 

func (x *RuntimeConfig) Reset()

func (*RuntimeConfig) String 

func (x *RuntimeConfig) String() string

type StepDefinition 

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
}

func (*StepDefinition) Descriptor deprecated 

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

Deprecated: Use StepDefinition.ProtoReflect.Descriptor instead.

func (*StepDefinition) GetCapabilityType 

func (x *StepDefinition) GetCapabilityType() string

func (*StepDefinition) GetConfig 

func (x *StepDefinition) GetConfig() *pb1.Map

func (*StepDefinition) GetId 

func (x *StepDefinition) GetId() string

func (*StepDefinition) GetInputs 

func (x *StepDefinition) GetInputs() *StepInputs

func (*StepDefinition) GetRef 

func (x *StepDefinition) GetRef() string

func (*StepDefinition) ProtoMessage 

func (*StepDefinition) ProtoMessage()

func (*StepDefinition) ProtoReflect 

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

func (*StepDefinition) Reset 

func (x *StepDefinition) Reset()

func (*StepDefinition) String 

func (x *StepDefinition) String() string

type StepInputs 

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
}

func (*StepInputs) Descriptor deprecated 

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

Deprecated: Use StepInputs.ProtoReflect.Descriptor instead.

func (*StepInputs) GetMapping 

func (x *StepInputs) GetMapping() *pb1.Map

func (*StepInputs) GetOutputRef 

func (x *StepInputs) GetOutputRef() string

func (*StepInputs) ProtoMessage 

func (*StepInputs) ProtoMessage()

func (*StepInputs) ProtoReflect 

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

func (*StepInputs) Reset 

func (x *StepInputs) Reset()

func (*StepInputs) String 

func (x *StepInputs) String() string

type WorkflowSpec 

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
}

func WorkflowSpecToProto 

func WorkflowSpecToProto(spec *sdk.WorkflowSpec) (*WorkflowSpec, error)

func (*WorkflowSpec) Descriptor deprecated 

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

Deprecated: Use WorkflowSpec.ProtoReflect.Descriptor instead.

func (*WorkflowSpec) GetActions 

func (x *WorkflowSpec) GetActions() []*StepDefinition

func (*WorkflowSpec) GetConsensus 

func (x *WorkflowSpec) GetConsensus() []*StepDefinition

func (*WorkflowSpec) GetName 

func (x *WorkflowSpec) GetName() string

func (*WorkflowSpec) GetOwner 

func (x *WorkflowSpec) GetOwner() string

func (*WorkflowSpec) GetTargets 

func (x *WorkflowSpec) GetTargets() []*StepDefinition

func (*WorkflowSpec) GetTriggers 

func (x *WorkflowSpec) GetTriggers() []*StepDefinition

func (*WorkflowSpec) ProtoMessage 

func (*WorkflowSpec) ProtoMessage()

func (*WorkflowSpec) ProtoReflect 

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

func (*WorkflowSpec) Reset 

func (x *WorkflowSpec) Reset()

func (*WorkflowSpec) String 

func (x *WorkflowSpec) String() string

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.