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(opts ...ZipSendProxyThreadOption) *ZipSendProxyThread
  • func (this *ZipSendProxyThread) Add(p *pack.LogSinkPack)
  • func (this *ZipSendProxyThread) Append(p *pack.LogSinkPack)
  • func (this *ZipSendProxyThread) ApplyConfig(conf config.Config)
  • func (this *ZipSendProxyThread) SendDirect(arr []*pack.LogSinkPack)
  • func (this *ZipSendProxyThread) SetTcpClient(c wnet.TcpClient)
• type ZipSendProxyThreadOption
  • func WithConfigObserver(obj *config.ConfigObserver) ZipSendProxyThreadOption
  • func WithContext(ctx context.Context, cancel context.CancelFunc) ZipSendProxyThreadOption
  • func WithLogger(logger logger.Logger) ZipSendProxyThreadOption
  • func WithTcpClient(tcpClient wnet.TcpClient) ZipSendProxyThreadOption
  • func WithUseQueue() ZipSendProxyThreadOption

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 {
	Log logger.Logger

	Queue *queue.RequestQueue
	// contains filtered or unexported fields
}

func GetInstance

func GetInstance(opts ...ZipSendProxyThreadOption) *ZipSendProxyThread

func (*ZipSendProxyThread) Add

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

func (*ZipSendProxyThread) Append

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

func (*ZipSendProxyThread) ApplyConfig

func (this *ZipSendProxyThread) ApplyConfig(conf config.Config)

implements config.ConfigObserver

func (*ZipSendProxyThread) SendDirect

func (this *ZipSendProxyThread) SendDirect(arr []*pack.LogSinkPack)

func (*ZipSendProxyThread) SetTcpClient

func (this *ZipSendProxyThread) SetTcpClient(c wnet.TcpClient)

set tcp channel to write

type ZipSendProxyThreadOption

type ZipSendProxyThreadOption interface {
	// contains filtered or unexported methods
}

func WithConfigObserver

func WithConfigObserver(obj *config.ConfigObserver) ZipSendProxyThreadOption

func WithContext

func WithContext(ctx context.Context, cancel context.CancelFunc) ZipSendProxyThreadOption

func WithLogger

func WithLogger(logger logger.Logger) ZipSendProxyThreadOption

func WithTcpClient

func WithTcpClient(tcpClient wnet.TcpClient) ZipSendProxyThreadOption

func WithUseQueue

func WithUseQueue() ZipSendProxyThreadOption