config

Documentation

Index

• Variables
• type Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (x *Config) GetDataPath() string
  • func (x *Config) GetMaxBytesPerFile() int64
  • func (x *Config) GetMaxMsgSize() int32
  • func (x *Config) GetMinMsgSize() int32
  • func (x *Config) GetSyncEvery() int64
  • func (x *Config) GetSyncTimeout() int64
  • func (*Config) ProtoMessage()
  • func (x *Config) ProtoReflect() protoreflect.Message
  • func (x *Config) Reset()
  • func (x *Config) String() string

Variables

var File_config_proto protoreflect.FileDescriptor

Types

type Config

type Config struct {
	DataPath        string `protobuf:"bytes,1,opt,name=data_path,json=dataPath,proto3" json:"data_path,omitempty"`                           // 文件地址地址
	MaxBytesPerFile int64  `protobuf:"varint,2,opt,name=max_bytes_per_file,json=maxBytesPerFile,proto3" json:"max_bytes_per_file,omitempty"` // 每个文件最大的大小
	MinMsgSize      int32  `protobuf:"varint,3,opt,name=min_msg_size,json=minMsgSize,proto3" json:"min_msg_size,omitempty"`                  // 最小消息大小
	MaxMsgSize      int32  `protobuf:"varint,4,opt,name=max_msg_size,json=maxMsgSize,proto3" json:"max_msg_size,omitempty"`                  // 最大消息大小
	SyncEvery       int64  `protobuf:"varint,5,opt,name=sync_every,json=syncEvery,proto3" json:"sync_every,omitempty"`                       // 每进行 N 次读写，刷一次盘 number of writes per fsync
	SyncTimeout     int64  `protobuf:"varint,6,opt,name=sync_timeout,json=syncTimeout,proto3" json:"sync_timeout,omitempty"`                 // 每过 N 毫秒(MS)读写，刷一次盘 duration of time per fsync
	// contains filtered or unexported fields
}

func (*Config) Descriptor

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetDataPath

func (x *Config) GetDataPath() string

func (*Config) GetMaxBytesPerFile

func (x *Config) GetMaxBytesPerFile() int64

func (*Config) GetMaxMsgSize

func (x *Config) GetMaxMsgSize() int32

func (*Config) GetMinMsgSize

func (x *Config) GetMinMsgSize() int32

func (*Config) GetSyncEvery

func (x *Config) GetSyncEvery() int64

func (*Config) GetSyncTimeout

func (x *Config) GetSyncTimeout() int64

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset

func (x *Config) Reset()

func (*Config) String

func (x *Config) String() string