memory

Documentation

Index

• type LockerMap
  • func NewLockerMap() *LockerMap
  • func (m *LockerMap) Close() error
  • func (m *LockerMap) NewLocker(ctx context.Context, key sync.Key) (sync.Locker, error)
• type PubSub
  • func NewPubSub() *PubSub
  • func (m *PubSub) Publish(publisherID *time.ActorID, topic string, event sync.DocEvent)
  • func (m *PubSub) Subscribe(subscriber types.Client, topics []string) (*sync.Subscription, map[string][]types.Client, error)
  • func (m *PubSub) Unsubscribe(topics []string, sub *sync.Subscription)

Types

type LockerMap

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

LockerMap is locker map based on memory.

func NewLockerMap

func NewLockerMap() *LockerMap

NewLockerMap creates an instance of LockerMap.

func (*LockerMap) Close

func (m *LockerMap) Close() error

Close closes all resources of this LockerMap.

func (*LockerMap) NewLocker

func (m *LockerMap) NewLocker(
	ctx context.Context,
	key sync.Key,
) (sync.Locker, error)

NewLocker creates locker of the given key.

type PubSub

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

PubSub is the memory implementation of PubSub, used for single agent or tests.

func NewPubSub

func NewPubSub() *PubSub

NewPubSub creates an instance of PubSub.

func (*PubSub) Publish

func (m *PubSub) Publish(
	publisherID *time.ActorID,
	topic string,
	event sync.DocEvent,
)

Publish publishes the given event to the given Topic.

func (*PubSub) Subscribe

func (m *PubSub) Subscribe(
	subscriber types.Client,
	topics []string,
) (*sync.Subscription, map[string][]types.Client, error)

Subscribe subscribes to the given topics.

func (*PubSub) Unsubscribe

func (m *PubSub) Unsubscribe(topics []string, sub *sync.Subscription)

Unsubscribe unsubscribes the given topics.