mysql_redis

Documentation

Index

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

Types

type MySQLRedis

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

func New

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

func (*MySQLRedis) ActivateTenants

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

func (*MySQLRedis) Close

func (m *MySQLRedis) Close() error

func (*MySQLRedis) CountTenantPendingTasks

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

func (*MySQLRedis) CreateTask

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

func (*MySQLRedis) CreateTenant

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

func (*MySQLRedis) FindActiveTenants

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

func (*MySQLRedis) FindPendingTasks

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

func (*MySQLRedis) GetTask

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

func (*MySQLRedis) GetTaskStatus

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

func (*MySQLRedis) GetTenant

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

func (*MySQLRedis) UpdateTaskStatus

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