mongodb

Documentation

Index

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

Variables

var DatabaseName = "keel"

DatabaseName is the database name in MongoDB, modify this variable to change database

Types

type MongoDB

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

func New

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

func (*MongoDB) ActivateTenants

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

func (*MongoDB) Close

func (m *MongoDB) Close() error

func (*MongoDB) CountTenantPendingTasks

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

func (*MongoDB) CreateTask

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

func (*MongoDB) CreateTenant

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

func (*MongoDB) FindActiveTenants

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

func (*MongoDB) FindPendingTasks

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

func (*MongoDB) GetTask

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

func (*MongoDB) GetTaskStatus

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

func (*MongoDB) GetTenant

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

func (*MongoDB) UpdateTaskStatus

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