process

package
v0.26.0 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	NodeTypeUnknown = "unknown"
	NodeTypeResult  = "result"
	NodeTypeEvent   = "event"
	NodeTypeTask    = "task"
	NodeTypeMap     = "map"
	NodeTypeFilter  = "filter"
)

NodeType are the string constant corresponding to each type of node.

Variables

View Source 
var Process_Node_Filter_Condition_Predicate_name = map[int32]string{
	0: "Unknown",
	1: "EQ",
	2: "GT",
	3: "GTE",
	4: "LT",
	5: "LTE",
	6: "CONTAINS",
}
View Source 
var Process_Node_Filter_Condition_Predicate_value = map[string]int32{
	"Unknown":  0,
	"EQ":       1,
	"GT":       2,
	"GTE":      3,
	"LT":       4,
	"LTE":      5,
	"CONTAINS": 6,
}
View Source 
var Process_Node_Map_Output_Null_name = map[int32]string{
	0: "NULL_VALUE",
}
View Source 
var Process_Node_Map_Output_Null_value = map[string]int32{
	"NULL_VALUE": 0,
}

Functions

func RegisterCodec added in v0.19.0 

func RegisterCodec(cdc *codec.Codec)

Types

type KeyOutput added in v0.18.0 

type KeyOutput struct {
	Key   string
	Value *Process_Node_Map_Output
}

KeyOutput is a simple key/value representation of one output of a Process_Node_Map.

type Process 

type Process struct {
	// Process's hash
	Hash github_com_mesg_foundation_engine_hash.Hash `` /* 148-byte string literal not displayed */
	// Process's name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" hash:"name:2" validate:"required,printascii"`
	// Nodes with information related to the execution to trigger.
	Nodes []*Process_Node `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty" hash:"name:4" validate:"dive,required"`
	// Edges to create the link between the nodes.
	Edges []*Process_Edge `protobuf:"bytes,5,rep,name=edges,proto3" json:"edges,omitempty" hash:"name:5" validate:"dive,required"`
	// The address of the process.
	Address github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 162-byte string literal not displayed */
	// The address of the account that pays for the process
	PaymentAddress       github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 176-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

A process is a configuration to trigger a specific task when certains conditions of a trigger are valid.

func New added in v0.20.0 

func New(name string, nodes []*Process_Node, edges []*Process_Edge, paymentAddress sdk.AccAddress) (*Process, error)

New returns a new process and validate it.

func (Process) ChildrenKeys added in v0.18.0 

func (g Process) ChildrenKeys(nodeKey string) []string

ChildrenIDs returns the list of node IDs with a dependency to the current node

func (*Process) Descriptor 

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

func (Process) EdgesFrom 

func (g Process) EdgesFrom(src string) []*Process_Edge

EdgesFrom return all the edges that has a common source

func (*Process) Equal 

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

func (Process) FindNode 

func (g Process) FindNode(nodeKey string) (*Process_Node, error)

FindNode return a specific node in a graph identifies by its ID. Returns an error if there is no match or multiple matches

func (Process) FindNodes 

func (g Process) FindNodes(filter func(n *Process_Node) bool) []*Process_Node

FindNodes returns a list of nodes matching a specific filter

func (Process) FindParentWithType added in v0.20.0 

func (g Process) FindParentWithType(nodeKey string, match func(*Process_Node) bool) (*Process_Node, error)

FindParentWithType returns the first parent matching the type. Only works on mono-parental graph. TODO: make it works on multi-parents TODO: find a better way than having to pass this match function

func (Process) ParentKeys added in v0.18.0 

func (g Process) ParentKeys(nodeKey string) []string

ParentIDs returns the list of node IDs with the current node as child

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) Reset 

func (m *Process) Reset()

func (*Process) String 

func (m *Process) String() string

func (*Process) Trigger 

func (w *Process) Trigger() (*Process_Node, error)

Trigger returns the trigger of the process

