lsd

package
v0.0.0-...-845418e Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2021 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package lsd is a generated protocol buffer package.

It is generated from these files: 

lsd-config.proto

It has these top-level messages: 

LsdConfig

Package lsd is a generated protocol buffer package.

It is generated from these files:
	lsd.proto

It has these top-level messages:
	RequestNewEvents
	ResponseOffsets
	ResponseGeneric

Index

Constants

View Source 
const Default_LsdConfigClientConfigTReceiverT_ConnectTimeout uint64 = 1
View Source 
const Default_LsdConfigClientConfigTReceiverT_RequestTimeout uint64 = 30
View Source 
const Default_LsdConfigClientConfigTRoutingConfigT_Gzip bool = false
View Source 
const Default_LsdConfigClientConfigTRoutingConfigT_OutBufferSizeMultiplier uint64 = 1
View Source 
const Default_LsdConfigClientConfigT_AlwaysFlock bool = false
View Source 
const Default_LsdConfigClientConfigT_BacklogFlushInterval uint64 = 10
View Source 
const Default_LsdConfigClientConfigT_FileEventsBufferSize uint64 = 500
View Source 
const Default_LsdConfigClientConfigT_FileRotateInterval uint64 = 120
View Source 
const Default_LsdConfigClientConfigT_MaxFileSize uint64 = 1000000
View Source 
const Default_LsdConfigClientConfigT_OffsetsSaveInterval uint64 = 1
View Source 
const Default_LsdConfigClientConfigT_OutBufferSize uint64 = 50
View Source 
const Default_LsdConfigClientConfigT_PeriodicScanInterval uint64 = 600
View Source 
const Default_LsdConfigClientConfigT_TrafficStatsRecalcInterval uint64 = 10
View Source 
const Default_LsdConfigClientConfigT_UsageCheckInterval uint64 = 60
View Source 
const Default_LsdConfigServerConfigTServerSettingsT_Gzip bool = false
View Source 
const Default_LsdConfigServerConfigTServerSettingsT_GzipParallel uint64 = 1
View Source 
const Default_LsdConfigServerConfigT_ErrorSleepInterval uint64 = 60
View Source 
const Default_LsdConfigServerConfigT_FileRotateInterval uint64 = 5
View Source 
const Default_LsdConfigServerConfigT_MaxFileSize uint64 = 5000000
View Source 
const Default_LsdConfigServerConfigT_TrafficStatsRecalcInterval uint64 = 10
View Source 
const Default_RequestNewEventsEventT_IsCompressed bool = false

Variables

