zip

Documentation

Index

• Constants
• type DefaultZipMod
  • func NewDefaultZipMod() *DefaultZipMod
  • func (this *DefaultZipMod) Compress(in []byte) (output []byte, err error)
  • func (this *DefaultZipMod) Decompress(in []byte) ([]byte, error)
  • func (this *DefaultZipMod) ID() byte
• type ZipMod
• type ZipModLoader
  • func NewZipModLoader() *ZipModLoader
• type ZipSendProxyThread
  • func GetInstance() *ZipSendProxyThread
  • func (this *ZipSendProxyThread) Add(p *pack.LogSinkPack)
  • func (this *ZipSendProxyThread) Append(p *pack.LogSinkPack)

Constants

const (
	ZIP_MOD_DEFULAT_GZIP = 1
)

Types

type DefaultZipMod

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

func NewDefaultZipMod

func NewDefaultZipMod() *DefaultZipMod

func (*DefaultZipMod) Compress

func (this *DefaultZipMod) Compress(in []byte) (output []byte, err error)

func (*DefaultZipMod) Decompress

func (this *DefaultZipMod) Decompress(in []byte) ([]byte, error)

func (*DefaultZipMod) ID

func (this *DefaultZipMod) ID() byte

type ZipMod

type ZipMod interface {
	ID() byte
	Compress(b []byte) ([]byte, error)
}

type ZipModLoader

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

func NewZipModLoader

func NewZipModLoader() *ZipModLoader

type ZipSendProxyThread

type ZipSendProxyThread struct {
	Queue *queue.RequestQueue
	// contains filtered or unexported fields
}

func GetInstance

func GetInstance() *ZipSendProxyThread

func (*ZipSendProxyThread) Add

func (this *ZipSendProxyThread) Add(p *pack.LogSinkPack)

func (*ZipSendProxyThread) Append

func (this *ZipSendProxyThread) Append(p *pack.LogSinkPack)