interaction

package
v1.13.0 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type Input 

type Input struct {
	// Headers that are passed with the interaction to and from the processing workflow.
	// These can include things like auth or tracing tokens.
	Header *v11.Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// The name of the input handler to invoke on the target workflow
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The arguments to pass to the named handler.
	Args *v11.Payloads `protobuf:"bytes,3,opt,name=args,proto3" json:"args,omitempty"`
}

Input carries interaction input that comes from the caller.

func (*Input) Descriptor 

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

func (*Input) Equal 

func (this *Input) Equal(that interface{}) bool

func (*Input) GetArgs 

func (m *Input) GetArgs() *v11.Payloads

func (*Input) GetHeader 

func (m *Input) GetHeader() *v11.Header

func (*Input) GetName 

func (m *Input) GetName() string

func (*Input) GoString 

func (this *Input) GoString() string

func (*Input) Marshal 

func (m *Input) Marshal() (dAtA []byte, err error)

func (*Input) MarshalTo 

func (m *Input) MarshalTo(dAtA []byte) (int, error)

func (*Input) MarshalToSizedBuffer 

func (m *Input) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) Reset 

func (m *Input) Reset()

func (*Input) Size 

func (m *Input) Size() (n int)

func (*Input) String 

func (this *Input) String() string

func (*Input) Unmarshal 

func (m *Input) Unmarshal(dAtA []byte) error

func (*Input) XXX_DiscardUnknown 

func (m *Input) XXX_DiscardUnknown()

func (*Input) XXX_Marshal 

func (m *Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Input) XXX_Merge 

func (m *Input) XXX_Merge(src proto.Message)

func (*Input) XXX_Size 

func (m *Input) XXX_Size() int

func (*Input) XXX_Unmarshal 

func (m *Input) XXX_Unmarshal(b []byte) error

type Invocation 

type Invocation struct {
	Meta  *Meta  `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Input *Input `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
}

func (*Invocation) Descriptor 

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

func (*Invocation) Equal 

func (this *Invocation) Equal(that interface{}) bool

func (*Invocation) GetInput 

func (m *Invocation) GetInput() *Input

func (*Invocation) GetMeta 

func (m *Invocation) GetMeta() *Meta

func (*Invocation) GoString 

func (this *Invocation) GoString() string

func (*Invocation) Marshal 

func (m *Invocation) Marshal() (dAtA []byte, err error)

func (*Invocation) MarshalTo 

func (m *Invocation) MarshalTo(dAtA []byte) (int, error)

func (*Invocation) MarshalToSizedBuffer 

func (m *Invocation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Invocation) ProtoMessage 

func (*Invocation) ProtoMessage()

func (*Invocation) Reset 

func (m *Invocation) Reset()

func (*Invocation) Size 

func (m *Invocation) Size() (n int)

func (*Invocation) String 

func (this *Invocation) String() string

func (*Invocation) Unmarshal 

func (m *Invocation) Unmarshal(dAtA []byte) error

func (*Invocation) XXX_DiscardUnknown 

func (m *Invocation) XXX_DiscardUnknown()

func (*Invocation) XXX_Marshal 

func (m *Invocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Invocation) XXX_Merge 

func (m *Invocation) XXX_Merge(src proto.Message)

func (*Invocation) XXX_Size 

func (m *Invocation) XXX_Size() int

func (*Invocation) XXX_Unmarshal 

func (m *Invocation) XXX_Unmarshal(b []byte) error

type Meta 

type Meta struct {
	// An ID with workflow-scoped uniqueness for this interaction
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The event ID after which this interaction can execute. The effects of
	// history up to and including this event ID should be visible to the
	// interaction when it executes.
	EventId int64 `protobuf:"varint,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// The type of this interaction.
	InteractionType v1.InteractionType `` /* 150-byte string literal not displayed */
	// A string identifying the agent that requested this interaction.
	Identity  string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	RequestId string `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
}

Meta carries metadata about an interaction for use by the system (i.e. not generall user-visible)

func (*Meta) Descriptor 

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

func (*Meta) Equal 

func (this *Meta) Equal(that interface{}) bool

func (*Meta) GetEventId 

func (m *Meta) GetEventId() int64

func (*Meta) GetId 

func (m *Meta) GetId() string

func (*Meta) GetIdentity 

func (m *Meta) GetIdentity() string

func (*Meta) GetInteractionType 

func (m *Meta) GetInteractionType() v1.InteractionType

func (*Meta) GetRequestId 

