test

Documentation

Index

• type Double
  • func (this *Double) Init(parentCtx context.Context, params map[string]interface{}) error
  • func (this *Double) Process(ctx context.Context, args map[string]interface{}) (map[string]interface{}, error)
• type MockedConfigManager
  • func (this *MockedConfigManager) GetConfig(configKey string) (*libdag.DagConfig, error)
• type MockedHandlerManager
  • func (this *MockedHandlerManager) CreateHandler(handlerName string) (libdag.DagNodeHandler, error)
• type MockedLoader
  • func (this *MockedLoader) LoadConfigData(configKey string) ([]byte, error)

Types

type Double

type Double struct {
}

func (*Double) Init

func (this *Double) Init(parentCtx context.Context, params map[string]interface{}) error

func (*Double) Process

func (this *Double) Process(ctx context.Context, args map[string]interface{}) (map[string]interface{}, error)

type MockedConfigManager

type MockedConfigManager struct {
	libdag.ConfigManager
}

func (*MockedConfigManager) GetConfig

func (this *MockedConfigManager) GetConfig(configKey string) (*libdag.DagConfig, error)

type MockedHandlerManager

type MockedHandlerManager struct {
	libdag.HandlerManager
}

func (*MockedHandlerManager) CreateHandler

func (this *MockedHandlerManager) CreateHandler(handlerName string) (libdag.DagNodeHandler, error)

type MockedLoader

type MockedLoader struct {
	ConfigPath string
}

func (*MockedLoader) LoadConfigData

func (this *MockedLoader) LoadConfigData(configKey string) ([]byte, error)