storage

type Cache interface {
	Set(id string, item Item) error
	Retreive(id string) (*Item, error)
	Remove(id string) error
}

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

type Item struct {
	ID          string    `json:"id" db:"id"`
	Name        string    `json:"name" db:"name"`
	Description string    `json:"description" db:"description"`
	Price       float64   `json:"price" db:"price"`
	CreatedAt   time.Time `json:"created_at" db:"created_at"`
	UpdatedAt   time.Time `json:"updated_at" db:"updated_at"`
}

type ProccessMessageFunc func(ctx context.Context, id string, values map[string]interface{}) error

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

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

type StreamProcessor struct {
	StreamName string
	// contains filtered or unexported fields
}