sink

package
v1.0.13 Latest Latest
Warning

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

Go to latest
Published: Jan 5, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	FileName = "sink.file"
)
View Source
const (
	HTTPName = "sink.http"
)

Variables

This section is empty.

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) Children

func (m *File) Children() [][]mirror.Module

func (*File) Context

func (m *File) Context() *mirror.ModuleContext

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) Children

func (m *HTTP) Children() [][]mirror.Module

func (*HTTP) Context

func (m *HTTP) Context() *mirror.ModuleContext

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 {
	FollowRedirects bool             `json:"follow_redirects,omitempty"`
	TargetURL       *expr.StringExpr `json:"target_url,omitempty"`
	Timeout         string           `json:"timeout,omitempty"`
	Parallel        int              `json:"parallel"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL