Versions in this module Expand all Collapse all v0 v0.0.6 Oct 9, 2023 v0.0.5 Jun 9, 2023 v0.0.4 May 17, 2023 v0.0.3 May 16, 2023 v0.0.2 May 15, 2023 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
Go to main page