nodes

Documentation

Overview

Package nodes is a generated GoMock package.

Index

• type InterfaceNode
• type MockInterfaceNode
  • func NewMockInterfaceNode(ctrl *gomock.Controller) *MockInterfaceNode
  • func (m *MockInterfaceNode) EXPECT() *MockInterfaceNodeMockRecorder
  • func (m *MockInterfaceNode) GetPredecessorNodes(interfaceNode InterfaceNode, workflowContext *WorkflowContext) []InterfaceNode
  • func (m *MockInterfaceNode) GetPredecessorNodesResults(interfaceNode InterfaceNode, workflowContext *WorkflowContext) []interface{}
  • func (m *MockInterfaceNode) GetResult(interfaceNode InterfaceNode, workflowContext *WorkflowContext) interface{}
  • func (m *MockInterfaceNode) Process(interfaceNode InterfaceNode, workflowContext *WorkflowContext) error
  • func (m *MockInterfaceNode) ProcessVirt(workflowContext *WorkflowContext) error
  • func (m *MockInterfaceNode) SaveResult(interfaceNode InterfaceNode, workflowContext *WorkflowContext, ...)
• type MockInterfaceNodeMockRecorder
  • func (mr *MockInterfaceNodeMockRecorder) GetPredecessorNodes(interfaceNode, workflowContext interface{}) *gomock.Call
  • func (mr *MockInterfaceNodeMockRecorder) GetPredecessorNodesResults(interfaceNode, workflowContext interface{}) *gomock.Call
  • func (mr *MockInterfaceNodeMockRecorder) GetResult(interfaceNode, workflowContext interface{}) *gomock.Call
  • func (mr *MockInterfaceNodeMockRecorder) Process(interfaceNode, workflowContext interface{}) *gomock.Call
  • func (mr *MockInterfaceNodeMockRecorder) ProcessVirt(workflowContext interface{}) *gomock.Call
  • func (mr *MockInterfaceNodeMockRecorder) SaveResult(interfaceNode, workflowContext, result interface{}) *gomock.Call
• type Node
  • func (node *Node) GetPredecessorNodes(interfaceNode InterfaceNode, workflowContext *WorkflowContext) []InterfaceNode
  • func (node *Node) GetPredecessorNodesResults(interfaceNode InterfaceNode, workflowContext *WorkflowContext) []interface{}
  • func (node *Node) GetResult(interfaceNode InterfaceNode, workflowContext *WorkflowContext) interface{}
  • func (node *Node) Process(interfaceNode InterfaceNode, workflowContext *WorkflowContext) error
  • func (node *Node) SaveResult(interfaceNode InterfaceNode, workflowContext *WorkflowContext, ...)
• type WorkflowContext
  • func NewWorkflowContext() *WorkflowContext
  • func (workflowContext *WorkflowContext) GetNodes() []InterfaceNode
  • func (workflowContext *WorkflowContext) SetNodes(nodes []InterfaceNode)

Types

type InterfaceNode

type InterfaceNode interface {
	Process(interfaceNode InterfaceNode, workflowContext *WorkflowContext) error
	ProcessVirt(workflowContext *WorkflowContext) error
	SaveResult(interfaceNode InterfaceNode, workflowContext *WorkflowContext, result interface{})
	GetResult(interfaceNode InterfaceNode, workflowContext *WorkflowContext) interface{}
	GetPredecessorNodes(interfaceNode InterfaceNode, workflowContext *WorkflowContext) []InterfaceNode
	GetPredecessorNodesResults(interfaceNode InterfaceNode, workflowContext *WorkflowContext) []interface{}
}

* Interface for defining unit of work to be processed by event loop. Classes that implement InterfaceNode can provide their own constructor.

type MockInterfaceNode

type MockInterfaceNode struct {
	// contains filtered or unexported fields
}

MockInterfaceNode is a mock of InterfaceNode interface.

func NewMockInterfaceNode

func NewMockInterfaceNode(ctrl *gomock.Controller) *MockInterfaceNode

NewMockInterfaceNode creates a new mock instance.

func (*MockInterfaceNode) EXPECT

func (m *MockInterfaceNode) EXPECT() *MockInterfaceNodeMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockInterfaceNode) GetPredecessorNodes

func (m *MockInterfaceNode) GetPredecessorNodes(interfaceNode InterfaceNode, workflowContext *WorkflowContext) []InterfaceNode

GetPredecessorNodes mocks base method.

