Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

client

package

Go to main page

Versions in this module

v0

v0.4.0

Nov 19, 2025

Changes in this version

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

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

+ var ErrUnexpectedEndOfGroupLog = fmt.Errorf("proto: unexpected end of group")

+ func SerializeLogGroupToPB(logGroup interface{}) (_result []byte, _err error)

+ type Log struct

+ Contents []*LogContent

+ Time *uint32

+ TimeNs *uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Log) Descriptor() ([]byte, []int)

+ func (*Log) ProtoMessage()

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

+ func (m *Log) GetTime() uint32

+ func (m *Log) GetTimeNs() uint32

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

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

+ func (m *Log) MarshalToSizedBuffer(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

+ func (m *Log) XXX_DiscardUnknown()

+ func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Log) XXX_Merge(src proto.Message)

+ func (m *Log) XXX_Size() int

+ func (m *Log) XXX_Unmarshal(b []byte) error

+ type LogContent struct

+ Key *string

+ Value *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogContent) Descriptor() ([]byte, []int)

+ 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) MarshalToSizedBuffer(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

+ func (m *LogContent) XXX_DiscardUnknown()

+ func (m *LogContent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogContent) XXX_Merge(src proto.Message)

+ func (m *LogContent) XXX_Size() int

+ func (m *LogContent) XXX_Unmarshal(b []byte) error

+ type LogGroup struct

+ Category *string

+ LogTags []*LogTag

+ Logs []*Log

+ MachineUUID *string

+ Source *string

+ Topic *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogGroup) Descriptor() ([]byte, []int)

+ func (*LogGroup) ProtoMessage()

+ func (m *LogGroup) GetCategory() string

+ func (m *LogGroup) GetLogTags() []*LogTag

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

+ func (m *LogGroup) GetMachineUUID() 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) MarshalToSizedBuffer(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

+ func (m *LogGroup) XXX_DiscardUnknown()

+ func (m *LogGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogGroup) XXX_Merge(src proto.Message)

+ func (m *LogGroup) XXX_Size() int

+ func (m *LogGroup) XXX_Unmarshal(b []byte) error

+ type LogGroupList struct

+ LogGroups []*LogGroup

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogGroupList) Descriptor() ([]byte, []int)

+ 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) MarshalToSizedBuffer(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

+ func (m *LogGroupList) XXX_DiscardUnknown()

+ func (m *LogGroupList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogGroupList) XXX_Merge(src proto.Message)

+ func (m *LogGroupList) XXX_Size() int

+ func (m *LogGroupList) XXX_Unmarshal(b []byte) error

+ type LogTag struct

+ Key *string

+ Value *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogTag) Descriptor() ([]byte, []int)

+ func (*LogTag) ProtoMessage()

+ func (m *LogTag) GetKey() string

+ func (m *LogTag) GetValue() string

+ func (m *LogTag) Marshal() (dAtA []byte, err error)

+ func (m *LogTag) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogTag) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogTag) Reset()

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

+ func (m *LogTag) String() string

+ func (m *LogTag) Unmarshal(dAtA []byte) error

+ func (m *LogTag) XXX_DiscardUnknown()

+ func (m *LogTag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogTag) XXX_Merge(src proto.Message)

+ func (m *LogTag) XXX_Size() int

+ func (m *LogTag) XXX_Unmarshal(b []byte) error

+ type SlsLogPackage struct

+ Data []byte

+ UncompressSize *int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SlsLogPackage) Descriptor() ([]byte, []int)

+ func (*SlsLogPackage) ProtoMessage()

+ func (m *SlsLogPackage) GetData() []byte

+ func (m *SlsLogPackage) GetUncompressSize() int32

+ func (m *SlsLogPackage) Marshal() (dAtA []byte, err error)

+ func (m *SlsLogPackage) MarshalTo(dAtA []byte) (int, error)

+ func (m *SlsLogPackage) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SlsLogPackage) Reset()

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

+ func (m *SlsLogPackage) String() string

+ func (m *SlsLogPackage) Unmarshal(dAtA []byte) error

+ func (m *SlsLogPackage) XXX_DiscardUnknown()

+ func (m *SlsLogPackage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SlsLogPackage) XXX_Merge(src proto.Message)

+ func (m *SlsLogPackage) XXX_Size() int

+ func (m *SlsLogPackage) XXX_Unmarshal(b []byte) error

+ type SlsLogPackageList struct

+ Packages []*SlsLogPackage

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SlsLogPackageList) Descriptor() ([]byte, []int)

+ func (*SlsLogPackageList) ProtoMessage()

+ func (m *SlsLogPackageList) GetPackages() []*SlsLogPackage

+ func (m *SlsLogPackageList) Marshal() (dAtA []byte, err error)

+ func (m *SlsLogPackageList) MarshalTo(dAtA []byte) (int, error)

+ func (m *SlsLogPackageList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SlsLogPackageList) Reset()

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

+ func (m *SlsLogPackageList) String() string

+ func (m *SlsLogPackageList) Unmarshal(dAtA []byte) error

+ func (m *SlsLogPackageList) XXX_DiscardUnknown()

+ func (m *SlsLogPackageList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SlsLogPackageList) XXX_Merge(src proto.Message)

+ func (m *SlsLogPackageList) XXX_Size() int

+ func (m *SlsLogPackageList) XXX_Unmarshal(b []byte) error

v0.3.0

Dec 10, 2024

v0.0.3

Dec 10, 2024

Changes in this version

+ func BytesLength(src []byte) (_result *int64)

+ func Compress(src []byte, compressType *string) (_result []byte, _err error)

+ func IsCompressorAvailable(compressType *string) (_result *bool)

+ func IsDecompressorAvailable(compressType *string) (_result *bool)

v0.0.2

Sep 23, 2024

Changes in this version

+ func ReadAndUncompressBlock(stream io.Reader, compressType *string, bodyRawSize *string) (_result io.Reader, _err error)

v0.0.1

Jun 2, 2023