Versions in this module Expand all Collapse all v1 v1.1.0 Sep 17, 2015 Changes in this version + const CompressedMessages + const ConfigurationBucket + const MaxPartitionAge + const MaxPartitions + const MinPartitions + const NoPartitions + const PartitionCount + const QueueConfigName + const QueueDeletedStatsSuffix + const QueueDepthAprStatsSuffix + const QueueDepthStatsSuffix + const QueueFillDeltaStatsSuffix + const QueueReceivedStatsSuffix + const QueueSentStatsSuffix + const QueueSetName + const VisibilityTimeout + var DefaultSettings = map[string]string + var ErrConfigurationOptionNotFound = errors.New("Configuration Value Not Found") + var MaxIDSize = *big.NewInt(math.MaxInt64) + var Settings = [...]string + func GetNodePartitionRange(cfg *Config, list *memberlist.Memberlist) (int, int) + func InitMemberList(name string, port int, seedServers []string, seedPort int) (*memberlist.Memberlist, int, error) + type Config struct + Compressor compressor.Compressor + Core Core + Queues *Queues + RiakPool *riak.Client + Stats Stats + Topics *Topics + func GetCoreConfig(configFile *string) (*Config, error) + func (cfg *Config) GetCompressedMessages(queueName string) (bool, error) + func (cfg *Config) GetMaxPartitionAge(queueName string) (float64, error) + func (cfg *Config) GetMaxPartitions(queueName string) (int, error) + func (cfg *Config) GetMinPartitions(queueName string) (int, error) + func (cfg *Config) GetVisibilityTimeout(queueName string) (float64, error) + func (cfg *Config) InitializeQueue(queueName string) error + func (cfg *Config) RiakConnection() *riak.Client + func (cfg *Config) SetCompressedMessages(queueName string, compressedMessages bool) error + func (cfg *Config) SetMaxPartitionAge(queueName string, age float64) error + func (cfg *Config) SetMaxPartitions(queueName string, timeout int) error + func (cfg *Config) SetMinPartitions(queueName string, timeout int) error + func (cfg *Config) SetVisibilityTimeout(queueName string, timeout float64) error + type ConfigRequest struct + CompressedMessages *bool + MaxPartitionAge *float64 + MaxPartitions *int + MinPartitions *int + VisibilityTimeout *float64 + type Core struct + BackendConnectionPool int + HTTPPort int + LogLevel logrus.Level + LogLevelString string + Name string + Port int + RiakNodes string + SeedPort int + SeedServer string + SeedServers []string + SyncConfigInterval time.Duration + type HTTPApiV1 struct + func (h HTTPApiV1) InitWebserver(list *memberlist.Memberlist, cfg *Config) + type Partition struct + ID int + LastUsed time.Time + type Partitions struct + func InitPartitions(cfg *Config, queueName string) *Partitions + func (part *Partitions) GetPartition(cfg *Config, queueName string, list *memberlist.Memberlist) (int, int, *Partition, error) + func (part *Partitions) PartitionCount() int + func (part *Partitions) PushPartition(cfg *Config, queueName string, partition *Partition, lock bool) + type Queue struct + Config *riak.RDtMap + Name string + Parts *Partitions + func (queue *Queue) BatchDelete(cfg *Config, ids []string) (int, error) + func (queue *Queue) Delete(cfg *Config, id string) bool + func (queue *Queue) Get(cfg *Config, list *memberlist.Memberlist, batchsize int64) ([]riak.RObject, error) + func (queue *Queue) Put(cfg *Config, message string) string + func (queue *Queue) RetrieveMessages(ids []string, cfg *Config) []riak.RObject + type Queues struct + Config *riak.RDtMap + QueueMap map[string]*Queue + func (queues *Queues) DeleteQueue(name string, cfg *Config) bool + func (queues *Queues) Exists(cfg *Config, queueName string) bool + type Stats struct + Address string + Client stats.Client + FlushInterval int + Prefix string + Type string + type Topic struct + Config *riak.RDtMap + Name string + func (topic *Topic) AddQueue(cfg *Config, name string) + func (topic *Topic) Broadcast(cfg *Config, message string) map[string]string + func (topic *Topic) Delete(cfg *Config) + func (topic *Topic) DeleteQueue(cfg *Config, name string) + func (topic *Topic) ListQueues() []string + type Topics struct + Config *riak.RDtMap + TopicMap map[string]*Topic + func InitTopics(cfg *Config, queues *Queues) *Topics + func (topics *Topics) DeleteTopic(cfg *Config, name string) bool + func (topics *Topics) InitTopic(name string) v1.0.2 Feb 13, 2015 v1.0.1 Feb 4, 2015 v1.0.0 Jan 30, 2015
Go to main page