redis

package

v0.0.0-...-ba21cce Latest Latest Go to latest Published: Apr 16, 2018 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func UnmarshalJSONItem(js []byte) (web.Item, error)

UnmarshalJSONItem unmarshals a JSON payload into an item depending on whether the item is a message or a thread

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

func NewRedisControllerStore(host string) (*RedisControllerStore, error)

func (rcs *RedisControllerStore) Add(botID web.BotID) error

func (rcs *RedisControllerStore) Get(botID web.BotID) (web.ItemStore, error)

func (rcs *RedisControllerStore) Remove(botID web.BotID) error

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

func NewRedisConversationStore(host string) (*RedisConversationStore, error)

func (cs *RedisConversationStore) Active(botid web.BotID) (id, state string, err error)

func (cs *RedisConversationStore) End(botid web.BotID) error

func (cs *RedisConversationStore) GetData(botid web.BotID, key string) (string, error)

func (cs *RedisConversationStore) IsActive(botid web.BotID) bool

func (cs *RedisConversationStore) SetData(botid web.BotID, key, value string) error

func (cs *RedisConversationStore) SetState(botid web.BotID, state string) error

func (cs *RedisConversationStore) Start(botid web.BotID, id string) error

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

func (is *RedisItemStore) Add(item web.Item) error

func (is *RedisItemStore) Get(id, threadID web.ItemID) (web.Item, error)

func (is *RedisItemStore) Last(n int64, thread web.ItemID) (items []web.Item, err error)

func (is *RedisItemStore) Update(item web.Item) error