replay

Documentation

Index

• func New(c *config.Config) (pipeline.Processor, error)
• func ReplayLines(req *fasthttp.Request, res *fasthttp.Response, ctx *pipeline.Context, ...) (int, error, bool)
• type Config
• type ReplayProcessor
  • func (processor *ReplayProcessor) Name() string
  • func (processor *ReplayProcessor) Process(ctx *pipeline.Context) error
  • func (processor ReplayProcessor) Stop() error

Functions

func New

func New(c *config.Config) (pipeline.Processor, error)

func ReplayLines

func ReplayLines(req *fasthttp.Request, res *fasthttp.Response, ctx *pipeline.Context, lines []string, schema, host, username, password string) (int, error, bool)

Types

type Config

type Config struct {
	Schema string `config:"schema"`
	Host   string `config:"host"`

	Filename   string `config:"filename"`
	InputQueue string `config:"input_queue"`
	Username   string `config:"username"`
	Password   string `config:"password"`
}

type ReplayProcessor

type ReplayProcessor struct {
	HTTPPool *fasthttp.RequestResponsePool
	// contains filtered or unexported fields
}

func (*ReplayProcessor) Name

func (processor *ReplayProcessor) Name() string

func (*ReplayProcessor) Process

func (processor *ReplayProcessor) Process(ctx *pipeline.Context) error

func (ReplayProcessor) Stop

func (processor ReplayProcessor) Stop() error