mongodb_redis

Documentation

Index

• type MongoDBRedis
  • func New(dsn string) (*MongoDBRedis, error)
  • func (m *MongoDBRedis) ActivateTenants(ctx context.Context, opt types.ActivateTenantsOption) error
  • func (m *MongoDBRedis) Close() error
  • func (m *MongoDBRedis) CountTenantPendingTasks(ctx context.Context, opt types.CountTenantPendingTasksOption) (int64, error)
  • func (m *MongoDBRedis) CreateTask(ctx context.Context, t entity.Task) error
  • func (m *MongoDBRedis) CreateTenant(ctx context.Context, t entity.Tenant) error
  • func (m *MongoDBRedis) FindActiveTenants(ctx context.Context, opt types.FindActiveTenantsOption) (entity.Tenants, error)
  • func (m *MongoDBRedis) FindPendingTasks(ctx context.Context, opt types.FindPendingTasksOption) (entity.Tasks, error)
  • func (m *MongoDBRedis) GetTask(ctx context.Context, opt types.GetTaskOption) (*entity.Task, error)
  • func (m *MongoDBRedis) GetTaskStatus(ctx context.Context, opt types.GetTaskStatusOption) (enum.TaskStatus, error)
  • func (m *MongoDBRedis) GetTenant(ctx context.Context, opt types.GetTenantOption) (*entity.Tenant, error)
  • func (m *MongoDBRedis) UpdateTaskStatus(ctx context.Context, opt types.UpdateTaskStatusOption) error

Types

type MongoDBRedis

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

func New

func New(dsn string) (*MongoDBRedis, error)

func (*MongoDBRedis) ActivateTenants

func (m *MongoDBRedis) ActivateTenants(ctx context.Context, opt types.ActivateTenantsOption) error

func (*MongoDBRedis) Close

func (m *MongoDBRedis) Close() error

func (*MongoDBRedis) CountTenantPendingTasks

func (m *MongoDBRedis) CountTenantPendingTasks(ctx context.Context, opt types.CountTenantPendingTasksOption) (int64, error)

func (*MongoDBRedis) CreateTask

func (m *MongoDBRedis) CreateTask(ctx context.Context, t entity.Task) error

func (*MongoDBRedis) CreateTenant

func (m *MongoDBRedis) CreateTenant(ctx context.Context, t entity.Tenant) error

func (*MongoDBRedis) FindActiveTenants

func (m *MongoDBRedis) FindActiveTenants(ctx context.Context, opt types.FindActiveTenantsOption) (entity.Tenants, error)

func (*MongoDBRedis) FindPendingTasks

func (m *MongoDBRedis) FindPendingTasks(ctx context.Context, opt types.FindPendingTasksOption) (entity.Tasks, error)

func (*MongoDBRedis) GetTask

func (m *MongoDBRedis) GetTask(ctx context.Context, opt types.GetTaskOption) (*entity.Task, error)

func (*MongoDBRedis) GetTaskStatus

func (m *MongoDBRedis) GetTaskStatus(ctx context.Context, opt types.GetTaskStatusOption) (enum.TaskStatus, error)

func (*MongoDBRedis) GetTenant

func (m *MongoDBRedis) GetTenant(ctx context.Context, opt types.GetTenantOption) (*entity.Tenant, error)

func (*MongoDBRedis) UpdateTaskStatus

func (m *MongoDBRedis) UpdateTaskStatus(ctx context.Context, opt types.UpdateTaskStatusOption) error