graph

package

v0.0.0-...-0f8ae5d Latest Latest Go to latest Published: Dec 31, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gradecak/fission-workflows

Links

Open Source Insights

Documentation ¶

Overview ¶

Package graph is a generated protocol buffer package.

It is generated from these files:

pkg/provenance/graph/graph.proto

It has these top-level messages:

Node
IDs
Provenance

Index ¶

Variables
type IDs
- func NewIDArray() *IDs
type Node
type Node_Op
- func (Node_Op) EnumDescriptor() ([]byte, []int)
- func (x Node_Op) String() string
type Node_Type
- func (Node_Type) EnumDescriptor() ([]byte, []int)
- func (x Node_Type) String() string
type Provenance
- func GenProvenance(wfi *types.WorkflowInvocation) *Provenance
- func NewProvenance() *Provenance

Constants ¶

This section is empty.

Variables ¶

View Source

var Node_Op_name = map[int32]string{
	0: "NOP",
	1: "TRANSFORM",
	2: "READ",
	3: "WRITE",
	4: "CONTROL",
}

View Source

var Node_Op_value = map[string]int32{
	"NOP":       0,
	"TRANSFORM": 1,
	"READ":      2,
	"WRITE":     3,
	"CONTROL":   4,
}

View Source

var Node_Type_name = map[int32]string{
	0: "UNDEF",
	1: "WORKFLOW",
	2: "ENTITY",
	3: "TASK",
}

View Source

var Node_Type_value = map[string]int32{
	"UNDEF":    0,
	"WORKFLOW": 1,
	"ENTITY":   2,
	"TASK":     3,
}

Functions ¶

This section is empty.

Types ¶

type IDs ¶

type IDs struct {
	Ids []int64 `protobuf:"varint,1,rep,packed,name=ids" json:"ids,omitempty"`
}

func NewIDArray ¶

func NewIDArray() *IDs

func (*IDs) AddID ¶

func (m *IDs) AddID(id int64)

func (*IDs) Descriptor ¶

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

func (*IDs) GetIds ¶

func (m *IDs) GetIds() []int64

func (*IDs) Merge ¶

func (m *IDs) Merge(ids *IDs)

func (*IDs) ProtoMessage ¶

func (*IDs) ProtoMessage()

func (*IDs) Reset ¶

func (m *IDs) Reset()

func (*IDs) String ¶

func (m *IDs) String() string

type Node ¶

type Node struct {
	Type   Node_Type `protobuf:"varint,1,opt,name=type,enum=fission.workflows.provenance.Node_Type" json:"type,omitempty"`
	Op     Node_Op   `protobuf:"varint,2,opt,name=op,enum=fission.workflows.provenance.Node_Op" json:"op,omitempty"`
	Meta   string    `protobuf:"bytes,3,opt,name=meta" json:"meta,omitempty"`
	FnName string    `protobuf:"bytes,4,opt,name=fnName" json:"fnName,omitempty"`
	Task   string    `protobuf:"bytes,5,opt,name=task" json:"task,omitempty"`
}

Graph structure for boradcasting provenance data, it is up to the reciever or a middleware layer to decode the message into a particular graph format

func (*Node) Descriptor ¶

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

func (*Node) GetFnName ¶

func (m *Node) GetFnName() string

func (*Node) GetMeta ¶

func (m *Node) GetMeta() string

func (*Node) GetOp ¶

func (m *Node) GetOp() Node_Op

func (*Node) GetTask ¶

func (m *Node) GetTask() string

func (*Node) GetType ¶

func (m *Node) GetType() Node_Type

func (*Node) ProtoMessage ¶

func (*Node) ProtoMessage()

func (*Node) Reset ¶

func (m *Node) Reset()

func (*Node) String ¶

func (m *Node) String() string

type Node_Op ¶

type Node_Op int32

const (
	Node_NOP       Node_Op = 0
	Node_TRANSFORM Node_Op = 1
	Node_READ      Node_Op = 2
	Node_WRITE     Node_Op = 3
	Node_CONTROL   Node_Op = 4
)

func (Node_Op) EnumDescriptor ¶

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

func (Node_Op) String ¶

func (x Node_Op) String() string

type Node_Type ¶

type Node_Type int32

const (
	Node_UNDEF    Node_Type = 0
	Node_WORKFLOW Node_Type = 1
	Node_ENTITY   Node_Type = 2
	Node_TASK     Node_Type = 3
)

func (Node_Type) EnumDescriptor ¶

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

func (Node_Type) String ¶

func (x Node_Type) String() string

type Provenance ¶

type Provenance struct {
	Nodes          map[int64]*Node  `` /* 131-byte string literal not displayed */
	WfTasks        map[int64]*IDs   `` /* 135-byte string literal not displayed */
	WfPredecessors map[int64]*IDs   `` /* 149-byte string literal not displayed */
	Executed       map[string]int64 `` /* 137-byte string literal not displayed */
}

func GenProvenance ¶

func GenProvenance(wfi *types.WorkflowInvocation) *Provenance

func NewProvenance ¶

func NewProvenance() *Provenance

func (*Provenance) AddEntity ¶

func (p *Provenance) AddEntity(consentID string, wfIDs int64)

func (*Provenance) AddTasks ¶

func (p *Provenance) AddTasks(tasks map[string]*types.Task) *IDs

func (*Provenance) Descriptor ¶

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

func (*Provenance) FromWorkflow ¶

func (p *Provenance) FromWorkflow(wfi *types.WorkflowInvocation) int64

func (*Provenance) GetExecuted ¶

func (m *Provenance) GetExecuted() map[string]int64

func (*Provenance) GetNodes ¶

func (m *Provenance) GetNodes() map[int64]*Node

func (*Provenance) GetWfPredecessors ¶

func (m *Provenance) GetWfPredecessors() map[int64]*IDs

func (*Provenance) GetWfTasks ¶

func (m *Provenance) GetWfTasks() map[int64]*IDs

func (*Provenance) GetWorkflowPredecessors ¶

func (p *Provenance) GetWorkflowPredecessors(wfid int64) []int64

func (*Provenance) GetWorkflowTaskIds ¶

func (p *Provenance) GetWorkflowTaskIds(wfid int64) []int64

func (*Provenance) ProtoMessage ¶

func (*Provenance) ProtoMessage()

func (*Provenance) Reset ¶

func (m *Provenance) Reset()

func (*Provenance) String ¶

func (m *Provenance) String() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL