ali

Documentation

Index

• func NewCore(ops ...Option) (zapcore.Core, func() error)
• func NewMapObjEncoder(cfg zapcore.EncoderConfig) *mapObjEncoder
• 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 Option
  • func WithAccessKeyID(akID string) Option
  • func WithAccessKeySecret(akSecret string) Option
  • func WithApiBulkSize(apiBulkSize 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 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 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.

func NewMapObjEncoder

func NewMapObjEncoder(cfg zapcore.EncoderConfig) *mapObjEncoder

Types

type LogContent

type LogContent = pb.Log_Content

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 Option

type Option func(c *config)

func WithAccessKeyID

func WithAccessKeyID(akID string) Option

func WithAccessKeySecret

func WithAccessKeySecret(akSecret string) Option

func WithApiBulkSize

func WithApiBulkSize(apiBulkSize int) Option

func WithApiRetryCount

func WithApiRetryCount(apiRetryCount int) Option

func WithApiRetryMaxWaitTime

func WithApiRetryMaxWaitTime(apiRetryMaxWaitTime time.Duration) Option

func WithApiRetryWaitTime

func WithApiRetryWaitTime(apiRetryWaitTime time.Duration) Option

func WithApiTimeout

func WithApiTimeout(apiTimeout time.Duration) Option

func WithEncoder

func WithEncoder(enc zapcore.Encoder) Option

func WithEndpoint

func WithEndpoint(endpoint string) Option

func WithFallbackCore

func WithFallbackCore(core zapcore.Core) Option

func WithFlushBufferInterval

func WithFlushBufferInterval(flushBufferInterval time.Duration) Option

func WithFlushBufferSize

func WithFlushBufferSize(flushBufferSize int) Option

func WithLevelEnabler

func WithLevelEnabler(lv zapcore.LevelEnabler) Option

func WithLogstore

func WithLogstore(logStore string) Option

func WithProject

func WithProject(project string) Option