conf

package
v0.0.0-...-a3e95bc Latest Latest
Warning

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

Go to latest
Published: Jun 16, 2017 License: Apache-2.0 Imports: 13 Imported by: 0

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

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 CLIParams

type CLIParams struct {
	DefaultMessageTTL    int64
	DefaultDeliveryDelay int64
}

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) Descriptor() ([]byte, []int)

func (*PQConfig) Equal

func (this *PQConfig) Equal(that interface{}) bool

func (*PQConfig) GoString

func (this *PQConfig) GoString() string

func (*PQConfig) Marshal

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

func (*PQConfig) MarshalTo

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

func (*PQConfig) ProtoMessage

func (*PQConfig) ProtoMessage()

func (*PQConfig) Reset

func (m *PQConfig) Reset()

func (*PQConfig) Size

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

func (*PQConfig) String

func (this *PQConfig) String() string

func (*PQConfig) Unmarshal

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL