Documentation ¶
Index ¶
- type Service
- func (s *Service) Close() error
- func (s *Service) Del(ctx context.Context, ref *stategate.CacheRef) *errorz.Error
- func (s *Service) Get(ctx context.Context, ref *stategate.CacheRef) (*stategate.Cache, *errorz.Error)
- func (s *Service) GetEventChannel(ctx context.Context) (chan *stategate.Event, *errorz.Error)
- func (s *Service) GetMessageChannel(ctx context.Context) (chan *stategate.PeerMessage, *errorz.Error)
- func (s *Service) Lock(ctx context.Context, ref *stategate.Mutex) *errorz.Error
- func (s *Service) PublishEvent(ctx context.Context, event *stategate.Event) *errorz.Error
- func (s *Service) PublishMessage(ctx context.Context, message *stategate.PeerMessage) *errorz.Error
- func (s *Service) Set(ctx context.Context, value *stategate.Cache) *errorz.Error
- func (s *Service) Unlock(ctx context.Context, ref *stategate.MutexRef) *errorz.Error
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 (*Service) GetEventChannel ¶
func (*Service) GetMessageChannel ¶
func (*Service) PublishEvent ¶
func (*Service) PublishMessage ¶
Click to show internal directories.
Click to hide internal directories.