messageprocessors

Documentation

Index

• type ExecuteStepProcessor
  • func (r *ExecuteStepProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type ExecutionEndingProcessor
  • func (r *ExecutionEndingProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type ExecutionStartingRequestProcessor
  • func (r *ExecutionStartingRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type MessageProcessor
• type ProcessorDictionary
• type ScenarioDataStoreInitProcessor
  • func (r *ScenarioDataStoreInitProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type ScenarioExecutionEndingProcessor
  • func (r *ScenarioExecutionEndingProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type ScenarioExecutionStartingRequestProcessor
  • func (r *ScenarioExecutionStartingRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type SpecDataStoreInitProcessor
  • func (r *SpecDataStoreInitProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type SpecExecutionEndingProcessor
  • func (r *SpecExecutionEndingProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type SpecExecutionStartingRequestProcessor
  • func (r *SpecExecutionStartingRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type StepExecutionEndingProcessor
  • func (r *StepExecutionEndingProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type StepExecutionStartingRequestProcessor
  • func (r *StepExecutionStartingRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type StepNamesRequestProcessor
  • func (s *StepNamesRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message
• type StepValidateRequestProcessor
  • func (s *StepValidateRequestProcessor) Process(msg *gm.Message, context *t.GaugeContext) *gm.Message
• type SuiteDataStoreInitRequestProcessor
  • func (s *SuiteDataStoreInitRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

Types

type ExecuteStepProcessor

type ExecuteStepProcessor struct{}

func (*ExecuteStepProcessor) Process

func (r *ExecuteStepProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type ExecutionEndingProcessor

type ExecutionEndingProcessor struct{}

func (*ExecutionEndingProcessor) Process

func (r *ExecutionEndingProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type ExecutionStartingRequestProcessor

type ExecutionStartingRequestProcessor struct{}

func (*ExecutionStartingRequestProcessor) Process

func (r *ExecutionStartingRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type MessageProcessor

type MessageProcessor interface {
	Process(*m.Message, *t.GaugeContext) *m.Message
}

type ProcessorDictionary

type ProcessorDictionary map[m.Message_MessageType]MessageProcessor

type ScenarioDataStoreInitProcessor

type ScenarioDataStoreInitProcessor struct{}

func (*ScenarioDataStoreInitProcessor) Process

func (r *ScenarioDataStoreInitProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type ScenarioExecutionEndingProcessor

type ScenarioExecutionEndingProcessor struct{}

func (*ScenarioExecutionEndingProcessor) Process

func (r *ScenarioExecutionEndingProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type ScenarioExecutionStartingRequestProcessor

type ScenarioExecutionStartingRequestProcessor struct{}

func (*ScenarioExecutionStartingRequestProcessor) Process

func (r *ScenarioExecutionStartingRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type SpecDataStoreInitProcessor

type SpecDataStoreInitProcessor struct{}

func (*SpecDataStoreInitProcessor) Process

func (r *SpecDataStoreInitProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type SpecExecutionEndingProcessor

type SpecExecutionEndingProcessor struct{}

func (*SpecExecutionEndingProcessor) Process

func (r *SpecExecutionEndingProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type SpecExecutionStartingRequestProcessor

type SpecExecutionStartingRequestProcessor struct{}

func (*SpecExecutionStartingRequestProcessor) Process

func (r *SpecExecutionStartingRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type StepExecutionEndingProcessor

type StepExecutionEndingProcessor struct{}

func (*StepExecutionEndingProcessor) Process

func (r *StepExecutionEndingProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type StepExecutionStartingRequestProcessor

type StepExecutionStartingRequestProcessor struct{}

func (*StepExecutionStartingRequestProcessor) Process

func (r *StepExecutionStartingRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type StepNamesRequestProcessor

type StepNamesRequestProcessor struct{}

func (*StepNamesRequestProcessor) Process

func (s *StepNamesRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message

type StepValidateRequestProcessor

type StepValidateRequestProcessor struct{}

func (*StepValidateRequestProcessor) Process

func (s *StepValidateRequestProcessor) Process(msg *gm.Message, context *t.GaugeContext) *gm.Message

type SuiteDataStoreInitRequestProcessor

type SuiteDataStoreInitRequestProcessor struct{}

func (*SuiteDataStoreInitRequestProcessor) Process

func (s *SuiteDataStoreInitRequestProcessor) Process(msg *m.Message, context *t.GaugeContext) *m.Message