View Source 
var (
	ErrInvalidLengthLsdUnsafe = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLsdUnsafe   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Errno_name = map[int32]string{
	1: "ERRNO_GENERIC",
}
View Source 
var Errno_value = map[string]int32{
	"ERRNO_GENERIC": 1,
}
View Source 
var LsdConfigServerConfigTWriteMode_name = map[int32]string{
	1: "CHUNK_FILES",
	2: "PLAIN_LOG",
}
View Source 
var LsdConfigServerConfigTWriteMode_value = map[string]int32{
	"CHUNK_FILES": 1,
	"PLAIN_LOG":   2,
}
View Source 
var RequestMsgid_gpbrpc_name = map[uint32]string{
	1: "request_new_events",
}
View Source 
var RequestMsgid_gpbrpc_value = map[string]uint32{
	"request_new_events": 1,
}
View Source 
var RequestMsgid_name = map[int32]string{
	1: "REQUEST_NEW_EVENTS",
}
View Source 
var RequestMsgid_value = map[string]int32{
	"REQUEST_NEW_EVENTS": 1,
}
View Source 
var ResponseMsgid_gpbrpc_name = map[uint32]string{
	1: "response_generic",
	2: "response_offsets",
}
View Source 
var ResponseMsgid_gpbrpc_value = map[string]uint32{
	"response_generic": 1,
	"response_offsets": 2,
}
View Source 
var ResponseMsgid_name = map[int32]string{
	1: "RESPONSE_GENERIC",
	2: "RESPONSE_OFFSETS",
}
View Source 
var ResponseMsgid_value = map[string]int32{
	"RESPONSE_GENERIC": 1,
	"RESPONSE_OFFSETS": 2,
}

Functions

This section is empty.

Types

type Errno 

type Errno int32
const (
	Errno_ERRNO_GENERIC Errno = 1
)

func (Errno) Enum 

func (x Errno) Enum() *Errno

func (Errno) String 

func (x Errno) String() string

func (*Errno) UnmarshalJSON 

func (x *Errno) UnmarshalJSON(data []byte) error

type GpbrpcInterface 

type GpbrpcInterface interface {
	RequestNewEvents(rctx gpbrpc.RequestT, request *RequestNewEvents) gpbrpc.ResultT
}

type GpbrpcType 

type GpbrpcType struct {
}
var Gpbrpc GpbrpcType

func (GpbrpcType) Dispatch 

func (GpbrpcType) Dispatch(rctx gpbrpc.RequestT, abstract_service interface{}) gpbrpc.ResultT

func (GpbrpcType) ErrorGeneric 

func (GpbrpcType) ErrorGeneric(args ...interface{}) gpbrpc.ResultT

func (GpbrpcType) GetPackageName 

func (GpbrpcType) GetPackageName() string

func (GpbrpcType) GetRequestIdToNameMap 

func (GpbrpcType) GetRequestIdToNameMap() map[uint32]string

func (GpbrpcType) GetRequestMsg 

func (GpbrpcType) GetRequestMsg(request_msgid uint32) proto.Message

func (GpbrpcType) GetRequestMsgid 

func (GpbrpcType) GetRequestMsgid(msg proto.Message) uint32

func (GpbrpcType) GetRequestNameToIdMap 

func (GpbrpcType) GetRequestNameToIdMap() map[string]uint32

func (GpbrpcType) GetResponseIdToNameMap 

func (GpbrpcType) GetResponseIdToNameMap() map[uint32]string

func (GpbrpcType) GetResponseMsg 

func (GpbrpcType) GetResponseMsg(response_msgid uint32) proto.Message

func (GpbrpcType) GetResponseMsgid 

func (GpbrpcType) GetResponseMsgid(msg proto.Message) uint32

func (GpbrpcType) GetResponseNameToIdMap 

func (GpbrpcType) GetResponseNameToIdMap() map[string]uint32

func (GpbrpcType) OK 

func (GpbrpcType) OK(args ...interface{}) gpbrpc.ResultT

type LsdConfig 

type LsdConfig struct {
	ServerConfig *LsdConfigServerConfigT `protobuf:"bytes,1,opt,name=server_config" json:"server_config,omitempty"`
	ClientConfig *LsdConfigClientConfigT `protobuf:"bytes,2,opt,name=client_config" json:"client_config,omitempty"`
}

func (*LsdConfig) GetClientConfig 

func (m *LsdConfig) GetClientConfig() *LsdConfigClientConfigT

func (*LsdConfig) GetServerConfig 

func (m *LsdConfig) GetServerConfig() *LsdConfigServerConfigT

func (*LsdConfig) ProtoMessage 

func (*LsdConfig) ProtoMessage()

func (*LsdConfig) Reset 

func (m *LsdConfig) Reset()

func (*LsdConfig) String 

func (m *LsdConfig) String() string

type LsdConfigClientConfigT 

type LsdConfigClientConfigT struct {
	SourceDir                  *string                                 `protobuf:"bytes,1,req,name=source_dir" json:"source_dir,omitempty"`
	OffsetsDb                  *string                                 `protobuf:"bytes,2,req,name=offsets_db" json:"offsets_db,omitempty"`
	MaxFileSize                *uint64                                 `protobuf:"varint,3,opt,name=max_file_size,def=1000000" json:"max_file_size,omitempty"`
	FileRotateInterval         *uint64                                 `protobuf:"varint,4,opt,name=file_rotate_interval,def=120" json:"file_rotate_interval,omitempty"`
	AlwaysFlock                *bool                                   `protobuf:"varint,5,opt,name=always_flock,def=0" json:"always_flock,omitempty"`
	Routing                    []*LsdConfigClientConfigTRoutingConfigT `protobuf:"bytes,6,rep,name=routing" json:"routing,omitempty"`
	FileEventsBufferSize       *uint64                                 `protobuf:"varint,7,opt,name=file_events_buffer_size,def=500" json:"file_events_buffer_size,omitempty"`
	OutBufferSize              *uint64                                 `protobuf:"varint,8,opt,name=out_buffer_size,def=50" json:"out_buffer_size,omitempty"`
	UsageCheckInterval         *uint64                                 `protobuf:"varint,9,opt,name=usage_check_interval,def=60" json:"usage_check_interval,omitempty"`
	OffsetsSaveInterval        *uint64                                 `protobuf:"varint,10,opt,name=offsets_save_interval,def=1" json:"offsets_save_interval,omitempty"`
	TrafficStatsRecalcInterval *uint64                                 `protobuf:"varint,11,opt,name=traffic_stats_recalc_interval,def=10" json:"traffic_stats_recalc_interval,omitempty"`
	BacklogFlushInterval       *uint64                                 `protobuf:"varint,12,opt,name=backlog_flush_interval,def=10" json:"backlog_flush_interval,omitempty"`
	PeriodicScanInterval       *uint64                                 `protobuf:"varint,13,opt,name=periodic_scan_interval,def=600" json:"periodic_scan_interval,omitempty"`
}

func (*LsdConfigClientConfigT) GetAlwaysFlock 

func (m *LsdConfigClientConfigT) GetAlwaysFlock() bool

func (*LsdConfigClientConfigT) GetBacklogFlushInterval 

func (m *LsdConfigClientConfigT) GetBacklogFlushInterval() uint64

func (*LsdConfigClientConfigT) GetFileEventsBufferSize 

func (m *LsdConfigClientConfigT) GetFileEventsBufferSize() uint64

func (*LsdConfigClientConfigT) GetFileRotateInterval 

func (m *LsdConfigClientConfigT) GetFileRotateInterval() uint64

func (*LsdConfigClientConfigT) GetMaxFileSize 

func (m *LsdConfigClientConfigT) GetMaxFileSize() uint64

func (*LsdConfigClientConfigT) GetOffsetsDb 

func (m *LsdConfigClientConfigT) GetOffsetsDb() string

func (*LsdConfigClientConfigT) GetOffsetsSaveInterval 

func (m *LsdConfigClientConfigT) GetOffsetsSaveInterval() uint64

func (*LsdConfigClientConfigT) GetOutBufferSize 

func (m *LsdConfigClientConfigT) GetOutBufferSize() uint64

func (*LsdConfigClientConfigT) GetPeriodicScanInterval 

func (m *LsdConfigClientConfigT) GetPeriodicScanInterval() uint64

func (*LsdConfigClientConfigT) GetRouting 

func (m *LsdConfigClientConfigT) GetRouting() []*LsdConfigClientConfigTRoutingConfigT

func (*LsdConfigClientConfigT) GetSourceDir 

func (m *LsdConfigClientConfigT) GetSourceDir() string

func (*LsdConfigClientConfigT) GetTrafficStatsRecalcInterval 

func (m *LsdConfigClientConfigT) GetTrafficStatsRecalcInterval() uint64

func (*LsdConfigClientConfigT) GetUsageCheckInterval 

func (m *LsdConfigClientConfigT) GetUsageCheckInterval() uint64

func (*LsdConfigClientConfigT) ProtoMessage 

func (*LsdConfigClientConfigT) ProtoMessage()

func (*LsdConfigClientConfigT) Reset 

func (m *LsdConfigClientConfigT) Reset()

func (*LsdConfigClientConfigT) String 

func (m *LsdConfigClientConfigT) String() string

type LsdConfigClientConfigTReceiverT 

type LsdConfigClientConfigTReceiverT struct {
	Addr           *string `protobuf:"bytes,1,req,name=addr" json:"addr,omitempty"`
	Weight         *uint64 `protobuf:"varint,2,req,name=weight" json:"weight,omitempty"`
	ConnectTimeout *uint64 `protobuf:"varint,3,opt,name=connect_timeout,def=1" json:"connect_timeout,omitempty"`
	RequestTimeout *uint64 `protobuf:"varint,4,opt,name=request_timeout,def=30" json:"request_timeout,omitempty"`
}

func (*LsdConfigClientConfigTReceiverT) GetAddr 

func (m *LsdConfigClientConfigTReceiverT) GetAddr() string

func (*LsdConfigClientConfigTReceiverT) GetConnectTimeout 

func (m *LsdConfigClientConfigTReceiverT) GetConnectTimeout() uint64

func (*LsdConfigClientConfigTReceiverT) GetRequestTimeout 

func (m *LsdConfigClientConfigTReceiverT) GetRequestTimeout() uint64

func (*LsdConfigClientConfigTReceiverT) GetWeight 

func (m *LsdConfigClientConfigTReceiverT) GetWeight() uint64

func (*LsdConfigClientConfigTReceiverT) ProtoMessage 

func (*LsdConfigClientConfigTReceiverT) ProtoMessage()

func (*LsdConfigClientConfigTReceiverT) Reset 

func (m *LsdConfigClientConfigTReceiverT) Reset()

func (*LsdConfigClientConfigTReceiverT) String 

func (m *LsdConfigClientConfigTReceiverT) String() string

type LsdConfigClientConfigTRoutingConfigT 

type LsdConfigClientConfigTRoutingConfigT struct {
	Categories              []string                           `protobuf:"bytes,1,rep,name=categories" json:"categories,omitempty"`
	Receivers               []*LsdConfigClientConfigTReceiverT `protobuf:"bytes,2,rep,name=receivers" json:"receivers,omitempty"`
	OutBufferSizeMultiplier *uint64                            `protobuf:"varint,3,opt,name=out_buffer_size_multiplier,def=1" json:"out_buffer_size_multiplier,omitempty"`
	Gzip                    *bool                              `protobuf:"varint,4,opt,name=gzip,def=0" json:"gzip,omitempty"`
}

func (*LsdConfigClientConfigTRoutingConfigT) GetCategories 

func (m *LsdConfigClientConfigTRoutingConfigT) GetCategories() []string

func (*LsdConfigClientConfigTRoutingConfigT) GetGzip 

func (m *LsdConfigClientConfigTRoutingConfigT) GetGzip() bool

func (*LsdConfigClientConfigTRoutingConfigT) GetOutBufferSizeMultiplier 

func (m *LsdConfigClientConfigTRoutingConfigT) GetOutBufferSizeMultiplier() uint64

func (*LsdConfigClientConfigTRoutingConfigT) GetReceivers 

func (m *LsdConfigClientConfigTRoutingConfigT) GetReceivers() []*LsdConfigClientConfigTReceiverT

func (*LsdConfigClientConfigTRoutingConfigT) ProtoMessage 

func (*LsdConfigClientConfigTRoutingConfigT) ProtoMessage()

func (*LsdConfigClientConfigTRoutingConfigT) Reset 

func (m *LsdConfigClientConfigTRoutingConfigT) Reset()

func (*LsdConfigClientConfigTRoutingConfigT) String 

func (m *LsdConfigClientConfigTRoutingConfigT) String() string

type LsdConfigServerConfigT 

type LsdConfigServerConfigT struct {
	// default settings that are redefined by more concrete ones (above)
	TargetDir                  *string                                  `protobuf:"bytes,1,req,name=target_dir" json:"target_dir,omitempty"`
	Mode                       *LsdConfigServerConfigTWriteMode         `protobuf:"varint,2,opt,name=mode,enum=lsd.LsdConfigServerConfigTWriteMode,def=1" json:"mode,omitempty"`
	MaxFileSize                *uint64                                  `protobuf:"varint,3,opt,name=max_file_size,def=5000000" json:"max_file_size,omitempty"`
	FileRotateInterval         *uint64                                  `protobuf:"varint,4,opt,name=file_rotate_interval,def=5" json:"file_rotate_interval,omitempty"`
	ForceFileName              *string                                  `protobuf:"bytes,5,opt,name=force_file_name" json:"force_file_name,omitempty"`
	PerCategorySettings        []*LsdConfigServerConfigTServerSettingsT `protobuf:"bytes,6,rep,name=per_category_settings" json:"per_category_settings,omitempty"`
	ErrorSleepInterval         *uint64                                  `protobuf:"varint,7,opt,name=error_sleep_interval,def=60" json:"error_sleep_interval,omitempty"`
	TrafficStatsRecalcInterval *uint64                                  `protobuf:"varint,8,opt,name=traffic_stats_recalc_interval,def=10" json:"traffic_stats_recalc_interval,omitempty"`
}

func (*LsdConfigServerConfigT) GetErrorSleepInterval 

func (m *LsdConfigServerConfigT) GetErrorSleepInterval() uint64

func (*LsdConfigServerConfigT) GetFileRotateInterval 

func (m *LsdConfigServerConfigT) GetFileRotateInterval() uint64

func (*LsdConfigServerConfigT) GetForceFileName 

func (m *LsdConfigServerConfigT) GetForceFileName() string

func (*LsdConfigServerConfigT) GetMaxFileSize 

func (m *LsdConfigServerConfigT) GetMaxFileSize() uint64

func (*LsdConfigServerConfigT) GetMode 

func (m *LsdConfigServerConfigT) GetMode() LsdConfigServerConfigTWriteMode

func (*LsdConfigServerConfigT) GetPerCategorySettings 

func (m *LsdConfigServerConfigT) GetPerCategorySettings() []*LsdConfigServerConfigTServerSettingsT

func (*LsdConfigServerConfigT) GetTargetDir 

func (m *LsdConfigServerConfigT) GetTargetDir() string

func (*LsdConfigServerConfigT) GetTrafficStatsRecalcInterval 

func (m *LsdConfigServerConfigT) GetTrafficStatsRecalcInterval() uint64

func (*LsdConfigServerConfigT) ProtoMessage 

func (*LsdConfigServerConfigT) ProtoMessage()

func (*LsdConfigServerConfigT) Reset 

func (m *LsdConfigServerConfigT) Reset()

func (*LsdConfigServerConfigT) String 

func (m *LsdConfigServerConfigT) String() string

type LsdConfigServerConfigTServerSettingsT 

type LsdConfigServerConfigTServerSettingsT struct {
	Categories         []string                         `protobuf:"bytes,1,rep,name=categories" json:"categories,omitempty"`
	Mode               *LsdConfigServerConfigTWriteMode `protobuf:"varint,2,opt,name=mode,enum=lsd.LsdConfigServerConfigTWriteMode,def=1" json:"mode,omitempty"`
	MaxFileSize        *uint64                          `protobuf:"varint,3,opt,name=max_file_size" json:"max_file_size,omitempty"`
	FileRotateInterval *uint64                          `protobuf:"varint,4,opt,name=file_rotate_interval" json:"file_rotate_interval,omitempty"`
	ForceFileName      *string                          `protobuf:"bytes,5,opt,name=force_file_name" json:"force_file_name,omitempty"`
	Gzip               *bool                            `protobuf:"varint,6,opt,name=gzip,def=0" json:"gzip,omitempty"`
	GzipParallel       *uint64                          `protobuf:"varint,7,opt,name=gzip_parallel,def=1" json:"gzip_parallel,omitempty"`
}

func (*LsdConfigServerConfigTServerSettingsT) GetCategories 

func (m *LsdConfigServerConfigTServerSettingsT) GetCategories() []string

func (*LsdConfigServerConfigTServerSettingsT) GetFileRotateInterval 

func (m *LsdConfigServerConfigTServerSettingsT) GetFileRotateInterval() uint64

func (*LsdConfigServerConfigTServerSettingsT) GetForceFileName 

func (m *LsdConfigServerConfigTServerSettingsT) GetForceFileName() string

func (*LsdConfigServerConfigTServerSettingsT) GetGzip 

func (m *LsdConfigServerConfigTServerSettingsT) GetGzip() bool

func (*LsdConfigServerConfigTServerSettingsT) GetGzipParallel 

func (m *LsdConfigServerConfigTServerSettingsT) GetGzipParallel() uint64

func (*LsdConfigServerConfigTServerSettingsT) GetMaxFileSize 

func (m *LsdConfigServerConfigTServerSettingsT) GetMaxFileSize() uint64

func (*LsdConfigServerConfigTServerSettingsT) GetMode 

func (m *LsdConfigServerConfigTServerSettingsT) GetMode() LsdConfigServerConfigTWriteMode

func (*LsdConfigServerConfigTServerSettingsT) ProtoMessage 

func (*LsdConfigServerConfigTServerSettingsT) ProtoMessage()

func (*LsdConfigServerConfigTServerSettingsT) Reset 

func (m *LsdConfigServerConfigTServerSettingsT) Reset()

func (*LsdConfigServerConfigTServerSettingsT) String 

func (m *LsdConfigServerConfigTServerSettingsT) String() string

type LsdConfigServerConfigTWriteMode 

type LsdConfigServerConfigTWriteMode int32
const (
	LsdConfigServerConfigT_CHUNK_FILES LsdConfigServerConfigTWriteMode = 1
	LsdConfigServerConfigT_PLAIN_LOG   LsdConfigServerConfigTWriteMode = 2
)
const Default_LsdConfigServerConfigTServerSettingsT_Mode LsdConfigServerConfigTWriteMode = LsdConfigServerConfigT_CHUNK_FILES
const Default_LsdConfigServerConfigT_Mode LsdConfigServerConfigTWriteMode = LsdConfigServerConfigT_CHUNK_FILES

func (LsdConfigServerConfigTWriteMode) Enum 

func (x LsdConfigServerConfigTWriteMode) Enum() *LsdConfigServerConfigTWriteMode

func (LsdConfigServerConfigTWriteMode) String 

func (x LsdConfigServerConfigTWriteMode) String() string

func (*LsdConfigServerConfigTWriteMode) UnmarshalJSON 

func (x *LsdConfigServerConfigTWriteMode) UnmarshalJSON(data []byte) error

type RequestMsgid 

type RequestMsgid int32
const (
	RequestMsgid_REQUEST_NEW_EVENTS RequestMsgid = 1
)

func (RequestMsgid) Enum 

func (x RequestMsgid) Enum() *RequestMsgid

func (RequestMsgid) String 

func (x RequestMsgid) String() string

func (*RequestMsgid) UnmarshalJSON 

func (x *RequestMsgid) UnmarshalJSON(data []byte) error

type RequestNewEvents 

type RequestNewEvents struct {
	Events           []*RequestNewEventsEventT `protobuf:"bytes,1,rep,name=events" json:"events,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*RequestNewEvents) GetEvents 

func (m *RequestNewEvents) GetEvents() []*RequestNewEventsEventT

func (*RequestNewEvents) Marshal 

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

func (*RequestNewEvents) MarshalTo 

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

func (*RequestNewEvents) ProtoMessage 

func (*RequestNewEvents) ProtoMessage()

func (*RequestNewEvents) Reset 

func (m *RequestNewEvents) Reset()

func (*RequestNewEvents) Size 

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

func (*RequestNewEvents) String 

func (m *RequestNewEvents) String() string

func (*RequestNewEvents) Unmarshal 

func (m *RequestNewEvents) Unmarshal(data []byte) error

type RequestNewEventsEventT 

type RequestNewEventsEventT struct {
	Category         *string  `protobuf:"bytes,1,req,name=category" json:"category,omitempty"`
	Inode            *uint64  `protobuf:"varint,2,req,name=inode" json:"inode,omitempty"`
	Offset           *uint64  `protobuf:"varint,3,req,name=offset" json:"offset,omitempty"`
	Lines            []string `protobuf:"bytes,4,rep,name=lines" json:"lines,omitempty"`
	IsCompressed     *bool    `protobuf:"varint,5,opt,name=is_compressed,def=0" json:"is_compressed,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*RequestNewEventsEventT) GetCategory 

func (m *RequestNewEventsEventT) GetCategory() string

func (*RequestNewEventsEventT) GetInode 

func (m *RequestNewEventsEventT) GetInode() uint64

func (*RequestNewEventsEventT) GetIsCompressed 

func (m *RequestNewEventsEventT) GetIsCompressed() bool

func (*RequestNewEventsEventT) GetLines 

func (m *RequestNewEventsEventT) GetLines() []string

func (*RequestNewEventsEventT) GetOffset 

func (m *RequestNewEventsEventT) GetOffset() uint64

func (*RequestNewEventsEventT) Marshal 

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

func (*RequestNewEventsEventT) MarshalTo 

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

func (*RequestNewEventsEventT) ProtoMessage 

func (*RequestNewEventsEventT) ProtoMessage()

func (*RequestNewEventsEventT) Reset 

func (m *RequestNewEventsEventT) Reset()

func (*RequestNewEventsEventT) Size 

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

func (*RequestNewEventsEventT) String 

func (m *RequestNewEventsEventT) String() string

func (*RequestNewEventsEventT) Unmarshal 

func (m *RequestNewEventsEventT) Unmarshal(data []byte) error

type ResponseGeneric 

type ResponseGeneric struct {
	ErrorCode        *int32  `protobuf:"zigzag32,1,req,name=error_code" json:"error_code,omitempty"`
	ErrorText        *string `protobuf:"bytes,2,opt,name=error_text" json:"error_text,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ResponseGeneric) GetErrorCode 

func (m *ResponseGeneric) GetErrorCode() int32

func (*ResponseGeneric) GetErrorText 

func (m *ResponseGeneric) GetErrorText() string

func (*ResponseGeneric) Marshal 

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

func (*ResponseGeneric) MarshalTo 

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

func (*ResponseGeneric) ProtoMessage 

func (*ResponseGeneric) ProtoMessage()

func (*ResponseGeneric) Reset 

func (m *ResponseGeneric) Reset()

func (*ResponseGeneric) Size 

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

func (*ResponseGeneric) String 

func (m *ResponseGeneric) String() string

func (*ResponseGeneric) Unmarshal 

func (m *ResponseGeneric) Unmarshal(data []byte) error

type ResponseMsgid 

type ResponseMsgid int32
const (
	ResponseMsgid_RESPONSE_GENERIC ResponseMsgid = 1
	ResponseMsgid_RESPONSE_OFFSETS ResponseMsgid = 2
)

func (ResponseMsgid) Enum 

func (x ResponseMsgid) Enum() *ResponseMsgid

func (ResponseMsgid) String 

func (x ResponseMsgid) String() string

func (*ResponseMsgid) UnmarshalJSON 

func (x *ResponseMsgid) UnmarshalJSON(data []byte) error

type ResponseOffsets 

type ResponseOffsets struct {
	Offsets          []*ResponseOffsetsOffsetT `protobuf:"bytes,1,rep,name=offsets" json:"offsets,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*ResponseOffsets) GetOffsets 

func (m *ResponseOffsets) GetOffsets() []*ResponseOffsetsOffsetT

func (*ResponseOffsets) Marshal 

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

func (*ResponseOffsets) MarshalTo 

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

func (*ResponseOffsets) ProtoMessage 

func (*ResponseOffsets) ProtoMessage()

func (*ResponseOffsets) Reset 

func (m *ResponseOffsets) Reset()

func (*ResponseOffsets) Size 

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

func (*ResponseOffsets) String 

func (m *ResponseOffsets) String() string

func (*ResponseOffsets) Unmarshal 

func (m *ResponseOffsets) Unmarshal(data []byte) error

type ResponseOffsetsOffsetT 

type ResponseOffsetsOffsetT struct {
	Inode            *uint64 `protobuf:"varint,1,req,name=inode" json:"inode,omitempty"`
	Offset           *uint64 `protobuf:"varint,2,req,name=offset" json:"offset,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ResponseOffsetsOffsetT) GetInode 

func (m *ResponseOffsetsOffsetT) GetInode() uint64

func (*ResponseOffsetsOffsetT) GetOffset 

func (m *ResponseOffsetsOffsetT) GetOffset() uint64

func (*ResponseOffsetsOffsetT) Marshal 

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

func (*ResponseOffsetsOffsetT) MarshalTo 

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

func (*ResponseOffsetsOffsetT) ProtoMessage 

func (*ResponseOffsetsOffsetT) ProtoMessage()

func (*ResponseOffsetsOffsetT) Reset 

func (m *ResponseOffsetsOffsetT) Reset()

func (*ResponseOffsetsOffsetT) Size 

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

func (*ResponseOffsetsOffsetT) String 

func (m *ResponseOffsetsOffsetT) String() string

func (*ResponseOffsetsOffsetT) Unmarshal 

func (m *ResponseOffsetsOffsetT) Unmarshal(data []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.