broker

type App struct {
	// contains filtered or unexported fields
}

type Config struct {
	Version uint32 `json:"version"`

	Addr string `json:"addr"`

	HttpAddr string `json:"http_addr"`

	KeepAlive int `json:"keepalive"`

	MaxMessageSize int `json:"max_msg_size"`
	MessageTimeout int `json:"msg_timeout"`
	MaxQueueSize   int `json:"max_queue_size"`

	Store       string          `json:"store"`
	StoreConfig json.RawMessage `json:"store_config"`
}

type MemStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type MemStoreDriver struct {
}

type MsgHandler struct {
	// contains filtered or unexported fields
}

type RedisStore struct {
	// contains filtered or unexported fields
}

type RedisStoreConfig struct {
	Addr      string `json:"addr"`
	DB        int    `json:"db"`
	Password  string `json:"password"`
	IdleConns int    `json:"idle_conns"`
	KeyPrefix string `json:"key_prefix"`
}

type RedisStoreDriver struct {
}

type Store interface {
	Close() error
	GenerateID() (int64, error)
	Save(queue string, m *msg) error
	Delete(queue string, msgId int64) error
	Pop(queue string) error
	Front(queue string) (*msg, error)
	Len(queue string) (int, error)
}

type StoreDriver interface {
	Open(configJson json.RawMessage) (Store, error)
}