db

Documentation

Index

• Constants
• Variables
• func MatchWaitingIndexFunc(obj any) (bool, error)
• type BattleEvent
• type BattleVersionIndexer
  • func (i *BattleVersionIndexer) FromArgs(args ...any) ([]byte, error)
  • func (i *BattleVersionIndexer) FromObject(obj any) (bool, [][]byte, error)
• type Database
  • func NewDatabase() (*Database, error)
  • func (d *Database) Txn(write bool) *memdb.Txn
  • func (d *Database) Watch() *Watcher
• type Match
• type MatchPlayer
• type MatchPlayerIdIndexer
  • func (i *MatchPlayerIdIndexer) FromArgs(args ...interface{}) ([]byte, error)
  • func (i *MatchPlayerIdIndexer) FromObject(obj any) (bool, [][]byte, error)
• type Subscriber
  • func NewSubscriber(watcher *Watcher) *Subscriber
  • func (s *Subscriber) Close() error
  • func (s *Subscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)
• type Watcher
  • func NewWatcher() *Watcher
  • func (w *Watcher) Close()
  • func (w *Watcher) Closed() bool

Constants

const (
	TableBattle            = "battle"
	IndexBattleId          = "id"
	IndexBattleAggregateId = "aggregateId"
	IndexBattlePlayerId    = "playerId"
)

const (
	IndexMatchId        = "id"
	IndexMatchPlayerId  = "playerId"
	IndexMatchIsWaiting = "isWaiting"
)

const (
	TableMatch = "match"
)

Variables

var BattleTableSchema = &memdb.TableSchema{
	Name: TableBattle,
	Indexes: map[string]*memdb.IndexSchema{
		IndexBattleId: {
			Name:   IndexBattleId,
			Unique: true,
			Indexer: &memdb.StringFieldIndex{
				Field: "Id",
			},
		},
		IndexBattleAggregateId: {
			Name:    IndexBattleAggregateId,
			Unique:  true,
			Indexer: &BattleVersionIndexer{},
		},
	},
}

var DefaultSet = wire.NewSet(
	NewDatabase,
)

var MatchTableSchema = &memdb.TableSchema{
	Name: TableMatch,
	Indexes: map[string]*memdb.IndexSchema{
		IndexMatchId: {
			Name:   IndexMatchId,
			Unique: true,
			Indexer: &memdb.StringFieldIndex{
				Field: "Id",
			},
		},
		IndexMatchPlayerId: {
			Name:    IndexMatchPlayerId,
			Unique:  false,
			Indexer: &MatchPlayerIdIndexer{},
		},
		IndexMatchIsWaiting: {
			Name:   IndexMatchIsWaiting,
			Unique: false,
			Indexer: &memdb.ConditionalIndex{
				Conditional: MatchWaitingIndexFunc,
			},
		},
	},
}

Functions

func MatchWaitingIndexFunc

func MatchWaitingIndexFunc(obj any) (bool, error)

Types

type BattleEvent

type BattleEvent struct {
	Id          string
	AggregateId string
	Type        string
	Version     int
	CreatedAt   int64
}

type BattleVersionIndexer

type BattleVersionIndexer struct{}

func (*BattleVersionIndexer) FromArgs

func (i *BattleVersionIndexer) FromArgs(args ...any) ([]byte, error)

func (*BattleVersionIndexer) FromObject

func (i *BattleVersionIndexer) FromObject(obj any) (bool, [][]byte, error)

type Database

type Database struct {
	*memdb.MemDB
	// contains filtered or unexported fields
}

func NewDatabase

func NewDatabase() (*Database, error)

func (*Database) Txn

func (d *Database) Txn(write bool) *memdb.Txn

func (*Database) Watch

func (d *Database) Watch() *Watcher

type Match

type Match struct {
	Id      string
	Players []MatchPlayer
}

type MatchPlayer

type MatchPlayer struct {
	Id   string
	Team int
}

type MatchPlayerIdIndexer

type MatchPlayerIdIndexer struct{}

func (*MatchPlayerIdIndexer) FromArgs

func (i *MatchPlayerIdIndexer) FromArgs(args ...interface{}) ([]byte, error)

func (*MatchPlayerIdIndexer) FromObject

func (i *MatchPlayerIdIndexer) FromObject(obj any) (bool, [][]byte, error)

type Subscriber

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

func NewSubscriber

func NewSubscriber(watcher *Watcher) *Subscriber

func (*Subscriber) Close

func (s *Subscriber) Close() error

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)

type Watcher

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

func NewWatcher

func NewWatcher() *Watcher

func (*Watcher) Close

func (w *Watcher) Close()

func (*Watcher) Closed

func (w *Watcher) Closed() bool