Versions in this module Expand all Collapse all v0 v0.1.0 May 5, 2020 Changes in this version + type SharedMem struct + Conn redis.Conn + func New(logger *logrus.Logger, addr string, port int) (*SharedMem, error) + func (m *SharedMem) AsyncPublishMessage(data domain.Message) error + func (m *SharedMem) AsyncWriteEntity(data domain.Entity) error + func (m *SharedMem) NewSubscriber() (sharedmem.Subscriber, error) + func (m *SharedMem) SyncReadEntity() (domain.Entity, error) + type Subscriber struct + func (sub *Subscriber) SyncSubscribeMessage() (domain.Message, error)