func (*Process) Validate 

func (w *Process) Validate() error

Validate returns an error if the process is invalid for whatever reason

func (*Process) XXX_DiscardUnknown 

func (m *Process) XXX_DiscardUnknown()

func (*Process) XXX_Marshal 

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

func (*Process) XXX_Merge 

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

func (*Process) XXX_Size 

func (m *Process) XXX_Size() int

func (*Process) XXX_Unmarshal 

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

type Process_Edge 

type Process_Edge struct {
	// Source of the edge.
	Src string `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty" hash:"name:1" validate:"required"`
	// Destination of the edge.
	Dst                  string   `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty" hash:"name:2" validate:"required"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Process_Edge) Descriptor 

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

func (*Process_Edge) Equal 

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

func (*Process_Edge) ProtoMessage 

func (*Process_Edge) ProtoMessage()

func (*Process_Edge) Reset 

func (m *Process_Edge) Reset()

func (*Process_Edge) String 

func (m *Process_Edge) String() string

func (*Process_Edge) XXX_DiscardUnknown 

func (m *Process_Edge) XXX_DiscardUnknown()

func (*Process_Edge) XXX_Marshal 

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

func (*Process_Edge) XXX_Merge 

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

func (*Process_Edge) XXX_Size 

func (m *Process_Edge) XXX_Size() int

func (*Process_Edge) XXX_Unmarshal 

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

type Process_Node 

type Process_Node struct {
	// Key that identifies the node.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" hash:"name:1" validate:"required"`
	// Types that are valid to be assigned to Type:
	//	*Process_Node_Result_
	//	*Process_Node_Event_
	//	*Process_Node_Task_
	//	*Process_Node_Map_
	//	*Process_Node_Filter_
	Type                 isProcess_Node_Type `protobuf_oneof:"type"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Node of the process

func (*Process_Node) Descriptor 

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

func (*Process_Node) Equal 

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

func (*Process_Node) GetEvent 

func (m *Process_Node) GetEvent() *Process_Node_Event

func (*Process_Node) GetFilter 

func (m *Process_Node) GetFilter() *Process_Node_Filter

func (*Process_Node) GetMap 

func (m *Process_Node) GetMap() *Process_Node_Map

func (*Process_Node) GetResult 

func (m *Process_Node) GetResult() *Process_Node_Result

func (*Process_Node) GetTask 

func (m *Process_Node) GetTask() *Process_Node_Task

func (*Process_Node) GetType 

func (m *Process_Node) GetType() isProcess_Node_Type

func (*Process_Node) ProtoMessage 

func (*Process_Node) ProtoMessage()

func (*Process_Node) Reset 

func (m *Process_Node) Reset()

func (*Process_Node) String 

func (m *Process_Node) String() string

func (*Process_Node) TypeString added in v0.24.0 

func (node *Process_Node) TypeString() string

TypeString returns the type of the node in string

func (*Process_Node) XXX_DiscardUnknown 

func (m *Process_Node) XXX_DiscardUnknown()

func (*Process_Node) XXX_Marshal 

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

func (*Process_Node) XXX_Merge 

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

func (*Process_Node) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Process_Node) XXX_Size 

func (m *Process_Node) XXX_Size() int

func (*Process_Node) XXX_Unmarshal 

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

type Process_Node_Event 

type Process_Node_Event struct {
	// Hash of the instance that triggers the process.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 169-byte string literal not displayed */
	// Key of the event that triggers the process.
	EventKey             string   `protobuf:"bytes,3,opt,name=eventKey,proto3" json:"eventKey,omitempty" hash:"name:3" validate:"printascii,required"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Process_Node_Event) Descriptor 

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

func (*Process_Node_Event) Equal 

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

func (*Process_Node_Event) ProtoMessage 

func (*Process_Node_Event) ProtoMessage()

func (*Process_Node_Event) Reset 

func (m *Process_Node_Event) Reset()

