sls

Documentation

Index

• Variables
• type Account
• type ConsumeFunc
• type Consumer
  • func (c *Consumer) Close() error
  • func (c *Consumer) Start() error
• type ConsumerManager
  • func (cm *ConsumerManager) Close() error
  • func (cm *ConsumerManager) Patch(account *Account)
  • func (cm *ConsumerManager) Start(ctx context.Context) error
• type LogStore
• type Processor

Variables

var Endpoints = []string{
	"cn-hangzhou.log.aliyuncs.com",
	"cn-hangzhou-finance.log.aliyuncs.com",
	"cn-shanghai.log.aliyuncs.com",
	"cn-shanghai-finance-1.log.aliyuncs.com",
	"cn-qingdao.log.aliyuncs.com",
	"cn-beijing.log.aliyuncs.com",
	"cn-zhangjiakou.log.aliyuncs.com",
	"cn-huhehaote.log.aliyuncs.com",
	"cn-shenzhen.log.aliyuncs.com",
	"cn-shenzhen-finance.log.aliyuncs.com",
	"cn-chengdu.log.aliyuncs.com",
	"cn-hongkong.log.aliyuncs.com",
	"ap-northeast-1.log.aliyuncs.com",
	"ap-southeast-1.log.aliyuncs.com",
	"ap-southeast-2.log.aliyuncs.com",
	"ap-southeast-3.log.aliyuncs.com",
	"ap-southeast-5.log.aliyuncs.com",
	"me-east-1.log.aliyuncs.com",
	"us-west-1.log.aliyuncs.com",
	"eu-central-1.log.aliyuncs.com",
	"us-east-1.log.aliyuncs.com",
	"ap-south-1.log.aliyuncs.com",
	"eu-west-1.log.aliyuncs.com",
}

Endpoints sls endpoints

Types

type Account

type Account struct {
	Group           string            `file:"comsume_group"`
	AccessKey       string            `file:"ali_access_key"`
	AccessSecretKey string            `file:"ali_access_secret_key"`
	Endpoints       []string          `file:"endpoints"`
	Tags            map[string]string `file:"tags"`
}

Account .

type ConsumeFunc

type ConsumeFunc func(shardID int, groups *sls.LogGroupList) string

ConsumeFunc .

type Consumer

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

Consumer .

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Start

func (c *Consumer) Start() error

type ConsumerManager

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

ConsumerManager .

func (*ConsumerManager) Close

func (cm *ConsumerManager) Close() error

Close .

func (*ConsumerManager) Patch

func (cm *ConsumerManager) Patch(account *Account)

func (*ConsumerManager) Start

func (cm *ConsumerManager) Start(ctx context.Context) error

Start .

type LogStore

type LogStore struct {
	Project string `file:"project"`
	Store   string `file:"store"`
	Type    string `file:"type"`
}

LogStore .

type Processor

type Processor interface {
	MatchProject(project string) bool
	MatchStore(project, store string) *LogStore
	GetHandler(project, store, typ string, account *Account) ConsumeFunc
}

Processor .