redistr

Documentation

Index

• Variables
• type RedisReadWriter
  • func (r *RedisReadWriter) Close() error
  • func (r *RedisReadWriter) Configure(cfg *config.TrackConfigOptions) error
  • func (r *RedisReadWriter) ListIDs(ctx context.Context) ([]string, error)
  • func (r *RedisReadWriter) LoadTrackByID(ctx context.Context, trackID string) (*track.Track, error)
  • func (r *RedisReadWriter) WriteTrack(ctx context.Context, p *merged.Pilot) error

Variables

var (
	ReadWriter = &RedisReadWriter{stop: make(chan struct{})}
)

Types

type RedisReadWriter

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

func (*RedisReadWriter) Close

func (r *RedisReadWriter) Close() error

func (*RedisReadWriter) Configure

func (r *RedisReadWriter) Configure(cfg *config.TrackConfigOptions) error

func (*RedisReadWriter) ListIDs

func (r *RedisReadWriter) ListIDs(ctx context.Context) ([]string, error)

func (*RedisReadWriter) LoadTrackByID

func (r *RedisReadWriter) LoadTrackByID(ctx context.Context, trackID string) (*track.Track, error)

func (*RedisReadWriter) WriteTrack

func (r *RedisReadWriter) WriteTrack(ctx context.Context, p *merged.Pilot) error