ali

Documentation

Index

• func NewCore(ops ...Option) (zapcore.Core, func() error)
• type LogContent
• type LogProject
  • func (p *LogProject) GetLogStore(name string) (s *LogStore, err error)
  • func (p *LogProject) ListLogStore() (storeNames []string, err error)
• type LogStore
  • func (s *LogStore) PutLogs(lg *pb.LogGroup) (err error)
• type MapObjEncoder
  • func NewMapObjEncoder(cfg zapcore.EncoderConfig) *MapObjEncoder
  • func (e *MapObjEncoder) Clone() zapcore.Encoder
  • func (e *MapObjEncoder) EncodeEntry(ent zapcore.Entry, fields []zapcore.Field) (*buffer.Buffer, error)
• type Option
  • func WithAPIBulkSize(apiBulkSize int) Option
  • func WithAPIIdleConnTimeout(apiIdleConnTimeout time.Duration) Option
  • func WithAPIMaxIdleConns(apiMaxIdleConns int) Option
  • func WithAPIMaxIdleConnsPerHost(apiMaxIdleConnsPerHost int) Option
  • func WithAPIRetryCount(apiRetryCount int) Option
  • func WithAPIRetryMaxWaitTime(apiRetryMaxWaitTime time.Duration) Option
  • func WithAPIRetryWaitTime(apiRetryWaitTime time.Duration) Option
  • func WithAPITimeout(apiTimeout time.Duration) Option
  • func WithAccessKeyID(akID string) Option
  • func WithAccessKeySecret(akSecret string) Option
  • func WithEncoder(enc zapcore.Encoder) Option
  • func WithEndpoint(endpoint string) Option
  • func WithFallbackCore(core zapcore.Core) Option
  • func WithFlushBufferInterval(flushBufferInterval time.Duration) Option
  • func WithFlushBufferSize(flushBufferSize int) Option
  • func WithLevelEnabler(lv zapcore.LevelEnabler) Option
  • func WithLogstore(logStore string) Option
  • func WithMaxQueueSize(maxQueueSize int) Option
  • func WithProject(project string) Option

Functions

func NewCore

func NewCore(ops ...Option) (zapcore.Core, func() error)

NewCore creates a Core that writes logs to a WriteSyncer.

Types

type LogContent

type LogContent = pb.Log_Content

LogContent ...

type LogProject

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

LogProject defines the Ali project detail

func (*LogProject) GetLogStore

func (p *LogProject) GetLogStore(name string) (s *LogStore, err error)

GetLogStore returns logstore according by logstore name.

func (*LogProject) ListLogStore

func (p *LogProject) ListLogStore() (storeNames []string, err error)

ListLogStore returns all logstore names of project p.

type LogStore

type LogStore struct {
	Name           string `json:"logstoreName"`
	TTL            int
	ShardCount     int
	CreateTime     uint32
	LastModifyTime uint32
	// contains filtered or unexported fields
}

LogStore stores the logs

func (*LogStore) PutLogs

func (s *LogStore) PutLogs(lg *pb.LogGroup) (err error)

PutLogs puts logs into logstore. The callers should transform user logs into LogGroup.

type MapObjEncoder

type MapObjEncoder struct {
	*zapcore.EncoderConfig

	*zapcore.MapObjectEncoder
	// contains filtered or unexported fields
}

MapObjEncoder ...

func NewMapObjEncoder

func NewMapObjEncoder(cfg zapcore.EncoderConfig) *MapObjEncoder

NewMapObjEncoder ...

func (*MapObjEncoder) Clone

func (e *MapObjEncoder) Clone() zapcore.Encoder

Clone ...

func (*MapObjEncoder) EncodeEntry

func (e *MapObjEncoder) EncodeEntry(ent zapcore.Entry, fields []zapcore.Field) (*buffer.Buffer, error)

EncodeEntry ...

type Option

type Option func(c *config)

Option 可选项

func WithAPIBulkSize

func WithAPIBulkSize(apiBulkSize int) Option

WithAPIBulkSize ...

func WithAPIIdleConnTimeout

func WithAPIIdleConnTimeout(apiIdleConnTimeout time.Duration) Option

WithAPIIdleConnTimeout ...

func WithAPIMaxIdleConns

func WithAPIMaxIdleConns(apiMaxIdleConns int) Option

WithAPIMaxIdleConns ...

func WithAPIMaxIdleConnsPerHost

func WithAPIMaxIdleConnsPerHost(apiMaxIdleConnsPerHost int) Option

WithAPIMaxIdleConnsPerHost ...

func WithAPIRetryCount

func WithAPIRetryCount(apiRetryCount int) Option

WithAPIRetryCount ...

func WithAPIRetryMaxWaitTime

func WithAPIRetryMaxWaitTime(apiRetryMaxWaitTime time.Duration) Option

WithAPIRetryMaxWaitTime ...

func WithAPIRetryWaitTime

func WithAPIRetryWaitTime(apiRetryWaitTime time.Duration) Option

WithAPIRetryWaitTime ...

func WithAPITimeout

func WithAPITimeout(apiTimeout time.Duration) Option

WithAPITimeout ...

func WithAccessKeyID

func WithAccessKeyID(akID string) Option

WithAccessKeyID ...

func WithAccessKeySecret

func WithAccessKeySecret(akSecret string) Option

WithAccessKeySecret ....

func WithEncoder

func WithEncoder(enc zapcore.Encoder) Option

WithEncoder ...

func WithEndpoint

func WithEndpoint(endpoint string) Option

WithEndpoint ...

func WithFallbackCore

func WithFallbackCore(core zapcore.Core) Option

WithFallbackCore ...

func WithFlushBufferInterval

func WithFlushBufferInterval(flushBufferInterval time.Duration) Option

WithFlushBufferInterval ...

func WithFlushBufferSize

func WithFlushBufferSize(flushBufferSize int) Option

WithFlushBufferSize ...

func WithLevelEnabler

func WithLevelEnabler(lv zapcore.LevelEnabler) Option

WithLevelEnabler ...

func WithLogstore

func WithLogstore(logStore string) Option

WithLogstore ...

func WithMaxQueueSize

func WithMaxQueueSize(maxQueueSize int) Option

WithMaxQueueSize ...

func WithProject

func WithProject(project string) Option

WithProject ...