redis

package

v0.2.0 Latest Latest Go to latest Published: Sep 14, 2019 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func (r *Record) Address() string

func (r *Record) ID() int64

func (r *Record) Text() string

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

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)