trans

Documentation

Index

• Constants
• Variables
• func EscapeLimitJSONBytes(bytes []byte, capacity int) []byte
• func SetTransStatisticDuration(d time.Duration)
• type ConsoleTransfer
  • func (d *ConsoleTransfer) Name() string
  • func (d *ConsoleTransfer) Start() error
  • func (d *ConsoleTransfer) Stop() error
  • func (d *ConsoleTransfer) Trans(source string, data ...[]byte) error
  • func (d *ConsoleTransfer) Visit(t Transfer)
• type Counter
  • func (c *Counter) CountIncr()
  • func (c *Counter) CountReset() string
  • func (c *Counter) CountStat() (string, bool)
• type DingTransfer
  • func NewDingTransfer(id, url, prefix string) *DingTransfer
  • func (d *DingTransfer) Name() string
  • func (d *DingTransfer) Start() error
  • func (d *DingTransfer) Stop() error
  • func (d *DingTransfer) Trans(source string, data ...[]byte) error
• type FileTransfer
  • func NewFileTransfer(id, dir string) *FileTransfer
  • func (ft *FileTransfer) Name() string
  • func (ft *FileTransfer) Start() error
  • func (ft *FileTransfer) Stop() error
  • func (ft *FileTransfer) Trans(source string, data ...[]byte) error
• type LarkTransfer
  • func NewLarkTransfer(id, url, prefix string) *LarkTransfer
  • func (d *LarkTransfer) Name() string
  • func (d *LarkTransfer) Start() error
  • func (d *LarkTransfer) Stop() error
  • func (d *LarkTransfer) Trans(source string, data ...[]byte) error
• type NullTransfer
  • func (d *NullTransfer) Name() string
  • func (d *NullTransfer) Start() error
  • func (d *NullTransfer) Stop() error
  • func (d *NullTransfer) Trans(source string, data ...[]byte) error
• type Transfer
• type TransferMatcher
• type WebhookTransfer
  • func NewWebhookTransfer(id, url, prefix string) *WebhookTransfer
  • func (d *WebhookTransfer) Name() string
  • func (d *WebhookTransfer) Start() error
  • func (d *WebhookTransfer) Stop() error
  • func (d *WebhookTransfer) Trans(_ string, data ...[]byte) error

Constants

const DefaultChannelBufferSize = 16

const DefaultTransferPrefix = "logtail-"

const DoubleSize = 2

const TransferFileSize = 1024 * 1024 * 8

TransferFileSize 8 MB for each transfer file.

const TypeConsole = "console"

const TypeDing = "ding"

const TypeFile = "file"

const TypeLark = "lark"

TypeLark transfer type lark.

const TypeNull = "null"

const TypeWebhook = "webhook"

Variables

var ErrHTTPStatusNonOK = errors.New("http status non ok")

var Types = []string{TypeNull, TypeConsole, TypeFile, TypeWebhook, TypeDing, TypeLark}

Types all transfer types.

Functions

func EscapeLimitJSONBytes

func EscapeLimitJSONBytes(bytes []byte, capacity int) []byte

func SetTransStatisticDuration

func SetTransStatisticDuration(d time.Duration)

Types

type ConsoleTransfer

type ConsoleTransfer struct {
	ID string
}

func (*ConsoleTransfer) Name

func (d *ConsoleTransfer) Name() string

func (*ConsoleTransfer) Start

func (d *ConsoleTransfer) Start() error

func (*ConsoleTransfer) Stop

func (d *ConsoleTransfer) Stop() error

func (*ConsoleTransfer) Trans

func (d *ConsoleTransfer) Trans(source string, data ...[]byte) error

func (*ConsoleTransfer) Visit

func (d *ConsoleTransfer) Visit(t Transfer)

type Counter

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

Counter is a utility to count the count of transfer times.

func (*Counter) CountIncr

func (c *Counter) CountIncr()

CountIncr increase the counter.

func (*Counter) CountReset

func (c *Counter) CountReset() string

CountReset reset the counter and return the statistic message.

func (*Counter) CountStat

func (c *Counter) CountStat() (string, bool)

CountStat return statistic message if exceeding the end of the time range.

type DingTransfer

type DingTransfer struct {
	Counter
	// contains filtered or unexported fields
}

func NewDingTransfer

func NewDingTransfer(id, url, prefix string) *DingTransfer

NewDingTransfer new dingding trans.

func (*DingTransfer) Name

func (d *DingTransfer) Name() string

func (*DingTransfer) Start

func (d *DingTransfer) Start() error

func (*DingTransfer) Stop

func (d *DingTransfer) Stop() error

func (*DingTransfer) Trans

func (d *DingTransfer) Trans(source string, data ...[]byte) error

Trans transfer data to dingding.

type FileTransfer

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

func NewFileTransfer

func NewFileTransfer(id, dir string) *FileTransfer

NewFileTransfer new file trans.

func (*FileTransfer) Name

func (ft *FileTransfer) Name() string

func (*FileTransfer) Start

func (ft *FileTransfer) Start() error

func (*FileTransfer) Stop

func (ft *FileTransfer) Stop() error

func (*FileTransfer) Trans

func (ft *FileTransfer) Trans(source string, data ...[]byte) error

type LarkTransfer

type LarkTransfer struct {
	Counter
	// contains filtered or unexported fields
}

LarkTransfer transfer to support lark.

func NewLarkTransfer

func NewLarkTransfer(id, url, prefix string) *LarkTransfer

NewLarkTransfer initialize a lark trans.

func (*LarkTransfer) Name

func (d *LarkTransfer) Name() string

func (*LarkTransfer) Start

func (d *LarkTransfer) Start() error

func (*LarkTransfer) Stop

func (d *LarkTransfer) Stop() error

func (*LarkTransfer) Trans

func (d *LarkTransfer) Trans(source string, data ...[]byte) error

Trans transfer data to Lark.

type NullTransfer

type NullTransfer struct {
	ID string
}

func (*NullTransfer) Name

func (d *NullTransfer) Name() string

func (*NullTransfer) Start

func (d *NullTransfer) Start() error

func (*NullTransfer) Stop

func (d *NullTransfer) Stop() error

func (*NullTransfer) Trans

func (d *NullTransfer) Trans(source string, data ...[]byte) error

type Transfer

type Transfer interface {
	Name() string
	Trans(source string, data ...[]byte) error
	Start() error
	Stop() error
}

type TransferMatcher

type TransferMatcher func(ids []string) []Transfer

type WebhookTransfer

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

func NewWebhookTransfer

func NewWebhookTransfer(id, url, prefix string) *WebhookTransfer

NewWebhookTransfer new webhook trans.

func (*WebhookTransfer) Name

func (d *WebhookTransfer) Name() string

func (*WebhookTransfer) Start

func (d *WebhookTransfer) Start() error

func (*WebhookTransfer) Stop

func (d *WebhookTransfer) Stop() error

func (*WebhookTransfer) Trans

func (d *WebhookTransfer) Trans(_ string, data ...[]byte) error