Documentation
¶
Index ¶
- type CategoryCassandraBuilder
- func (b *CategoryCassandraBuilder) Active(flag bool) *CategoryCassandraBuilder
- func (b *CategoryCassandraBuilder) And() *CategoryCassandraBuilder
- func (b *CategoryCassandraBuilder) Limit(size int) *CategoryCassandraBuilder
- func (b *CategoryCassandraBuilder) Name(query string) *CategoryCassandraBuilder
- type CategoryEventKafka
- func (e *CategoryEventKafka) Created(ctx context.Context, category domain.Category) error
- func (e *CategoryEventKafka) HardRemoved(ctx context.Context, id string) error
- func (e *CategoryEventKafka) Removed(ctx context.Context, id string) error
- func (e *CategoryEventKafka) Restored(ctx context.Context, id string) error
- func (e *CategoryEventKafka) Updated(ctx context.Context, category domain.Category) error
- type CategoryRepositoryCassandra
- func (r *CategoryRepositoryCassandra) Fetch(ctx context.Context, params core.PaginationParams, filter core.FilterParams) ([]*domain.Category, error)
- func (r *CategoryRepositoryCassandra) FetchByID(ctx context.Context, id string, activeOnly bool) (*domain.Category, error)
- func (r *CategoryRepositoryCassandra) HardRemove(ctx context.Context, id string) error
- func (r *CategoryRepositoryCassandra) Remove(ctx context.Context, id string) error
- func (r *CategoryRepositoryCassandra) Replace(ctx context.Context, category domain.Category) error
- func (r *CategoryRepositoryCassandra) Restore(ctx context.Context, id string) error
- func (r *CategoryRepositoryCassandra) Save(ctx context.Context, category domain.Category) error
- type CategoryRootCassandraRepository
- func (r *CategoryRootCassandraRepository) AddItem(ctx context.Context, rootID string, item map[string]string) error
- func (r *CategoryRootCassandraRepository) Fetch(ctx context.Context, params core.PaginationParams) ([]*domain.CategoryByRoot, error)
- func (r *CategoryRootCassandraRepository) FetchByRoot(ctx context.Context, rootID string) (*domain.CategoryByRoot, error)
- func (r *CategoryRootCassandraRepository) HardRemoveList(ctx context.Context, rootID string) error
- func (r *CategoryRootCassandraRepository) RemoveItem(ctx context.Context, rootID, categoryID string) error
- func (r *CategoryRootCassandraRepository) Save(ctx context.Context, root domain.CategoryByRoot) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CategoryCassandraBuilder ¶
type CategoryCassandraBuilder struct {
Statement string
}
func (*CategoryCassandraBuilder) Active ¶
func (b *CategoryCassandraBuilder) Active(flag bool) *CategoryCassandraBuilder
func (*CategoryCassandraBuilder) And ¶
func (b *CategoryCassandraBuilder) And() *CategoryCassandraBuilder
func (*CategoryCassandraBuilder) Limit ¶
func (b *CategoryCassandraBuilder) Limit(size int) *CategoryCassandraBuilder
func (*CategoryCassandraBuilder) Name ¶
func (b *CategoryCassandraBuilder) Name(query string) *CategoryCassandraBuilder
type CategoryEventKafka ¶
type CategoryEventKafka struct {
// contains filtered or unexported fields
}
func NewCategoryEventKafka ¶
func NewCategoryEventKafka(cfg *config.Kernel) *CategoryEventKafka
func (*CategoryEventKafka) HardRemoved ¶
func (e *CategoryEventKafka) HardRemoved(ctx context.Context, id string) error
func (*CategoryEventKafka) Removed ¶
func (e *CategoryEventKafka) Removed(ctx context.Context, id string) error
type CategoryRepositoryCassandra ¶
type CategoryRepositoryCassandra struct {
// contains filtered or unexported fields
}
func NewCategoryRepositoryCassandra ¶
func NewCategoryRepositoryCassandra(pool *gocql.ClusterConfig) *CategoryRepositoryCassandra
func (*CategoryRepositoryCassandra) Fetch ¶
func (r *CategoryRepositoryCassandra) Fetch(ctx context.Context, params core.PaginationParams, filter core.FilterParams) ([]*domain.Category, error)
func (*CategoryRepositoryCassandra) HardRemove ¶
func (r *CategoryRepositoryCassandra) HardRemove(ctx context.Context, id string) error
func (*CategoryRepositoryCassandra) Remove ¶
func (r *CategoryRepositoryCassandra) Remove(ctx context.Context, id string) error
type CategoryRootCassandraRepository ¶
type CategoryRootCassandraRepository struct {
// contains filtered or unexported fields
}
func NewCategoryRootCassandraRepository ¶
func NewCategoryRootCassandraRepository(pool *gocql.ClusterConfig) *CategoryRootCassandraRepository
func (*CategoryRootCassandraRepository) Fetch ¶
func (r *CategoryRootCassandraRepository) Fetch(ctx context.Context, params core.PaginationParams) ([]*domain.CategoryByRoot, error)
func (*CategoryRootCassandraRepository) FetchByRoot ¶
func (r *CategoryRootCassandraRepository) FetchByRoot(ctx context.Context, rootID string) (*domain.CategoryByRoot, error)
func (*CategoryRootCassandraRepository) HardRemoveList ¶
func (r *CategoryRootCassandraRepository) HardRemoveList(ctx context.Context, rootID string) error
func (*CategoryRootCassandraRepository) RemoveItem ¶
func (r *CategoryRootCassandraRepository) RemoveItem(ctx context.Context, rootID, categoryID string) error
func (*CategoryRootCassandraRepository) Save ¶
func (r *CategoryRootCassandraRepository) Save(ctx context.Context, root domain.CategoryByRoot) error
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.