pipes

Documentation

Index

• Constants
• type CompressGZip
  • func (p *CompressGZip) Convert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)
  • func (p *CompressGZip) Revert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)
• type CompressZLib
  • func (p *CompressZLib) Convert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)
  • func (p *CompressZLib) Revert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)
• type DebugPipe
  • func (p *DebugPipe) Convert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)
  • func (p *DebugPipe) Revert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)
• type DummyPipe
  • func (p *DummyPipe) Convert(in chan goul.Item, message goul.Message) (chan goul.Item, error)
  • func (p *DummyPipe) Revert(in chan goul.Item, message goul.Message) (chan goul.Item, error)

Constants

const (
	CouldNotCreateNewGZipReader = "couldn't create new reader"
)

constants...

const (
	CouldNotCreateNewZLibReader = "couldn't create new reader"
)

constants...

Types

type CompressGZip

type CompressGZip struct {
	goul.Pipe
	ID string
}

CompressGZip is a sample processing pipe that compress the packet with gzip.

func (*CompressGZip) Convert

func (p *CompressGZip) Convert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)

Convert implements interface Pipe/Converter

func (*CompressGZip) Revert

func (p *CompressGZip) Revert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)

Revert implements interface Pipe/Reverter

type CompressZLib

type CompressZLib struct {
	goul.Pipe
	ID string
}

CompressZLib is a sample processing pipe that compress the packet with zlib.

func (*CompressZLib) Convert

func (p *CompressZLib) Convert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)

Convert implements interface Pipe/Converter

func (*CompressZLib) Revert

func (p *CompressZLib) Revert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)

Revert implements interface Pipe/Reverter

type DebugPipe

type DebugPipe struct {
	goul.Pipe
	ID string
}

DebugPipe ...

func (*DebugPipe) Convert

func (p *DebugPipe) Convert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)

Convert implements interface Pipe/Converter

func (*DebugPipe) Revert

func (p *DebugPipe) Revert(in chan goul.Item, message goul.Message) (out chan goul.Item, err error)

Revert implements interface Pipe/Reverter

type DummyPipe

type DummyPipe struct {
	goul.Pipe
	ID string
}

DummyPipe ...

func (*DummyPipe) Convert

func (p *DummyPipe) Convert(in chan goul.Item, message goul.Message) (chan goul.Item, error)

Convert implements interface Pipe/Converter

func (*DummyPipe) Revert

func (p *DummyPipe) Revert(in chan goul.Item, message goul.Message) (chan goul.Item, error)

Revert implements interface Pipe/Reverter