mocks

package
v0.1.21 Latest Latest
Warning

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

 Go to latest Published: Dec 15, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockBranchTracker 

type MockBranchTracker struct {
	mock.Mock
}

func (*MockBranchTracker) AddProcessor 

func (m *MockBranchTracker) AddProcessor(sessionID uuid.UUID, processorID uuid.UUID, nextProcessorIDs []uuid.UUID)

func (*MockBranchTracker) GetBranches 

func (m *MockBranchTracker) GetBranches() []string

func (*MockBranchTracker) GetCompletedProcessors 

func (m *MockBranchTracker) GetCompletedProcessors(sessionID uuid.UUID) []uuid.UUID

func (*MockBranchTracker) IsComplete 

func (m *MockBranchTracker) IsComplete(sessionID uuid.UUID) bool

IsComplete check if all processors in a session are completed

func (*MockBranchTracker) MarkComplete 

func (m *MockBranchTracker) MarkComplete(sessionID uuid.UUID, processorID uuid.UUID) (allComplete bool)

MarkComplete mark the processor as completed

func (*MockBranchTracker) RestoreState 

func (m *MockBranchTracker) RestoreState(sessionID uuid.UUID, completedProcessorIDs []uuid.UUID)

type MockFileHandler 

type MockFileHandler struct {
	mock.Mock
	definitions.EngineFileHandler
}

func (*MockFileHandler) Close 

func (m *MockFileHandler) Close()

func (*MockFileHandler) GenerateNewFileHandler 

func (m *MockFileHandler) GenerateNewFileHandler() (definitions.EngineFileHandler, error)

func (*MockFileHandler) GetInputFile 

func (m *MockFileHandler) GetInputFile() string

func (*MockFileHandler) GetOutputFile 

func (m *MockFileHandler) GetOutputFile() string

func (*MockFileHandler) Read 

func (m *MockFileHandler) Read() (io.Reader, error)

func (*MockFileHandler) Write 

func (m *MockFileHandler) Write() (io.Writer, error)

type MockFlowManager 

type MockFlowManager struct {
	mock.Mock
}

func (*MockFlowManager) AddProcessorToFlowAfter 

func (m *MockFlowManager) AddProcessorToFlowAfter(flowID uuid.UUID, processor *definitions.SimpleProcessor, referenceProcessorID uuid.UUID) error

func (*MockFlowManager) AddProcessorToFlowBefore 

func (m *MockFlowManager) AddProcessorToFlowBefore(flowID uuid.UUID, processor *definitions.SimpleProcessor, referenceProcessorID uuid.UUID) error

func (*MockFlowManager) GetFirstProcessorsForFlow 

func (m *MockFlowManager) GetFirstProcessorsForFlow(flowID uuid.UUID) ([]*definitions.SimpleProcessor, error)

func (*MockFlowManager) GetFlowByID 

func (m *MockFlowManager) GetFlowByID(flowID uuid.UUID) (*definitions.Flow, error)

func (*MockFlowManager) GetFlowProcessors 

func (m *MockFlowManager) GetFlowProcessors(flowID uuid.UUID) ([]*definitions.SimpleProcessor, error)

func (*MockFlowManager) GetLastUpdateTime 

func (m *MockFlowManager) GetLastUpdateTime(flowIDs []uuid.UUID) (map[uuid.UUID]time.Time, error)

func (*MockFlowManager) GetProcessorByID 

func (m *MockFlowManager) GetProcessorByID(flowID uuid.UUID, processorID uuid.UUID) (*definitions.SimpleProcessor, error)

func (*MockFlowManager) GetProcessors 

func (m *MockFlowManager) GetProcessors(processorIDs []uuid.UUID) ([]*definitions.SimpleProcessor, error)

func (*MockFlowManager) GetTriggerProcessorsForFlow 

func (m *MockFlowManager) GetTriggerProcessorsForFlow(flowID uuid.UUID) ([]*definitions.SimpleTriggerProcessor, error)

func (*MockFlowManager) ListFlows 

func (m *MockFlowManager) ListFlows(pagination *definitions.PaginationRequest, since time.Time) (*definitions.PaginatedData[*definitions.Flow], error)

func (*MockFlowManager) SaveFlow 

func (m *MockFlowManager) SaveFlow(flow *definitions.Flow) error

func (*MockFlowManager) SetFlowActive 

func (m *MockFlowManager) SetFlowActive(flowID uuid.UUID, active bool) error

type MockProcessor 

type MockProcessor struct {
	mock.Mock
	definitions.Processor
	definitions.TriggerProcessor
}

MockProcessor is an autogenerated mock type for the Processor type it covers both the Processor and TriggerProcessor interfaces

func (*MockProcessor) Close 

func (m *MockProcessor) Close() error

func (*MockProcessor) Execute 

func (m *MockProcessor) Execute(info *definitions.EngineFlowObject,
	fileHandler definitions.ProcessorFileHandler, log *logrus.Logger) (*definitions.EngineFlowObject, error)

func (*MockProcessor) GetScheduleType 

func (m *MockProcessor) GetScheduleType() definitions.ScheduleType

func (*MockProcessor) HandleSessionUpdate 

func (m *MockProcessor) HandleSessionUpdate(update definitions.SessionUpdate)

func (*MockProcessor) Name 

func (m *MockProcessor) Name() string

func (*MockProcessor) SetConfig 

func (m *MockProcessor) SetConfig(config map[string]interface{}) error

type MockProcessorFactory 

type MockProcessorFactory struct {
	mock.Mock
}

func (*MockProcessorFactory) GetProcessor 

func (m *MockProcessorFactory) GetProcessor(id uuid.UUID, typeName string) (definitions.Processor, error)

func (*MockProcessorFactory) GetTriggerProcessor 

func (m *MockProcessorFactory) GetTriggerProcessor(id uuid.UUID, typeName string) (definitions.TriggerProcessor, error)

type MockWriteAheadLogger 

type MockWriteAheadLogger struct {
	mock.Mock
}

func (*MockWriteAheadLogger) ReadEntries 

func (m *MockWriteAheadLogger) ReadEntries() ([]definitions.LogEntry, error)

func (*MockWriteAheadLogger) ReadLastEntries 

func (m *MockWriteAheadLogger) ReadLastEntries() ([]definitions.LogEntry, error)

func (*MockWriteAheadLogger) WriteEntry 

func (m *MockWriteAheadLogger) WriteEntry(entry definitions.LogEntry)

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.