func (*Process_Node_Event) String 

func (m *Process_Node_Event) String() string

func (*Process_Node_Event) XXX_DiscardUnknown 

func (m *Process_Node_Event) XXX_DiscardUnknown()

func (*Process_Node_Event) XXX_Marshal 

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

func (*Process_Node_Event) XXX_Merge 

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

func (*Process_Node_Event) XXX_Size 

func (m *Process_Node_Event) XXX_Size() int

func (*Process_Node_Event) XXX_Unmarshal 

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

type Process_Node_Event_ 

type Process_Node_Event_ struct {
	Event *Process_Node_Event `protobuf:"bytes,3,opt,name=event,proto3,oneof" json:"event,omitempty" hash:"name:3"`
}

func (*Process_Node_Event_) Equal 

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

type Process_Node_Filter 

type Process_Node_Filter struct {
	// List of condition to apply for this filter
	Conditions           []Process_Node_Filter_Condition `protobuf:"bytes,2,rep,name=conditions,proto3" json:"conditions" hash:"name:2" validate:"dive"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*Process_Node_Filter) Descriptor 

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

func (*Process_Node_Filter) Equal 

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

func (*Process_Node_Filter) ProtoMessage 

func (*Process_Node_Filter) ProtoMessage()

func (*Process_Node_Filter) Reset 

func (m *Process_Node_Filter) Reset()

func (*Process_Node_Filter) String 

func (m *Process_Node_Filter) String() string

func (*Process_Node_Filter) XXX_DiscardUnknown 

func (m *Process_Node_Filter) XXX_DiscardUnknown()

func (*Process_Node_Filter) XXX_Marshal 

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

func (*Process_Node_Filter) XXX_Merge 

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

func (*Process_Node_Filter) XXX_Size 

func (m *Process_Node_Filter) XXX_Size() int

func (*Process_Node_Filter) XXX_Unmarshal 

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

type Process_Node_Filter_ 

type Process_Node_Filter_ struct {
	Filter *Process_Node_Filter `protobuf:"bytes,6,opt,name=filter,proto3,oneof" json:"filter,omitempty" hash:"name:6"`
}

func (*Process_Node_Filter_) Equal 

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

type Process_Node_Filter_Condition 

type Process_Node_Filter_Condition struct {
	// Type of condition to apply.
	Predicate Process_Node_Filter_Condition_Predicate `` /* 162-byte string literal not displayed */
	// Value of the filter.
	Value *types.Value `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty" hash:"name:4" validate:"required"`
	// Input defined as reference.
	Ref                  *Process_Node_Reference `protobuf:"bytes,5,opt,name=ref,proto3" json:"ref,omitempty" hash:"name:5" validate:"required"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*Process_Node_Filter_Condition) Descriptor 

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

func (*Process_Node_Filter_Condition) Equal 

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

func (*Process_Node_Filter_Condition) Match 

func (f *Process_Node_Filter_Condition) Match(data *types.Value) (bool, error)

Match returns true the current filter matches the given data

func (*Process_Node_Filter_Condition) ProtoMessage 

func (*Process_Node_Filter_Condition) ProtoMessage()

func (*Process_Node_Filter_Condition) Reset 

func (m *Process_Node_Filter_Condition) Reset()

func (*Process_Node_Filter_Condition) String 

func (m *Process_Node_Filter_Condition) String() string

func (*Process_Node_Filter_Condition) XXX_DiscardUnknown 

func (m *Process_Node_Filter_Condition) XXX_DiscardUnknown()

func (*Process_Node_Filter_Condition) XXX_Marshal 

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

func (*Process_Node_Filter_Condition) XXX_Merge 

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

func (*Process_Node_Filter_Condition) XXX_Size 

func (m *Process_Node_Filter_Condition) XXX_Size() int

func (*Process_Node_Filter_Condition) XXX_Unmarshal 

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

type Process_Node_Filter_Condition_Predicate 

type Process_Node_Filter_Condition_Predicate int32

Type of condition available to compare the values. 

const (
	// Predicate not defined.
	Process_Node_Filter_Condition_Unknown Process_Node_Filter_Condition_Predicate = 0
	// Equal
	Process_Node_Filter_Condition_EQ Process_Node_Filter_Condition_Predicate = 1
	// Greater than
	Process_Node_Filter_Condition_GT Process_Node_Filter_Condition_Predicate = 2
	// Greater or equal than
	Process_Node_Filter_Condition_GTE Process_Node_Filter_Condition_Predicate = 3
	// Lesser than
	Process_Node_Filter_Condition_LT Process_Node_Filter_Condition_Predicate = 4
	// Lesser or equal than
	Process_Node_Filter_Condition_LTE Process_Node_Filter_Condition_Predicate = 5
	// CONTAINS
	Process_Node_Filter_Condition_CONTAINS Process_Node_Filter_Condition_Predicate = 6
)

func (Process_Node_Filter_Condition_Predicate) EnumDescriptor 

func (Process_Node_Filter_Condition_Predicate) EnumDescriptor() ([]byte, []int)

func (Process_Node_Filter_Condition_Predicate) String 

func (x Process_Node_Filter_Condition_Predicate) String() string

type Process_Node_Map 

type Process_Node_Map struct {
	// Outputs of the mapping.
	Outputs              map[string]*Process_Node_Map_Output `` /* 194-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*Process_Node_Map) Descriptor 

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

func (*Process_Node_Map) Equal 

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

func (Process_Node_Map) MarshalAmino added in v0.18.0 

func (m Process_Node_Map) MarshalAmino() ([]KeyOutput, error)

MarshalAmino transforms the Process_Node_Map to an array of key/value.

func (*Process_Node_Map) ProtoMessage 

func (*Process_Node_Map) ProtoMessage()

func (*Process_Node_Map) Reset 

func (m *Process_Node_Map) Reset()

func (*Process_Node_Map) String 

func (m *Process_Node_Map) String() string

func (*Process_Node_Map) UnmarshalAmino added in v0.18.0 

func (m *Process_Node_Map) UnmarshalAmino(keyValues []KeyOutput) error

UnmarshalAmino transforms the key/value array to a Process_Node_Map.

func (*Process_Node_Map) XXX_DiscardUnknown 

func (m *Process_Node_Map) XXX_DiscardUnknown()

func (*Process_Node_Map) XXX_Marshal 

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

func (*Process_Node_Map) XXX_Merge 

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

func (*Process_Node_Map) XXX_Size 

func (m *Process_Node_Map) XXX_Size() int

func (*Process_Node_Map) XXX_Unmarshal 

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

type Process_Node_Map_ 

type Process_Node_Map_ struct {
	Map *Process_Node_Map `protobuf:"bytes,5,opt,name=map,proto3,oneof" json:"map,omitempty" hash:"name:5"`
}

func (*Process_Node_Map_) Equal 

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

type Process_Node_Map_Output 

type Process_Node_Map_Output struct {
	// Types that are valid to be assigned to Value:
	//	*Process_Node_Map_Output_Null_
	//	*Process_Node_Map_Output_StringConst
	//	*Process_Node_Map_Output_DoubleConst
	//	*Process_Node_Map_Output_BoolConst
	//	*Process_Node_Map_Output_Ref
	//	*Process_Node_Map_Output_List_
	//	*Process_Node_Map_Output_Map_
	Value                isProcess_Node_Map_Output_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*Process_Node_Map_Output) Descriptor 

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

func (*Process_Node_Map_Output) Equal 

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

func (*Process_Node_Map_Output) GetBoolConst added in v0.18.0 

func (m *Process_Node_Map_Output) GetBoolConst() bool

func (*Process_Node_Map_Output) GetDoubleConst added in v0.18.0 

func (m *Process_Node_Map_Output) GetDoubleConst() float64

func (*Process_Node_Map_Output) GetList added in v0.18.0 

func (m *Process_Node_Map_Output) GetList() *Process_Node_Map_Output_List

func (*Process_Node_Map_Output) GetMap added in v0.18.0 

func (m *Process_Node_Map_Output) GetMap() *Process_Node_Map_Output_Map

func (*Process_Node_Map_Output) GetNull added in v0.18.0 

func (m *Process_Node_Map_Output) GetNull() Process_Node_Map_Output_Null

func (*Process_Node_Map_Output) GetRef 

func (m *Process_Node_Map_Output) GetRef() *Process_Node_Reference

func (*Process_Node_Map_Output) GetStringConst added in v0.18.0 

func (m *Process_Node_Map_Output) GetStringConst() string

func (*Process_Node_Map_Output) GetValue 

func (m *Process_Node_Map_Output) GetValue() isProcess_Node_Map_Output_Value

func (*Process_Node_Map_Output) ProtoMessage 

func (*Process_Node_Map_Output) ProtoMessage()

func (*Process_Node_Map_Output) Reset 

func (m *Process_Node_Map_Output) Reset()

func (*Process_Node_Map_Output) String 

func (m *Process_Node_Map_Output) String() string

func (*Process_Node_Map_Output) XXX_DiscardUnknown 

func (m *Process_Node_Map_Output) XXX_DiscardUnknown()

func (*Process_Node_Map_Output) XXX_Marshal 

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

func (*Process_Node_Map_Output) XXX_Merge 

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

func (*Process_Node_Map_Output) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Process_Node_Map_Output) XXX_Size 

func (m *Process_Node_Map_Output) XXX_Size() int

func (*Process_Node_Map_Output) XXX_Unmarshal 

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

type Process_Node_Map_Output_BoolConst added in v0.18.0 

type Process_Node_Map_Output_BoolConst struct {
	BoolConst bool `protobuf:"varint,4,opt,name=bool_const,json=boolConst,proto3,oneof" json:"bool_const,omitempty" hash:"name:4"`
}

func (*Process_Node_Map_Output_BoolConst) Equal added in v0.18.0 

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

type Process_Node_Map_Output_DoubleConst added in v0.18.0 

type Process_Node_Map_Output_DoubleConst struct {
	DoubleConst float64 `` /* 131-byte string literal not displayed */
}

func (*Process_Node_Map_Output_DoubleConst) Equal added in v0.18.0 

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

type Process_Node_Map_Output_List added in v0.18.0 

type Process_Node_Map_Output_List struct {
	Outputs              []*Process_Node_Map_Output `protobuf:"bytes,1,rep,name=outputs,proto3" json:"outputs,omitempty" hash:"name:1" validate:"dive,required"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

List is a list of output as message, so it can be used in oneof.

func (*Process_Node_Map_Output_List) Descriptor added in v0.18.0 

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

func (*Process_Node_Map_Output_List) Equal added in v0.18.0 

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

func (*Process_Node_Map_Output_List) ProtoMessage added in v0.18.0 

func (*Process_Node_Map_Output_List) ProtoMessage()

func (*Process_Node_Map_Output_List) Reset added in v0.18.0 

func (m *Process_Node_Map_Output_List) Reset()

func (*Process_Node_Map_Output_List) String added in v0.18.0 

func (m *Process_Node_Map_Output_List) String() string

func (*Process_Node_Map_Output_List) XXX_DiscardUnknown added in v0.18.0 

func (m *Process_Node_Map_Output_List) XXX_DiscardUnknown()

func (*Process_Node_Map_Output_List) XXX_Marshal added in v0.18.0 

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

func (*Process_Node_Map_Output_List) XXX_Merge added in v0.18.0 

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

func (*Process_Node_Map_Output_List) XXX_Size added in v0.18.0 

func (m *Process_Node_Map_Output_List) XXX_Size() int

func (*Process_Node_Map_Output_List) XXX_Unmarshal added in v0.18.0 

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

type Process_Node_Map_Output_List_ added in v0.18.0 

type Process_Node_Map_Output_List_ struct {
	List *Process_Node_Map_Output_List `protobuf:"bytes,6,opt,name=list,proto3,oneof" json:"list,omitempty" hash:"name:6"`
}

func (*Process_Node_Map_Output_List_) Equal added in v0.18.0 

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

type Process_Node_Map_Output_Map added in v0.18.0 

type Process_Node_Map_Output_Map struct {
	Outputs              map[string]*Process_Node_Map_Output `` /* 194-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

Map is a map of output as message, so it can be used in oneof.

func (*Process_Node_Map_Output_Map) Descriptor added in v0.18.0 

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

func (*Process_Node_Map_Output_Map) Equal added in v0.18.0 

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

func (Process_Node_Map_Output_Map) MarshalAmino added in v0.18.0 

func (m Process_Node_Map_Output_Map) MarshalAmino() ([]KeyOutput, error)

MarshalAmino transforms the Process_Node_Map_Output_Map to an array of key/value.

func (*Process_Node_Map_Output_Map) ProtoMessage added in v0.18.0 

func (*Process_Node_Map_Output_Map) ProtoMessage()

func (*Process_Node_Map_Output_Map) Reset added in v0.18.0 

func (m *Process_Node_Map_Output_Map) Reset()

func (*Process_Node_Map_Output_Map) String added in v0.18.0 

func (m *Process_Node_Map_Output_Map) String() string

func (*Process_Node_Map_Output_Map) UnmarshalAmino added in v0.18.0 

func (m *Process_Node_Map_Output_Map) UnmarshalAmino(keyValues []KeyOutput) error

UnmarshalAmino transforms the key/value array to a Process_Node_Map_Output_Map.

func (*Process_Node_Map_Output_Map) XXX_DiscardUnknown added in v0.18.0 

func (m *Process_Node_Map_Output_Map) XXX_DiscardUnknown()

func (*Process_Node_Map_Output_Map) XXX_Marshal added in v0.18.0 

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

func (*Process_Node_Map_Output_Map) XXX_Merge added in v0.18.0 

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

func (*Process_Node_Map_Output_Map) XXX_Size added in v0.18.0 

func (m *Process_Node_Map_Output_Map) XXX_Size() int

func (*Process_Node_Map_Output_Map) XXX_Unmarshal added in v0.18.0 

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

type Process_Node_Map_Output_Map_ added in v0.18.0 

type Process_Node_Map_Output_Map_ struct {
	Map *Process_Node_Map_Output_Map `protobuf:"bytes,7,opt,name=map,proto3,oneof" json:"map,omitempty" hash:"name:7"`
}

func (*Process_Node_Map_Output_Map_) Equal added in v0.18.0 

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

type Process_Node_Map_Output_Null added in v0.18.0 

type Process_Node_Map_Output_Null int32
const (
	Process_Node_Map_Output_NULL_VALUE Process_Node_Map_Output_Null = 0
)

func (Process_Node_Map_Output_Null) EnumDescriptor added in v0.18.0 

func (Process_Node_Map_Output_Null) EnumDescriptor() ([]byte, []int)

func (Process_Node_Map_Output_Null) String added in v0.18.0 

func (x Process_Node_Map_Output_Null) String() string

type Process_Node_Map_Output_Null_ added in v0.18.0 

type Process_Node_Map_Output_Null_ struct {
	Null Process_Node_Map_Output_Null `` /* 127-byte string literal not displayed */
}

func (*Process_Node_Map_Output_Null_) Equal added in v0.18.0 

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

type Process_Node_Map_Output_Ref 

type Process_Node_Map_Output_Ref struct {
	Ref *Process_Node_Reference `protobuf:"bytes,5,opt,name=ref,proto3,oneof" json:"ref,omitempty" hash:"name:5"`
}

func (*Process_Node_Map_Output_Ref) Equal 

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

type Process_Node_Map_Output_StringConst added in v0.18.0 

type Process_Node_Map_Output_StringConst struct {
	StringConst string `protobuf:"bytes,2,opt,name=string_const,json=stringConst,proto3,oneof" json:"string_const,omitempty" hash:"name:2"`
}

func (*Process_Node_Map_Output_StringConst) Equal added in v0.18.0 

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

type Process_Node_Reference added in v0.21.0 

type Process_Node_Reference struct {
	NodeKey string `protobuf:"bytes,1,opt,name=nodeKey,proto3" json:"nodeKey,omitempty" hash:"name:1" validate:"required"`
	// Path can be nil if referencing the whole node's output
	Path                 *Process_Node_Reference_Path `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty" hash:"name:2"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*Process_Node_Reference) Descriptor added in v0.21.0 

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

func (*Process_Node_Reference) Equal added in v0.21.0 

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

func (*Process_Node_Reference) ProtoMessage added in v0.21.0 

func (*Process_Node_Reference) ProtoMessage()

func (*Process_Node_Reference) Reset added in v0.21.0 

func (m *Process_Node_Reference) Reset()

func (*Process_Node_Reference) String added in v0.21.0 

func (m *Process_Node_Reference) String() string

func (*Process_Node_Reference) XXX_DiscardUnknown added in v0.21.0 

func (m *Process_Node_Reference) XXX_DiscardUnknown()

func (*Process_Node_Reference) XXX_Marshal added in v0.21.0 

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

func (*Process_Node_Reference) XXX_Merge added in v0.21.0 

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

func (*Process_Node_Reference) XXX_Size added in v0.21.0 

func (m *Process_Node_Reference) XXX_Size() int

func (*Process_Node_Reference) XXX_Unmarshal added in v0.21.0 

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

type Process_Node_Reference_Path added in v0.21.0 

type Process_Node_Reference_Path struct {
	// Types that are valid to be assigned to Selector:
	//	*Process_Node_Reference_Path_Key
	//	*Process_Node_Reference_Path_Index
	Selector isProcess_Node_Reference_Path_Selector `protobuf_oneof:"selector"`
	// Path can be nil if on the leaf
	Path                 *Process_Node_Reference_Path `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty" hash:"name:3"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*Process_Node_Reference_Path) Descriptor added in v0.21.0 

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

func (*Process_Node_Reference_Path) Equal added in v0.21.0 

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

func (*Process_Node_Reference_Path) GetIndex added in v0.21.0 

func (m *Process_Node_Reference_Path) GetIndex() uint64

func (*Process_Node_Reference_Path) GetKey added in v0.21.0 

func (m *Process_Node_Reference_Path) GetKey() string

func (*Process_Node_Reference_Path) GetSelector added in v0.21.0 

func (m *Process_Node_Reference_Path) GetSelector() isProcess_Node_Reference_Path_Selector

func (*Process_Node_Reference_Path) ProtoMessage added in v0.21.0 

func (*Process_Node_Reference_Path) ProtoMessage()

func (*Process_Node_Reference_Path) Reset added in v0.21.0 

func (m *Process_Node_Reference_Path) Reset()

func (*Process_Node_Reference_Path) Resolve added in v0.21.0 

func (path *Process_Node_Reference_Path) Resolve(data *types.Struct) (*types.Value, error)

Resolve returns the value specified in the reference.

func (*Process_Node_Reference_Path) String added in v0.21.0 

func (m *Process_Node_Reference_Path) String() string

func (*Process_Node_Reference_Path) XXX_DiscardUnknown added in v0.21.0 

func (m *Process_Node_Reference_Path) XXX_DiscardUnknown()

func (*Process_Node_Reference_Path) XXX_Marshal added in v0.21.0 

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

func (*Process_Node_Reference_Path) XXX_Merge added in v0.21.0 

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

func (*Process_Node_Reference_Path) XXX_OneofWrappers added in v0.21.0 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Process_Node_Reference_Path) XXX_Size added in v0.21.0 

func (m *Process_Node_Reference_Path) XXX_Size() int

func (*Process_Node_Reference_Path) XXX_Unmarshal added in v0.21.0 

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

type Process_Node_Reference_Path_Index added in v0.21.0 

type Process_Node_Reference_Path_Index struct {
	Index uint64 `protobuf:"varint,2,opt,name=index,proto3,oneof" json:"index,omitempty" hash:"name:2"`
}

func (*Process_Node_Reference_Path_Index) Equal added in v0.21.0 

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

type Process_Node_Reference_Path_Key added in v0.21.0 

type Process_Node_Reference_Path_Key struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3,oneof" json:"key,omitempty" hash:"name:1" validate:"printascii"`
}

