storage

Documentation

Index

• type PostgresStorage
  • func NewPostgresStorage(ctx context.Context, connection string, ping bool) (*PostgresStorage, error)
  • func (p *PostgresStorage) Close()
  • func (p *PostgresStorage) Done(ctx context.Context, id int) error
  • func (p *PostgresStorage) Processing(ctx context.Context, id int) error
  • func (p *PostgresStorage) SaveTask(ctx context.Context, taskType int, taskValue int) (int, error)
  • func (p *PostgresStorage) State(ctx context.Context, id int) (string, error)

Types

type PostgresStorage

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

func NewPostgresStorage

func NewPostgresStorage(ctx context.Context, connection string, ping bool) (*PostgresStorage, error)

func (*PostgresStorage) Close

func (p *PostgresStorage) Close()

func (*PostgresStorage) Done

func (p *PostgresStorage) Done(ctx context.Context, id int) error

func (*PostgresStorage) Processing

func (p *PostgresStorage) Processing(ctx context.Context, id int) error

func (*PostgresStorage) SaveTask

func (p *PostgresStorage) SaveTask(ctx context.Context, taskType int, taskValue int) (int, error)

func (*PostgresStorage) State

func (p *PostgresStorage) State(ctx context.Context, id int) (string, error)