graph

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
  • func (m *IDs) AddID(id int64)
  • func (*IDs) Descriptor() ([]byte, []int)
  • func (m *IDs) GetIds() []int64
  • func (m *IDs) Merge(ids *IDs)
  • func (*IDs) ProtoMessage()
  • func (m *IDs) Reset()
  • func (m *IDs) String() string
• type Node
  • func (*Node) Descriptor() ([]byte, []int)
  • func (m *Node) GetFnName() string
  • func (m *Node) GetMeta() string
  • func (m *Node) GetOp() Node_Op
  • func (m *Node) GetTask() string
  • func (m *Node) GetType() Node_Type
  • func (*Node) ProtoMessage()
  • func (m *Node) Reset()
  • func (m *Node) String() string
• 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
  • func (p *Provenance) AddEntity(consentID string, wfIDs int64)
  • func (p *Provenance) AddTasks(tasks map[string]*types.Task) *IDs
  • func (*Provenance) Descriptor() ([]byte, []int)
  • func (p *Provenance) FromWorkflow(wfi *types.WorkflowInvocation) int64
  • func (m *Provenance) GetExecuted() map[string]int64
  • func (m *Provenance) GetNodes() map[int64]*Node
  • func (m *Provenance) GetWfPredecessors() map[int64]*IDs
  • func (m *Provenance) GetWfTasks() map[int64]*IDs
  • func (p *Provenance) GetWorkflowPredecessors(wfid int64) []int64
  • func (p *Provenance) GetWorkflowTaskIds(wfid int64) []int64
  • func (*Provenance) ProtoMessage()
  • func (m *Provenance) Reset()
  • func (m *Provenance) String() string

Variables

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

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

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

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

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