func (m *Meta) GetRequestId() string

func (*Meta) GoString 

func (this *Meta) GoString() string

func (*Meta) Marshal 

func (m *Meta) Marshal() (dAtA []byte, err error)

func (*Meta) MarshalTo 

func (m *Meta) MarshalTo(dAtA []byte) (int, error)

func (*Meta) MarshalToSizedBuffer 

func (m *Meta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) Reset 

func (m *Meta) Reset()

func (*Meta) Size 

func (m *Meta) Size() (n int)

func (*Meta) String 

func (this *Meta) String() string

func (*Meta) Unmarshal 

func (m *Meta) Unmarshal(dAtA []byte) error

func (*Meta) XXX_DiscardUnknown 

func (m *Meta) XXX_DiscardUnknown()

func (*Meta) XXX_Marshal 

func (m *Meta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Meta) XXX_Merge 

func (m *Meta) XXX_Merge(src proto.Message)

func (*Meta) XXX_Size 

func (m *Meta) XXX_Size() int

func (*Meta) XXX_Unmarshal 

func (m *Meta) XXX_Unmarshal(b []byte) error

type Output 

type Output struct {
	// Headers that are passed with the interaction to and from the processing workflow.
	// These can include things like auth or tracing tokens.
	Header *v11.Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Types that are valid to be assigned to Result:
	//	*Output_Success
	//	*Output_Failure
	Result isOutput_Result `protobuf_oneof:"result"`
}

Output carries the output data from an interaction.

func (*Output) Descriptor 

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

func (*Output) Equal 

func (this *Output) Equal(that interface{}) bool

func (*Output) GetFailure 

func (m *Output) GetFailure() *v12.Failure

func (*Output) GetHeader 

func (m *Output) GetHeader() *v11.Header

func (*Output) GetResult 

func (m *Output) GetResult() isOutput_Result

func (*Output) GetSuccess 

func (m *Output) GetSuccess() *v11.Payloads

func (*Output) GoString 

func (this *Output) GoString() string

func (*Output) Marshal 

func (m *Output) Marshal() (dAtA []byte, err error)

func (*Output) MarshalTo 

func (m *Output) MarshalTo(dAtA []byte) (int, error)

func (*Output) MarshalToSizedBuffer 

func (m *Output) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Output) ProtoMessage 

func (*Output) ProtoMessage()

func (*Output) Reset 

func (m *Output) Reset()

func (*Output) Size 

func (m *Output) Size() (n int)

func (*Output) String 

func (this *Output) String() string

func (*Output) Unmarshal 

func (m *Output) Unmarshal(dAtA []byte) error

func (*Output) XXX_DiscardUnknown 

func (m *Output) XXX_DiscardUnknown()

func (*Output) XXX_Marshal 

func (m *Output) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Output) XXX_Merge 

func (m *Output) XXX_Merge(src proto.Message)

func (*Output) XXX_OneofWrappers 

func (*Output) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Output) XXX_Size 

func (m *Output) XXX_Size() int

func (*Output) XXX_Unmarshal 

func (m *Output) XXX_Unmarshal(b []byte) error

type Output_Failure 

type Output_Failure struct {
	Failure *v12.Failure `protobuf:"bytes,3,opt,name=failure,proto3,oneof" json:"failure,omitempty"`
}

func (*Output_Failure) Equal 

func (this *Output_Failure) Equal(that interface{}) bool

func (*Output_Failure) GoString 

func (this *Output_Failure) GoString() string

func (*Output_Failure) MarshalTo 

func (m *Output_Failure) MarshalTo(dAtA []byte) (int, error)

func (*Output_Failure) MarshalToSizedBuffer 

func (m *Output_Failure) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Output_Failure) Size 

func (m *Output_Failure) Size() (n int)

func (*Output_Failure) String 

func (this *Output_Failure) String() string

type Output_Success 

type Output_Success struct {
	Success *v11.Payloads `protobuf:"bytes,2,opt,name=success,proto3,oneof" json:"success,omitempty"`
}

func (*Output_Success) Equal 

func (this *Output_Success) Equal(that interface{}) bool

func (*Output_Success) GoString 

func (this *Output_Success) GoString() string

func (*Output_Success) MarshalTo 

func (m *Output_Success) MarshalTo(dAtA []byte) (int, error)

func (*Output_Success) MarshalToSizedBuffer 

func (m *Output_Success) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Output_Success) Size 

func (m *Output_Success) Size() (n int)

func (*Output_Success) String 

func (this *Output_Success) 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.