policies

Documentation

Index

• func NoDeflate(d DEFLATE, data []byte) []byte
• func STDDeflate(d DEFLATE, data []byte) []byte
• type DEFLATE
• type DefaultPostingPolicy
  • func (d DefaultPostingPolicy) Decide(groups [][]byte, lines, length int64) PostingDecision
• type DeflateFunction
  • func NewDeflateFunction(level int) DeflateFunction
  • func (d DeflateFunction) Def() DeflateFunction
• type PostingDecision
• type PostingPolicy
  • func Def(p PostingPolicy) PostingPolicy

Functions

func NoDeflate

func NoDeflate(d DEFLATE, data []byte) []byte

func STDDeflate

func STDDeflate(d DEFLATE, data []byte) []byte

Types

type DEFLATE

type DEFLATE struct{}

type DefaultPostingPolicy

type DefaultPostingPolicy struct{}

func (DefaultPostingPolicy) Decide

func (d DefaultPostingPolicy) Decide(groups [][]byte, lines, length int64) PostingDecision

type DeflateFunction

type DeflateFunction func(d DEFLATE, data []byte) []byte

func NewDeflateFunction

func NewDeflateFunction(level int) DeflateFunction

func (DeflateFunction) Def

func (d DeflateFunction) Def() DeflateFunction

type PostingDecision

type PostingDecision struct {
	ExpireAt       time.Time
	CompressXover  DeflateFunction
	CompressHeader DeflateFunction
	CompressBody   DeflateFunction
}

type PostingPolicy

type PostingPolicy interface {
	Decide(groups [][]byte, lines, length int64) PostingDecision
}

func Def

func Def(p PostingPolicy) PostingPolicy