Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrItemNotFound = errors.New("item not found")
)
Functions ¶
This section is empty.
Types ¶
type CacheClient ¶
type CacheClient struct {
// contains filtered or unexported fields
}
func NewCacheClient ¶
func NewCacheClient(cache *ristretto.Cache) *CacheClient
func (*CacheClient) Remove ¶
func (c *CacheClient) Remove(id string) error
type ProccessMessageFunc ¶
ProccessMessageFunc is a function that processes a message from Redis
type SqlClient ¶
type SqlClient struct {
// contains filtered or unexported fields
}
func NewSqlClient ¶
type StorageClient ¶
type StorageClient struct {
// contains filtered or unexported fields
}
func NewStorageClient ¶
func NewStorageClient(sql *SqlClient, cache Cache) *StorageClient
func (*StorageClient) ProcessCacheInvalidationMessage ¶
func (*StorageClient) UpsertItem ¶
type StreamProcessor ¶
type StreamProcessor struct { StreamName string // contains filtered or unexported fields }
StreamProcessor is a struct that processes messages from Redis
func NewStreamProcessor ¶
func NewStreamProcessor(streamName string, redis *redis.Client) *StreamProcessor
func (*StreamProcessor) Run ¶
func (p *StreamProcessor) Run(ctx context.Context, processMessage ProccessMessageFunc) error
Run function to process messages from Redis one by one
Click to show internal directories.
Click to hide internal directories.