database

Documentation

Index

• type Database
• type MySQL
  • func NewMySQL(dsn string) *MySQL
  • func (db *MySQL) Delete(ctx context.Context, key model.Key) error
  • func (db *MySQL) Get(ctx context.Context, key model.Key) (model.Value, error)
  • func (db *MySQL) Put(ctx context.Context, key model.Key, value model.Value) error
  • func (db *MySQL) Run(ctx context.Context, ready chan<- struct{}) error

Types

type Database

type Database interface {
	Get(ctx context.Context, key model.Key) (model.Value, error)
	Put(ctx context.Context, key model.Key, value model.Value) error
	Delete(ctx context.Context, key model.Key) error
}

Database represents a database which has no insert and update method. We can use MySQL for inserting and updating but this is just an example.

type MySQL

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

func NewMySQL

func NewMySQL(dsn string) *MySQL

func (*MySQL) Delete

func (db *MySQL) Delete(ctx context.Context, key model.Key) error

func (*MySQL) Get

func (db *MySQL) Get(ctx context.Context, key model.Key) (model.Value, error)

func (*MySQL) Put

func (db *MySQL) Put(ctx context.Context, key model.Key, value model.Value) error

func (*MySQL) Run

func (db *MySQL) Run(ctx context.Context, ready chan<- struct{}) error