sink

Documentation

Index

• Constants
• func NewFile(ctx mirror.ModuleContext, cfg []byte) (mirror.Module, error)
• func NewHTTP(ctx mirror.ModuleContext, cfg []byte) (mirror.Module, error)
• type File
  • func (m *File) Output() <-chan mirror.Request
  • func (m *File) SetInput(c <-chan mirror.Request)
• type FileConfig
• type HTTP
  • func (m *HTTP) Output() <-chan mirror.Request
  • func (m *HTTP) SetInput(c <-chan mirror.Request)
• type HTTPConfig

Constants

const (
	FileName = "sink.file"
)

const (
	HTTPName = "sink.http"
)

Functions

func NewFile

func NewFile(ctx mirror.ModuleContext, cfg []byte) (mirror.Module, error)

func NewHTTP

func NewHTTP(ctx mirror.ModuleContext, cfg []byte) (mirror.Module, error)

Types

type File

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

func (*File) Output

func (m *File) Output() <-chan mirror.Request

func (*File) SetInput

func (m *File) SetInput(c <-chan mirror.Request)

type FileConfig

type FileConfig struct {
	Path       *expr.StringExpr `json:"path,omitempty"`
	Format     string           `json:"format,omitempty"`
	BufferSize int              `json:"buffer_size,omitempty"`
}

type HTTP

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

func (*HTTP) Output

func (m *HTTP) Output() <-chan mirror.Request

func (*HTTP) SetInput

func (m *HTTP) SetInput(c <-chan mirror.Request)

type HTTPConfig

type HTTPConfig struct {
	TargetURL string `json:"target_url,omitempty"`
	Timeout   string `json:"timeout,omitempty"`
	Parallel  int    `json:"parallel"`
}