config

Documentation

Index

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

Types

type Config

type Config struct {
	RedisConfig            RedisStorageConfig
	InMemoryConfig         InmemStorageConfig
	RedisQueueConfig       RedisQueueConfig
	InMemQueueConfig       InMemQueueConfig
	HttpPort               int
	GrpcPort               int
	StorageType            StorageType
	QueueType              QueueType
	EncoderDecoderType     EncoderDecoderType
	ActionExecutorCapacity int
	ClusterConfig          cluster.Config
	RingConfig             cluster.RingConfig
}

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"