func (*MockInterfaceNode) GetPredecessorNodesResults

func (m *MockInterfaceNode) GetPredecessorNodesResults(interfaceNode InterfaceNode, workflowContext *WorkflowContext) []interface{}

GetPredecessorNodesResults mocks base method.

func (*MockInterfaceNode) GetResult

func (m *MockInterfaceNode) GetResult(interfaceNode InterfaceNode, workflowContext *WorkflowContext) interface{}

GetResult mocks base method.

func (*MockInterfaceNode) Process

func (m *MockInterfaceNode) Process(interfaceNode InterfaceNode, workflowContext *WorkflowContext) error

Process mocks base method.

func (*MockInterfaceNode) ProcessVirt

func (m *MockInterfaceNode) ProcessVirt(workflowContext *WorkflowContext) error

ProcessVirt mocks base method.

func (*MockInterfaceNode) SaveResult

func (m *MockInterfaceNode) SaveResult(interfaceNode InterfaceNode, workflowContext *WorkflowContext, result interface{})

SaveResult mocks base method.

type MockInterfaceNodeMockRecorder

type MockInterfaceNodeMockRecorder struct {
	// contains filtered or unexported fields
}

MockInterfaceNodeMockRecorder is the mock recorder for MockInterfaceNode.

func (*MockInterfaceNodeMockRecorder) GetPredecessorNodes

func (mr *MockInterfaceNodeMockRecorder) GetPredecessorNodes(interfaceNode, workflowContext interface{}) *gomock.Call

GetPredecessorNodes indicates an expected call of GetPredecessorNodes.

func (*MockInterfaceNodeMockRecorder) GetPredecessorNodesResults

func (mr *MockInterfaceNodeMockRecorder) GetPredecessorNodesResults(interfaceNode, workflowContext interface{}) *gomock.Call

GetPredecessorNodesResults indicates an expected call of GetPredecessorNodesResults.

func (*MockInterfaceNodeMockRecorder) GetResult

func (mr *MockInterfaceNodeMockRecorder) GetResult(interfaceNode, workflowContext interface{}) *gomock.Call

GetResult indicates an expected call of GetResult.

func (*MockInterfaceNodeMockRecorder) Process

func (mr *MockInterfaceNodeMockRecorder) Process(interfaceNode, workflowContext interface{}) *gomock.Call

Process indicates an expected call of Process.

func (*MockInterfaceNodeMockRecorder) ProcessVirt

func (mr *MockInterfaceNodeMockRecorder) ProcessVirt(workflowContext interface{}) *gomock.Call

ProcessVirt indicates an expected call of ProcessVirt.

func (*MockInterfaceNodeMockRecorder) SaveResult

func (mr *MockInterfaceNodeMockRecorder) SaveResult(interfaceNode, workflowContext, result interface{}) *gomock.Call

SaveResult indicates an expected call of SaveResult.

type Node

type Node struct {
	Logger *log.Logger
}

* Concrete type for defining unit of work to be processed by event loop.

func (*Node) GetPredecessorNodes

func (node *Node) GetPredecessorNodes(interfaceNode InterfaceNode, workflowContext *WorkflowContext) []InterfaceNode

func (*Node) GetPredecessorNodesResults

func (node *Node) GetPredecessorNodesResults(interfaceNode InterfaceNode, workflowContext *WorkflowContext) []interface{}

func (*Node) GetResult

func (node *Node) GetResult(interfaceNode InterfaceNode, workflowContext *WorkflowContext) interface{}

func (*Node) Process

func (node *Node) Process(interfaceNode InterfaceNode, workflowContext *WorkflowContext) error

func (*Node) SaveResult

func (node *Node) SaveResult(interfaceNode InterfaceNode, workflowContext *WorkflowContext, result interface{})

type WorkflowContext

type WorkflowContext struct {
	EtwEventXml            string
	EtwEvent               utils.EtwEvent
	Query                  string
	QueryIncludesCondition bool
	BookmarkStore          store.PersistentKeyValueStoreInterface
	// contains filtered or unexported fields
}

* Class that stores information about the current state of a running workflow.

func NewWorkflowContext

func NewWorkflowContext() *WorkflowContext

func (*WorkflowContext) GetNodes

func (workflowContext *WorkflowContext) GetNodes() []InterfaceNode

func (*WorkflowContext) SetNodes

func (workflowContext *WorkflowContext) SetNodes(nodes []InterfaceNode)