process

package
v0.14.0 Latest Latest
Warning

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

 Go to latest Published: Sep 6, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Process_Node_Filter_Condition_Predicate_name = map[int32]string{
	0: "Unknown",
	1: "EQ",
}
View Source 
var Process_Node_Filter_Condition_Predicate_value = map[string]int32{
	"Unknown": 0,
	"EQ":      1,
}

Functions

This section is empty.

Types

type Process 

type Process struct {
	// Process's hash
	Hash github_com_mesg_foundation_engine_hash.Hash `` /* 135-byte string literal not displayed */
	// Process's key
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty" hash:"name:2" validate:"required"`
	// 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"`
	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 (Process) ChildrenIDs 

func (g Process) ChildrenIDs(nodeID 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(id 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) ParentIDs 

func (g Process) ParentIDs(nodeID 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 {
	// 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) ID 

func (r *Process_Node) ID() string

ID is the ID of the Result's node

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) 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 {
	// Key that identifies the node.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" hash:"name:1" validate:"required"`
	// Hash of the instance that triggers the process.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 156-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,2,opt,name=event,proto3,oneof" json:"event,omitempty"`
}

func (*Process_Node_Event_) Equal 

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

type Process_Node_Filter 

type Process_Node_Filter struct {
	// Key for the filter
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" hash:"name:1" validate:"required"`
	// 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"`
	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) Match 

func (f Process_Node_Filter) Match(data map[string]interface{}) bool

Match returns true if the data match the current list of filters

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,5,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
}

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 {
	// Key to check.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" hash:"name:1" validate:"required,printascii"`
	// Type of condition to apply.
	Predicate Process_Node_Filter_Condition_Predicate `` /* 157-byte string literal not displayed */
	// Value of the filter.
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty" hash:"name:3"`
	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(inputs map[string]interface{}) bool

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
)

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 {
	// Key of the mapping.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" hash:"name:1" validate:"required"`
	// Outputs of the mapping.
	Outputs              []*Process_Node_Map_Output `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty" hash:"name:2" validate:"dive,required"`
	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) 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) 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,4,opt,name=map,proto3,oneof" json:"map,omitempty"`
}

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 {
	// Key of the output.
	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 Value:
	//	*Process_Node_Map_Output_Ref
	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) GetRef 

func (m *Process_Node_Map_Output) GetRef() *Process_Node_Map_Output_Reference

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_Ref 

type Process_Node_Map_Output_Ref struct {
	Ref *Process_Node_Map_Output_Reference `protobuf:"bytes,2,opt,name=ref,proto3,oneof" json:"ref,omitempty" hash:"name:2" validate:"required"`
}

func (*Process_Node_Map_Output_Ref) Equal 

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

type Process_Node_Map_Output_Reference 

type Process_Node_Map_Output_Reference struct {
	// Key of the node in the graph. If empty, will be using the src of the edge.
	NodeKey string `protobuf:"bytes,1,opt,name=nodeKey,proto3" json:"nodeKey,omitempty" hash:"name:1" validate:"required"`
	// Key of a specific parameter of the referenced node's output data.
	Key                  string   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty" hash:"name:2" validate:"required"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Process_Node_Map_Output_Reference) Descriptor 

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

func (*Process_Node_Map_Output_Reference) Equal 

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

func (*Process_Node_Map_Output_Reference) ProtoMessage 

func (*Process_Node_Map_Output_Reference) ProtoMessage()

func (*Process_Node_Map_Output_Reference) Reset 

func (m *Process_Node_Map_Output_Reference) Reset()

func (*Process_Node_Map_Output_Reference) String 

func (m *Process_Node_Map_Output_Reference) String() string

func (*Process_Node_Map_Output_Reference) XXX_DiscardUnknown 

func (m *Process_Node_Map_Output_Reference) XXX_DiscardUnknown()

func (*Process_Node_Map_Output_Reference) XXX_Marshal 

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

func (*Process_Node_Map_Output_Reference) XXX_Merge 

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

func (*Process_Node_Map_Output_Reference) XXX_Size 

func (m *Process_Node_Map_Output_Reference) XXX_Size() int

func (*Process_Node_Map_Output_Reference) XXX_Unmarshal 

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

type Process_Node_Result 

type Process_Node_Result struct {
	// Key that identifies the node.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" hash:"name:1" validate:"required"`
	// Hash of the instance that triggers the process.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 156-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,1,opt,name=result,proto3,oneof" json:"result,omitempty"`
}

func (*Process_Node_Result_) Equal 

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

type Process_Node_Task 

type Process_Node_Task struct {
	// Key that identifies the node.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" hash:"name:1" validate:"required"`
	// Hash of the instance to execute.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 156-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,3,opt,name=task,proto3,oneof" json:"task,omitempty"`
}

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.