Documentation ¶
Overview ¶
Package conf is a generated protocol buffer package.
It is generated from these files:
conf/pqconfig.proto
It has these top-level messages:
PQConfig
Index ¶
- Variables
- type CLIParams
- type Config
- type PQConfig
- func (*PQConfig) Descriptor() ([]byte, []int)
- func (this *PQConfig) Equal(that interface{}) bool
- func (this *PQConfig) GoString() string
- func (m *PQConfig) Marshal() (data []byte, err error)
- func (m *PQConfig) MarshalTo(data []byte) (int, error)
- func (*PQConfig) ProtoMessage()
- func (m *PQConfig) Reset()
- func (m *PQConfig) Size() (n int)
- func (this *PQConfig) String() string
- func (m *PQConfig) Unmarshal(data []byte) error
- type PQueueConfigData
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthPqconfig = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPqconfig = fmt.Errorf("proto: integer overflow") )
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { FMPQServerInterface string `long:"fmpq-address" description:"FireMPQ native protocol." default:":8222"` SQSServerInterface string `long:"sqs-address" description:"SQS protocol interface for FireMPQ" default:""` SNSServerInterface string // `long:"sns-address" description:"NOT IMPLEMENTED: SNS protocol interface for FireMPQ" default:""` DbFlushInterval int64 `long:"flush-interval" description:"Disk synchronization interval in milliseconds" default:"100"` DatabasePath string `long:"data-dir" description:"FireMPQ database location" default:"./fmpq-data"` UpdateInterval int64 `long:"update-interval" description:"Timeout and expiration check period in milliseconds" default:"100"` PQueueConfig PQueueConfigData TextLogLevel string `long:"log-level" description:"Log level" default:"info" choice:"debug" choice:"info" choice:"warning"` PrintConfig bool `long:"log-config" description:"Print current config values"` Profiler string `long:"profiler-address" description:"Enables Go profiler on the defined interface:port" default:""` LogLevel logging.Level }
Config is a generic service config type.
var CFG *Config
func ParseConfigParameters ¶
func ParseConfigParameters() *Config
type PQConfig ¶
type PQConfig struct { // Default message TTL. MsgTtl int64 `protobuf:"varint,1,opt,name=msg_ttl,json=msgTtl,proto3" json:"msg_ttl,omitempty"` // Default delivery delay. DeliveryDelay int64 `protobuf:"varint,2,opt,name=delivery_delay,json=deliveryDelay,proto3" json:"delivery_delay,omitempty"` // Timeout before message is getting released. PopLockTimeout int64 `protobuf:"varint,3,opt,name=pop_lock_timeout,json=popLockTimeout,proto3" json:"pop_lock_timeout,omitempty"` // Pop count limit. 0 - unlimited. >0 Will be removed after this number of attempts. PopCountLimit int64 `protobuf:"varint,4,opt,name=pop_count_limit,json=popCountLimit,proto3" json:"pop_count_limit,omitempty"` // Max queue size. MaxMsgsInQueue int64 `protobuf:"varint,5,opt,name=max_msgs_in_queue,json=maxMsgsInQueue,proto3" json:"max_msgs_in_queue,omitempty"` // Max message size in bytes; MaxMsgSize int64 `protobuf:"varint,6,opt,name=max_msg_size,json=maxMsgSize,proto3" json:"max_msg_size,omitempty"` // Last time item has been pushed into queue. LastPushTs int64 `protobuf:"varint,7,opt,name=last_push_ts,json=lastPushTs,proto3" json:"last_push_ts,omitempty"` // Last pop time. LastPopTs int64 `protobuf:"varint,8,opt,name=last_pop_ts,json=lastPopTs,proto3" json:"last_pop_ts,omitempty"` // Pop wait timeout. PopWaitTimeout int64 `protobuf:"varint,9,opt,name=pop_wait_timeout,json=popWaitTimeout,proto3" json:"pop_wait_timeout,omitempty"` // Messages exceeded number of pop attemts will be moved into this queue if configured PopLimitQueueName string `protobuf:"bytes,10,opt,name=pop_limit_queue_name,json=popLimitQueueName,proto3" json:"pop_limit_queue_name,omitempty"` // Time stamp config was modified last time. LastUpdateTs int64 `protobuf:"varint,11,opt,name=last_update_ts,json=lastUpdateTs,proto3" json:"last_update_ts,omitempty"` }
func (*PQConfig) Descriptor ¶
func (*PQConfig) ProtoMessage ¶
func (*PQConfig) ProtoMessage()
type PQueueConfigData ¶
type PQueueConfigData struct { DefaultMessageTTL int64 `long:"msg-ttl" description:"Default message TTL for a new queue in milliseconds" default:"345600000"` DefaultDeliveryDelay int64 `long:"delivery-delay" description:"Default message delivery delay for a new queue in milliseconds" default:"0"` DefaultLockTimeout int64 `long:"lock-timeout" description:"Default message lock/visibility timeout for a new queue in milliseconds" default:"60000"` DefaultPopCountLimit int64 `long:"pop-count-limit" description:"Default receive attempts limit per message for a new queue" default:"99"` DefaultMaxQueueSize int64 `long:"max-queue-size" description:"Default max number of messages per queue" default:"100000000"` DefaultPopWaitTimeout int64 `long:"wait-timeout" description:"Default wait timeout to receive a message for a new queue in milliseconds." default:"0"` MaxPopWaitTimeout int64 `long:"max-wait-timeout" description:"Limit receive wait timeout. Milliseconds." default:"20000"` MaxPopBatchSize int64 `long:"max-receive-batch" description:"Limit the number of received messages at once." default:"10"` MaxLockTimeout int64 `long:"max-lock-timeout" description:"Max lock/visibility timeout in milliseconds" default:"43200000"` MaxDeliveryDelay int64 `long:"max-delivery-delay" description:"Maximum delivery delay in milliseconds." default:"900000"` MaxMessageTTL int64 `long:"max-message-ttl" description:"Maximum message TTL for the queue. In milliseconds" default:"345600000"` MaxMessageSize int64 `long:"max-message-size" description:"Maximum message size in bytes." default:"262144"` TimeoutCheckBatchSize int64 `` /* 166-byte string literal not displayed */ }
var CFG_PQ *PQueueConfigData
Click to show internal directories.
Click to hide internal directories.