repository

Documentation

Index

• type GameEventsRedisRepository
  • func (r *GameEventsRedisRepository) AddGameEvents(timestamp *timestamppb.Timestamp, gameEvents []*common.GameEvent) error
  • func (r *GameEventsRedisRepository) GetGameEventsFrom(timestamp *timestamppb.Timestamp) ([]*common.GameEvent, error)
• type IGameEventsRepository
• type IRepositoryFactory
  • func GetRepositoryFactory(db string) IRepositoryFactory
• type ISampleRepository
• type RedisFactory
  • func (a *RedisFactory) MakeGameEventsRepository() IGameEventsRepository
  • func (rf *RedisFactory) MakeSampleRepository() ISampleRepository
• type SampleRedisRepository
  • func (r *SampleRedisRepository) AddSample(sample *playback.Sample) error
  • func (r *SampleRedisRepository) AddSamples(samples []*playback.Sample)
  • func (r *SampleRedisRepository) GetLatestSample() (*playback.Sample, error)
  • func (r *SampleRedisRepository) GetSamples(startTime *timestamppb.Timestamp, endTime *timestamppb.Timestamp) ([]*playback.Sample, error)

Types

type GameEventsRedisRepository

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

func (*GameEventsRedisRepository) AddGameEvents

func (r *GameEventsRedisRepository) AddGameEvents(timestamp *timestamppb.Timestamp, gameEvents []*common.GameEvent) error

TODO(matheusvtna, joseviccruz): maybe serialize events.

func (*GameEventsRedisRepository) GetGameEventsFrom

func (r *GameEventsRedisRepository) GetGameEventsFrom(timestamp *timestamppb.Timestamp) ([]*common.GameEvent, error)

type IGameEventsRepository

type IGameEventsRepository interface {
	AddGameEvents(*timestamppb.Timestamp, []*common.GameEvent) error
	GetGameEventsFrom(*timestamppb.Timestamp) ([]*common.GameEvent, error)
}

type IRepositoryFactory

type IRepositoryFactory interface {
	MakeSampleRepository() ISampleRepository
	MakeGameEventsRepository() IGameEventsRepository
}

func GetRepositoryFactory

func GetRepositoryFactory(db string) IRepositoryFactory

type ISampleRepository

type ISampleRepository interface {
	AddSample(sample *playback.Sample) error
	AddSamples(samples []*playback.Sample)
	GetLatestSample() (*playback.Sample, error)
	GetSamples(*timestamppb.Timestamp, *timestamppb.Timestamp) ([]*playback.Sample, error)
}

type RedisFactory

type RedisFactory struct {
}

func (*RedisFactory) MakeGameEventsRepository

func (a *RedisFactory) MakeGameEventsRepository() IGameEventsRepository

func (*RedisFactory) MakeSampleRepository

func (rf *RedisFactory) MakeSampleRepository() ISampleRepository

type SampleRedisRepository

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

func (*SampleRedisRepository) AddSample

func (r *SampleRedisRepository) AddSample(sample *playback.Sample) error

func (*SampleRedisRepository) AddSamples

func (r *SampleRedisRepository) AddSamples(samples []*playback.Sample)

func (*SampleRedisRepository) GetLatestSample

func (r *SampleRedisRepository) GetLatestSample() (*playback.Sample, error)

func (*SampleRedisRepository) GetSamples

func (r *SampleRedisRepository) GetSamples(startTime *timestamppb.Timestamp, endTime *timestamppb.Timestamp) ([]*playback.Sample, error)