Versions in this module Expand all Collapse all v2 v2.0.4 Jul 30, 2021 v2.0.3 Jul 30, 2021 v2.0.2 Jul 29, 2021 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 + Formatter string + 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
Go to main page