alils

Nov 2, 2019

Changes in this version

+ const CacheSize

+ const Delimiter

+ const OffsetNewest

+ const OffsetOldest

+ var ErrIntOverflowLog = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthLog = fmt.Errorf("proto: negative length found during unmarshaling")

+ func NewAliLS() logs.Logger

+ type Config struct

+ Endpoint string

+ FlushWhen int

+ KeyID string

+ KeySecret string

+ Level int

+ LogStore string

+ Project string

+ Source string

+ Topics []string

+ type InputDetail struct

+ FilePattern string

+ FilterKeys []string

+ FilterRegex []string

+ Keys []string

+ LocalStorage bool

+ LogBeginRegex string

+ LogPath string

+ LogType string

+ Regex string

+ TimeFormat string

+ TopicFormat string

+ type Log struct

+ Contents []*LogContent

+ Time *uint32

+ XXXUnrecognized []byte

+ func (*Log) ProtoMessage()

+ func (m *Log) GetContents() []*LogContent

+ func (m *Log) GetTime() uint32

+ func (m *Log) Marshal() (data []byte, err error)

+ func (m *Log) MarshalTo(data []byte) (int, error)

+ func (m *Log) Reset()

+ func (m *Log) Size() (n int)

+ func (m *Log) String() string

+ func (m *Log) Unmarshal(data []byte) error

+ type LogConfig struct

+ CreateTime uint32

+ InputDetail InputDetail

+ InputType string

+ LastModifyTime uint32

+ Name string

+ OutputDetail OutputDetail

+ OutputType string

+ func (c *LogConfig) GetAppliedMachineGroup(confName string) (groupNames []string, err error)

+ type LogContent struct

+ Key *string

+ Value *string

+ XXXUnrecognized []byte

+ func (*LogContent) ProtoMessage()

+ func (m *LogContent) GetKey() string

+ func (m *LogContent) GetValue() string

+ func (m *LogContent) Marshal() (data []byte, err error)

+ func (m *LogContent) MarshalTo(data []byte) (int, error)

+ func (m *LogContent) Reset()

+ func (m *LogContent) Size() (n int)

+ func (m *LogContent) String() string

+ func (m *LogContent) Unmarshal(data []byte) error

+ type LogGroup struct

+ Logs []*Log

+ Reserved *string

+ Source *string

+ Topic *string

+ XXXUnrecognized []byte

+ func (*LogGroup) ProtoMessage()

+ func (m *LogGroup) GetLogs() []*Log

+ func (m *LogGroup) GetReserved() string

+ func (m *LogGroup) GetSource() string

+ func (m *LogGroup) GetTopic() string

+ func (m *LogGroup) Marshal() (data []byte, err error)

+ func (m *LogGroup) MarshalTo(data []byte) (int, error)

+ func (m *LogGroup) Reset()

+ func (m *LogGroup) Size() (n int)

+ func (m *LogGroup) String() string

+ func (m *LogGroup) Unmarshal(data []byte) error

+ type LogGroupList struct

+ LogGroups []*LogGroup

+ XXXUnrecognized []byte

+ func LogsBytesDecode(data []byte) (gl *LogGroupList, err error)

+ func (*LogGroupList) ProtoMessage()

+ func (m *LogGroupList) GetLogGroups() []*LogGroup

+ func (m *LogGroupList) Marshal() (data []byte, err error)

+ func (m *LogGroupList) MarshalTo(data []byte) (int, error)

+ func (m *LogGroupList) Reset()

+ func (m *LogGroupList) Size() (n int)

+ func (m *LogGroupList) String() string

+ func (m *LogGroupList) Unmarshal(data []byte) error

+ type LogProject struct

+ AccessKeyID string

+ AccessKeySecret string

+ Endpoint string

+ Name string

+ func NewLogProject(name, endpoint, AccessKeyID, accessKeySecret string) (p *LogProject, err error)

+ func (p *LogProject) ApplyConfigToMachineGroup(confName, groupName string) (err error)

+ func (p *LogProject) CreateConfig(c *LogConfig) (err error)

+ func (p *LogProject) CreateLogStore(name string, ttl, shardCnt int) (err error)

+ func (p *LogProject) CreateMachineGroup(m *MachineGroup) (err error)

+ func (p *LogProject) DeleteConfig(name string) (err error)

+ func (p *LogProject) DeleteLogStore(name string) (err error)

+ func (p *LogProject) DeleteMachineGroup(name string) (err error)

+ func (p *LogProject) GetAppliedConfigs(groupName string) (confNames []string, err error)

+ func (p *LogProject) GetAppliedMachineGroups(confName string) (groupNames []string, err error)

+ func (p *LogProject) GetConfig(name string) (c *LogConfig, err error)

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

+ func (p *LogProject) GetMachineGroup(name string) (m *MachineGroup, err error)

+ func (p *LogProject) ListConfig(offset, size int) (cfgNames []string, total int, err error)

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

+ func (p *LogProject) ListMachineGroup(offset, size int) (m []string, total int, err error)

+ func (p *LogProject) RemoveConfigFromMachineGroup(confName, groupName string) (err error)

+ func (p *LogProject) UpdateConfig(c *LogConfig) (err error)

+ func (p *LogProject) UpdateLogStore(name string, ttl, shardCnt int) (err error)

+ func (p *LogProject) UpdateMachineGroup(m *MachineGroup) (err error)

+ type LogStore struct

+ CreateTime uint32

+ LastModifyTime uint32

+ Name string

+ ShardCount int

+ TTL int

+ func (s *LogStore) GetCursor(shardID int, from string) (cursor string, err error)

+ func (s *LogStore) GetLogs(shardID int, cursor string, logGroupMaxCount int) (gl *LogGroupList, nextCursor string, err error)

+ func (s *LogStore) GetLogsBytes(shardID int, cursor string, logGroupMaxCount int) (out []byte, nextCursor string, err error)

+ func (s *LogStore) ListShards() (shardIDs []int, err error)

+ func (s *LogStore) PutLogs(lg *LogGroup) (err error)

+ type Machine struct

+ IP string

+ UniqueID string

+ UserdefinedID string

+ type MachineGroup struct

+ Attribute MachineGroupAttribute

+ CreateTime uint32

+ LastModifyTime uint32

+ MachineIDList []string

+ MachineIDType string

+ Name string

+ Type string

+ func (m *MachineGroup) GetAppliedConfigs() (confNames []string, err error)

+ func (m *MachineGroup) ListMachines() (ms []*Machine, total int, err error)

+ type MachineGroupAttribute struct

+ ExternalName string

+ TopicName string

+ type MachineList struct

+ Machines []*Machine

+ Total int

+ type OutputDetail struct

+ Endpoint string

+ LogStoreName string

+ type Shard struct

+ ShardID int