database

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(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