config

Documentation

Index

• type ClusterConfig
• type Config
  • func (c Config) RPCAddr() (string, error)
• type EncoderDecoderType
• type InMemQueueConfig
• type InmemStorageConfig
• type QueueType
• type RedisQueueConfig
• type RedisStorageConfig
• type StorageType

Types

type ClusterConfig

type ClusterConfig struct {
	NodeName       string
	BindAddr       string
	Tags           map[string]string
	StartJoinAddrs []string
	PartitionCount int
}

type Config

type Config struct {
	RedisConfig        RedisStorageConfig
	InMemoryConfig     InmemStorageConfig
	RedisQueueConfig   RedisQueueConfig
	InMemQueueConfig   InMemQueueConfig
	HttpPort           int
	GrpcPort           int
	StorageType        StorageType
	QueueType          QueueType
	EncoderDecoderType EncoderDecoderType
	ClusterConfig      ClusterConfig
	BatchSize          int
	AnalyticsConfig    analytics.DataCollectorConfig
}

func (Config) RPCAddr

func (c Config) RPCAddr() (string, error)

type EncoderDecoderType

type EncoderDecoderType string

const JSON_ENCODER_DECODER EncoderDecoderType = "JSON"

const PROTO_ENCODER_DECODER EncoderDecoderType = "PROTO"

type InMemQueueConfig

type InMemQueueConfig struct {
}

type InmemStorageConfig

type InmemStorageConfig struct {
}

type QueueType

type QueueType string

const QUEUE_TYPE_REDIS QueueType = "redis"

const QUEUE_TYPE_SQS QueueType = "sqs"

type RedisQueueConfig

type RedisQueueConfig struct {
	Addrs     []string
	Namespace string
}

type RedisStorageConfig

type RedisStorageConfig struct {
	Addrs     []string
	Namespace string
}

type StorageType

type StorageType string

const STORAGE_TYPE_DYNAMO StorageType = "dynamo"

const STORAGE_TYPE_INMEM StorageType = "memory"

const STORAGE_TYPE_REDIS StorageType = "redis"