client

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 19, 2025 License: Apache-2.0 Imports: 18 Imported by: 1

Documentation

Overview

This file is auto-generated, don't edit it. Thanks.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLog        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLog          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLog = fmt.Errorf("proto: unexpected end of group")
)

Functions

func BytesLength added in v0.0.3 

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

func Compress added in v0.0.3 

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

Description:

Compress data by specified compress type, use isCompressorAvailable to check if the compress type is supported.

@param src - the data to be compressed

@param compressType - the compress type

@return the compressed data

@throws error if the compress type is not supported or the compress failed

func IsCompressorAvailable added in v0.0.3 

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

func IsDecompressorAvailable added in v0.0.3 

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

func ReadAndUncompressBlock 

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

Description:

Read data from a readable stream, and parse it by JSON format

@param stream - the readable stream

@return the parsed result

func SerializeLogGroupToPB added in v0.4.0 

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

Types

type Log added in v0.4.0 

type Log struct {
	Time                 *uint32       `protobuf:"varint,1,req,name=Time" json:"Time,omitempty"`
	Contents             []*LogContent `protobuf:"bytes,2,rep,name=Contents" json:"Contents,omitempty"`
	TimeNs               *uint32       `protobuf:"fixed32,4,opt,name=TimeNs" json:"TimeNs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Log) Descriptor added in v0.4.0 

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

func (*Log) GetContents added in v0.4.0 

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

func (*Log) GetTime added in v0.4.0 

func (m *Log) GetTime() uint32

func (*Log) GetTimeNs added in v0.4.0 

func (m *Log) GetTimeNs() uint32

func (*Log) Marshal added in v0.4.0 

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

func (*Log) MarshalTo added in v0.4.0 

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

func (*Log) MarshalToSizedBuffer added in v0.4.0 

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

func (*Log) ProtoMessage added in v0.4.0 

func (*Log) ProtoMessage()

func (*Log) Reset added in v0.4.0 

func (m *Log) Reset()

func (*Log) Size added in v0.4.0 

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

func (*Log) String added in v0.4.0 

func (m *Log) String() string

func (*Log) Unmarshal added in v0.4.0 

func (m *Log) Unmarshal(dAtA []byte) error

func (*Log) XXX_DiscardUnknown added in v0.4.0 

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal added in v0.4.0 

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

func (*Log) XXX_Merge added in v0.4.0 

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

func (*Log) XXX_Size added in v0.4.0 

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal added in v0.4.0 

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

type LogContent added in v0.4.0 

type LogContent struct {
	Key   *string `protobuf:"bytes,1,req,name=Key" json:"Key,omitempty"`
	Value *string `protobuf:"bytes,2,req,name=Value" json:"Value,omitempty"`

	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
	// contains filtered or unexported fields
}

func (*LogContent) Descriptor added in v0.4.0 

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

func (*LogContent) GetKey added in v0.4.0 

func (m *LogContent) GetKey() string

func (*LogContent) GetValue added in v0.4.0 

func (m *LogContent) GetValue() string

func (*LogContent) Marshal added in v0.4.0 

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

func (*LogContent) MarshalTo added in v0.4.0 

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

func (*LogContent) MarshalToSizedBuffer added in v0.4.0 

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

func (*LogContent) ProtoMessage added in v0.4.0 

func (*LogContent) ProtoMessage()

func (*LogContent) Reset added in v0.4.0 

func (m *LogContent) Reset()

func (*LogContent) Size added in v0.4.0 

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

func (*LogContent) String added in v0.4.0 

func (m *LogContent) String() string

func (*LogContent) Unmarshal added in v0.4.0 

func (m *LogContent) Unmarshal(dAtA []byte) error

func (*LogContent) XXX_DiscardUnknown added in v0.4.0 

func (m *LogContent) XXX_DiscardUnknown()

func (*LogContent) XXX_Marshal added in v0.4.0 

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

func (*LogContent) XXX_Merge added in v0.4.0 

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

func (*LogContent) XXX_Size added in v0.4.0 

func (m *LogContent) XXX_Size() int

func (*LogContent) XXX_Unmarshal added in v0.4.0 

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

type LogGroup added in v0.4.0 

type LogGroup struct {
	Logs                 []*Log    `protobuf:"bytes,1,rep,name=Logs" json:"Logs,omitempty"`
	Category             *string   `protobuf:"bytes,2,opt,name=Category" json:"Category,omitempty"`
	Topic                *string   `protobuf:"bytes,3,opt,name=Topic" json:"Topic,omitempty"`
	Source               *string   `protobuf:"bytes,4,opt,name=Source" json:"Source,omitempty"`
	MachineUUID          *string   `protobuf:"bytes,5,opt,name=MachineUUID" json:"MachineUUID,omitempty"`
	LogTags              []*LogTag `protobuf:"bytes,6,rep,name=LogTags" json:"LogTags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*LogGroup) Descriptor added in v0.4.0 

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

func (*LogGroup) GetCategory added in v0.4.0 

func (m *LogGroup) GetCategory() string

func (*LogGroup) GetLogTags added in v0.4.0 

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

func (*LogGroup) GetLogs added in v0.4.0 

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

func (*LogGroup) GetMachineUUID added in v0.4.0 

func (m *LogGroup) GetMachineUUID() string

func (*LogGroup) GetSource added in v0.4.0 

func (m *LogGroup) GetSource() string

func (*LogGroup) GetTopic added in v0.4.0 

func (m *LogGroup) GetTopic() string

func (*LogGroup) Marshal added in v0.4.0 

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

func (*LogGroup) MarshalTo added in v0.4.0 

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

func (*LogGroup) MarshalToSizedBuffer added in v0.4.0 

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

func (*LogGroup) ProtoMessage added in v0.4.0 

func (*LogGroup) ProtoMessage()

func (*LogGroup) Reset added in v0.4.0 

func (m *LogGroup) Reset()

func (*LogGroup) Size added in v0.4.0 

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

func (*LogGroup) String added in v0.4.0 

func (m *LogGroup) String() string

func (*LogGroup) Unmarshal added in v0.4.0 

func (m *LogGroup) Unmarshal(dAtA []byte) error

func (*LogGroup) XXX_DiscardUnknown added in v0.4.0 

func (m *LogGroup) XXX_DiscardUnknown()

func (*LogGroup) XXX_Marshal added in v0.4.0 

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

func (*LogGroup) XXX_Merge added in v0.4.0 

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

func (*LogGroup) XXX_Size added in v0.4.0 

func (m *LogGroup) XXX_Size() int

func (*LogGroup) XXX_Unmarshal added in v0.4.0 

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

type LogGroupList added in v0.4.0 

type LogGroupList struct {
	LogGroups            []*LogGroup `protobuf:"bytes,1,rep,name=LogGroups" json:"LogGroups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*LogGroupList) Descriptor added in v0.4.0 

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

func (*LogGroupList) GetLogGroups added in v0.4.0 

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

func (*LogGroupList) Marshal added in v0.4.0 

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

func (*LogGroupList) MarshalTo added in v0.4.0 

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

func (*LogGroupList) MarshalToSizedBuffer added in v0.4.0 

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

func (*LogGroupList) ProtoMessage added in v0.4.0 

func (*LogGroupList) ProtoMessage()

func (*LogGroupList) Reset added in v0.4.0 

func (m *LogGroupList) Reset()

func (*LogGroupList) Size added in v0.4.0 

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

func (*LogGroupList) String added in v0.4.0 

func (m *LogGroupList) String() string

func (*LogGroupList) Unmarshal added in v0.4.0 

func (m *LogGroupList) Unmarshal(dAtA []byte) error

func (*LogGroupList) XXX_DiscardUnknown added in v0.4.0 

func (m *LogGroupList) XXX_DiscardUnknown()

func (*LogGroupList) XXX_Marshal added in v0.4.0 

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

func (*LogGroupList) XXX_Merge added in v0.4.0 

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

func (*LogGroupList) XXX_Size added in v0.4.0 

func (m *LogGroupList) XXX_Size() int

func (*LogGroupList) XXX_Unmarshal added in v0.4.0 

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

type LogTag added in v0.4.0 

type LogTag struct {
	Key   *string `protobuf:"bytes,1,req,name=Key" json:"Key,omitempty"`
	Value *string `protobuf:"bytes,2,req,name=Value" json:"Value,omitempty"`

	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
	// contains filtered or unexported fields
}

func (*LogTag) Descriptor added in v0.4.0 

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

func (*LogTag) GetKey added in v0.4.0 

func (m *LogTag) GetKey() string

func (*LogTag) GetValue added in v0.4.0 

func (m *LogTag) GetValue() string

func (*LogTag) Marshal added in v0.4.0 

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

func (*LogTag) MarshalTo added in v0.4.0 

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

func (*LogTag) MarshalToSizedBuffer added in v0.4.0 

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

func (*LogTag) ProtoMessage added in v0.4.0 

func (*LogTag) ProtoMessage()

func (*LogTag) Reset added in v0.4.0 

func (m *LogTag) Reset()

func (*LogTag) Size added in v0.4.0 

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

func (*LogTag) String added in v0.4.0 

func (m *LogTag) String() string

func (*LogTag) Unmarshal added in v0.4.0 

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

func (*LogTag) XXX_DiscardUnknown added in v0.4.0 

func (m *LogTag) XXX_DiscardUnknown()

func (*LogTag) XXX_Marshal added in v0.4.0 

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

func (*LogTag) XXX_Merge added in v0.4.0 

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

func (*LogTag) XXX_Size added in v0.4.0 

func (m *LogTag) XXX_Size() int

func (*LogTag) XXX_Unmarshal added in v0.4.0 

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

type SlsLogPackage added in v0.4.0 

type SlsLogPackage struct {
	Data                 []byte   `protobuf:"bytes,1,req,name=data" json:"data,omitempty"`
	UncompressSize       *int32   `protobuf:"varint,2,opt,name=uncompress_size,json=uncompressSize" json:"uncompress_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SlsLogPackage) Descriptor added in v0.4.0 

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

func (*SlsLogPackage) GetData added in v0.4.0 

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

func (*SlsLogPackage) GetUncompressSize added in v0.4.0 

func (m *SlsLogPackage) GetUncompressSize() int32

func (*SlsLogPackage) Marshal added in v0.4.0 

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

func (*SlsLogPackage) MarshalTo added in v0.4.0 

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

func (*SlsLogPackage) MarshalToSizedBuffer added in v0.4.0 

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

func (*SlsLogPackage) ProtoMessage added in v0.4.0 

func (*SlsLogPackage) ProtoMessage()

func (*SlsLogPackage) Reset added in v0.4.0 

func (m *SlsLogPackage) Reset()

func (*SlsLogPackage) Size added in v0.4.0 

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

func (*SlsLogPackage) String added in v0.4.0 

func (m *SlsLogPackage) String() string

func (*SlsLogPackage) Unmarshal added in v0.4.0 

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

func (*SlsLogPackage) XXX_DiscardUnknown added in v0.4.0 

func (m *SlsLogPackage) XXX_DiscardUnknown()

func (*SlsLogPackage) XXX_Marshal added in v0.4.0 

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

func (*SlsLogPackage) XXX_Merge added in v0.4.0 

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

func (*SlsLogPackage) XXX_Size added in v0.4.0 

func (m *SlsLogPackage) XXX_Size() int

func (*SlsLogPackage) XXX_Unmarshal added in v0.4.0 

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

type SlsLogPackageList added in v0.4.0 

type SlsLogPackageList struct {
	Packages             []*SlsLogPackage `protobuf:"bytes,1,rep,name=packages" json:"packages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SlsLogPackageList) Descriptor added in v0.4.0 

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

func (*SlsLogPackageList) GetPackages added in v0.4.0 

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

func (*SlsLogPackageList) Marshal added in v0.4.0 

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

func (*SlsLogPackageList) MarshalTo added in v0.4.0 

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

func (*SlsLogPackageList) MarshalToSizedBuffer added in v0.4.0 

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

func (*SlsLogPackageList) ProtoMessage added in v0.4.0 

func (*SlsLogPackageList) ProtoMessage()

func (*SlsLogPackageList) Reset added in v0.4.0 

func (m *SlsLogPackageList) Reset()

func (*SlsLogPackageList) Size added in v0.4.0 

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

func (*SlsLogPackageList) String added in v0.4.0 

func (m *SlsLogPackageList) String() string

func (*SlsLogPackageList) Unmarshal added in v0.4.0 

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

func (*SlsLogPackageList) XXX_DiscardUnknown added in v0.4.0 

func (m *SlsLogPackageList) XXX_DiscardUnknown()

func (*SlsLogPackageList) XXX_Marshal added in v0.4.0 

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

func (*SlsLogPackageList) XXX_Merge added in v0.4.0 

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

func (*SlsLogPackageList) XXX_Size added in v0.4.0 

func (m *SlsLogPackageList) XXX_Size() int

func (*SlsLogPackageList) XXX_Unmarshal added in v0.4.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.