config

Documentation

Index

• Variables
• type Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (x *Config) GetBatchSize() uint32
  • func (x *Config) GetDialTimeout() uint32
  • func (x *Config) GetHeartbeatInterval() uint32
  • func (x *Config) GetNsqAddrs() []string
  • func (x *Config) GetReadTimeout() uint32
  • func (x *Config) GetWriteTimeout() uint32
  • 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 {
	NsqAddrs          []string `protobuf:"bytes,1,rep,name=nsq_addrs,json=nsqAddrs,proto3" json:"nsq_addrs,omitempty"`                             // nsq 服务地址
	DialTimeout       uint32   `protobuf:"varint,2,opt,name=dial_timeout,json=dialTimeout,proto3" json:"dial_timeout,omitempty"`                   // 连接超时
	ReadTimeout       uint32   `protobuf:"varint,3,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"`                   // 读超时
	WriteTimeout      uint32   `protobuf:"varint,4,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"`                // 写超时
	BatchSize         uint32   `protobuf:"varint,5,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`                         // 一次性拉取的消息条书
	HeartbeatInterval uint32   `protobuf:"varint,6,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"` // 一次性拉取的消息条书
	// contains filtered or unexported fields
}

func (*Config) Descriptor

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetBatchSize

func (x *Config) GetBatchSize() uint32

func (*Config) GetDialTimeout

func (x *Config) GetDialTimeout() uint32

func (*Config) GetHeartbeatInterval

func (x *Config) GetHeartbeatInterval() uint32

func (*Config) GetNsqAddrs

func (x *Config) GetNsqAddrs() []string

func (*Config) GetReadTimeout

func (x *Config) GetReadTimeout() uint32

func (*Config) GetWriteTimeout

func (x *Config) GetWriteTimeout() uint32

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