redis

package
v0.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 3, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Service

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

func NewService

func NewService(logger *logger.Logger, conn *redis.Client) *Service

func (*Service) Close

func (s *Service) Close() error

func (*Service) Del

func (s *Service) Del(ctx context.Context, ref *stategate.CacheRef) *errorz.Error

func (*Service) Get

func (*Service) GetEventChannel added in v0.11.0

func (s *Service) GetEventChannel(ctx context.Context) (chan *stategate.Event, *errorz.Error)

func (*Service) GetMessageChannel added in v0.11.0

func (s *Service) GetMessageChannel(ctx context.Context) (chan *stategate.PeerMessage, *errorz.Error)

func (*Service) Lock

func (s *Service) Lock(ctx context.Context, ref *stategate.Mutex) *errorz.Error

func (*Service) PublishEvent added in v0.11.0

func (s *Service) PublishEvent(ctx context.Context, event *stategate.Event) *errorz.Error

func (*Service) PublishMessage added in v0.11.0

func (s *Service) PublishMessage(ctx context.Context, message *stategate.PeerMessage) *errorz.Error

func (*Service) Set

func (s *Service) Set(ctx context.Context, value *stategate.Cache) *errorz.Error

func (*Service) Unlock

func (s *Service) Unlock(ctx context.Context, ref *stategate.MutexRef) *errorz.Error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL