repository

Documentation

Index

• type ByDateDesc
  • func (d ByDateDesc) Len() int
  • func (d ByDateDesc) Less(i, j int) bool
  • func (d ByDateDesc) Swap(i, j int)
• type MessageInMemoryStore
  • func NewMessageInMemoryStore() *MessageInMemoryStore
• type MessageRepository
  • func NewLRUCacheStore(size int, logger *zap.Logger) (MessageRepository, error)
• type MessageRepositoryInMemory
  • func NewMessageInMemory(store *MessageInMemoryStore) *MessageRepositoryInMemory
  • func (r *MessageRepositoryInMemory) Delete(ctx context.Context, id string) <-chan error
  • func (r *MessageRepositoryInMemory) Find(ctx context.Context, id string) <-chan QueryResult
  • func (r *MessageRepositoryInMemory) FindAll(ctx context.Context) <-chan QueryResult
  • func (r *MessageRepositoryInMemory) Reset(ctx context.Context) <-chan error
  • func (r *MessageRepositoryInMemory) Save(ctx context.Context, m *domain.Message) <-chan error
• type QueryResult

Types

type ByDateDesc

type ByDateDesc []domain.Message

ByDateDesc ...

func (ByDateDesc) Len

func (d ByDateDesc) Len() int

func (ByDateDesc) Less

func (d ByDateDesc) Less(i, j int) bool

func (ByDateDesc) Swap

func (d ByDateDesc) Swap(i, j int)

type MessageInMemoryStore

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

MessageInMemoryStore ...

func NewMessageInMemoryStore

func NewMessageInMemoryStore() *MessageInMemoryStore

NewMessageInMemoryStore ...

type MessageRepository

type MessageRepository interface {
	Save(context.Context, *domain.Message) <-chan error
	Delete(context.Context, string) <-chan error
	Reset(context.Context) <-chan error
	Find(context.Context, string) <-chan QueryResult
	FindAll(context.Context) <-chan QueryResult
}

MessageRepository ...

func NewLRUCacheStore

func NewLRUCacheStore(size int, logger *zap.Logger) (MessageRepository, error)

type MessageRepositoryInMemory

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

MessageRepositoryInMemory ...

func NewMessageInMemory

func NewMessageInMemory(store *MessageInMemoryStore) *MessageRepositoryInMemory

NewMessageInMemory ...

func (*MessageRepositoryInMemory) Delete

func (r *MessageRepositoryInMemory) Delete(ctx context.Context, id string) <-chan error

Delete ...

func (*MessageRepositoryInMemory) Find

func (r *MessageRepositoryInMemory) Find(ctx context.Context, id string) <-chan QueryResult

Find ...

func (*MessageRepositoryInMemory) FindAll

func (r *MessageRepositoryInMemory) FindAll(ctx context.Context) <-chan QueryResult

FindAll ...

func (*MessageRepositoryInMemory) Reset

func (r *MessageRepositoryInMemory) Reset(ctx context.Context) <-chan error

Reset ...

func (*MessageRepositoryInMemory) Save

func (r *MessageRepositoryInMemory) Save(ctx context.Context, m *domain.Message) <-chan error

Save ...

type QueryResult

type QueryResult struct {
	Result interface{}
	Error  error
}

QueryResult ...