func (*Process_Node_Reference_Path_Key) Equal added in v0.21.0 

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

type Process_Node_Result 

type Process_Node_Result struct {
	// Hash of the instance that triggers the process.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 169-byte string literal not displayed */
	// Key of the task that triggers the process.
	TaskKey              string   `protobuf:"bytes,3,opt,name=taskKey,proto3" json:"taskKey,omitempty" hash:"name:3" validate:"printascii,required"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Process_Node_Result) Descriptor 

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

func (*Process_Node_Result) Equal 

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

func (*Process_Node_Result) ProtoMessage 

func (*Process_Node_Result) ProtoMessage()

func (*Process_Node_Result) Reset 

func (m *Process_Node_Result) Reset()

func (*Process_Node_Result) String 

func (m *Process_Node_Result) String() string

func (*Process_Node_Result) XXX_DiscardUnknown 

func (m *Process_Node_Result) XXX_DiscardUnknown()

func (*Process_Node_Result) XXX_Marshal 

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

func (*Process_Node_Result) XXX_Merge 

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

func (*Process_Node_Result) XXX_Size 

func (m *Process_Node_Result) XXX_Size() int

func (*Process_Node_Result) XXX_Unmarshal 

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

type Process_Node_Result_ 

type Process_Node_Result_ struct {
	Result *Process_Node_Result `protobuf:"bytes,2,opt,name=result,proto3,oneof" json:"result,omitempty" hash:"name:2"`
}

func (*Process_Node_Result_) Equal 

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

type Process_Node_Task 

type Process_Node_Task struct {
	// Hash of the instance to execute.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 169-byte string literal not displayed */
	// Task of the instance to execute.
	TaskKey              string   `protobuf:"bytes,3,opt,name=taskKey,proto3" json:"taskKey,omitempty" hash:"name:3" validate:"printascii,required"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Process_Node_Task) Descriptor 

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

func (*Process_Node_Task) Equal 

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

func (*Process_Node_Task) ProtoMessage 

func (*Process_Node_Task) ProtoMessage()

func (*Process_Node_Task) Reset 

func (m *Process_Node_Task) Reset()

func (*Process_Node_Task) String 

func (m *Process_Node_Task) String() string

func (*Process_Node_Task) XXX_DiscardUnknown 

func (m *Process_Node_Task) XXX_DiscardUnknown()

func (*Process_Node_Task) XXX_Marshal 

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

func (*Process_Node_Task) XXX_Merge 

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

func (*Process_Node_Task) XXX_Size 

func (m *Process_Node_Task) XXX_Size() int

func (*Process_Node_Task) XXX_Unmarshal 

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

type Process_Node_Task_ 

type Process_Node_Task_ struct {
	Task *Process_Node_Task `protobuf:"bytes,4,opt,name=task,proto3,oneof" json:"task,omitempty" hash:"name:4"`
}

func (*Process_Node_Task_) Equal 

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

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.