query

Documentation

Index

• type ProviderRepository
  • func NewProviderRepository(db *mongodb.Mongo, collectionName string) *ProviderRepository
  • func (t *ProviderRepository) DeleteProviders(ctx context.Context, name string) error
  • func (t *ProviderRepository) FindProviders(ctx context.Context) ([]entity.Provider, error)
  • func (t *ProviderRepository) GetProvider(ctx context.Context, filter any) (*entity.Provider, error)
  • func (t *ProviderRepository) GetProviderWithTasks(ctx context.Context, id primitive.ObjectID) (*entity.Provider, error)
  • func (t *ProviderRepository) InsertProvider(ctx context.Context, provider *entity.Provider) error
  • func (t *ProviderRepository) UpdateProvider(ctx context.Context, provider *entity.Provider) error
• type TaskRepository
  • func NewTaskRepository(db *mongodb.Mongo, collectionName string) *TaskRepository
  • func (t *TaskRepository) GetTasks(ctx context.Context, opt *options.FindOptions) ([]valueobject.Task, error)
  • func (t *TaskRepository) InsertTask(ctx context.Context, task valueobject.Task) error

Types

type ProviderRepository

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

func NewProviderRepository

func NewProviderRepository(db *mongodb.Mongo, collectionName string) *ProviderRepository

func (*ProviderRepository) DeleteProviders

func (t *ProviderRepository) DeleteProviders(ctx context.Context, name string) error

func (*ProviderRepository) FindProviders

func (t *ProviderRepository) FindProviders(ctx context.Context) ([]entity.Provider, error)

func (*ProviderRepository) GetProvider

func (t *ProviderRepository) GetProvider(ctx context.Context, filter any) (*entity.Provider, error)

func (*ProviderRepository) GetProviderWithTasks

func (t *ProviderRepository) GetProviderWithTasks(ctx context.Context, id primitive.ObjectID) (*entity.Provider, error)

func (*ProviderRepository) InsertProvider

func (t *ProviderRepository) InsertProvider(ctx context.Context, provider *entity.Provider) error

func (*ProviderRepository) UpdateProvider

func (t *ProviderRepository) UpdateProvider(ctx context.Context, provider *entity.Provider) error

type TaskRepository

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

func NewTaskRepository

func NewTaskRepository(db *mongodb.Mongo, collectionName string) *TaskRepository

func (*TaskRepository) GetTasks

func (t *TaskRepository) GetTasks(ctx context.Context, opt *options.FindOptions) ([]valueobject.Task, error)

func (*TaskRepository) InsertTask

func (t *TaskRepository) InsertTask(ctx context.Context, task valueobject.Task) error