redis

Documentation

Index

• type Record
  • func (r *Record) Address() string
  • func (r *Record) ID() int64
  • func (r *Record) Text() string
• type StorageService
  • func NewStorageService(address string, db int) *StorageService
  • func (s *StorageService) AllCreateEventsAfter(ctx context.Context, family string, lastId int64) <-chan drop.Record
  • func (s *StorageService) AllDeleteEvents(ctx context.Context, family string) <-chan drop.Record
  • func (s *StorageService) AllRecordsAfter(ctx context.Context, family string, startTime int64) (<-chan drop.Record, int64)
  • func (s *StorageService) DeleteRecord(family string, ikey int64) error
  • func (s *StorageService) GetRecord(family string, ikey int64) (drop.Record, error)
  • func (s *StorageService) PutRecord(family string, rec drop.Record) (int64, error)

Types

type Record

type Record struct {
	AddressField string `json:"Address"`
	TextField    string `json:"Text"`
	IDField      int64  `json:"ID"`
}

func (*Record) Address

func (r *Record) Address() string

func (*Record) ID

func (r *Record) ID() int64

func (*Record) Text

func (r *Record) Text() string

type StorageService

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

func NewStorageService

func NewStorageService(address string, db int) *StorageService

func (*StorageService) AllCreateEventsAfter

func (s *StorageService) AllCreateEventsAfter(ctx context.Context, family string, lastId int64) <-chan drop.Record

func (*StorageService) AllDeleteEvents

func (s *StorageService) AllDeleteEvents(ctx context.Context, family string) <-chan drop.Record

func (*StorageService) AllRecordsAfter

func (s *StorageService) AllRecordsAfter(ctx context.Context, family string, startTime int64) (<-chan drop.Record, int64)

func (*StorageService) DeleteRecord

func (s *StorageService) DeleteRecord(family string, ikey int64) error

func (*StorageService) GetRecord

func (s *StorageService) GetRecord(family string, ikey int64) (drop.Record, error)

func (*StorageService) PutRecord

func (s *StorageService) PutRecord(family string, rec drop.Record) (int64, error)