memory

Documentation

Index

• type Coordinator
  • func NewCoordinator(agentInfo *sync.AgentInfo) *Coordinator
  • func (m *Coordinator) Close() error
  • func (m *Coordinator) Members() map[string]*sync.AgentInfo
  • func (m *Coordinator) NewLocker(ctx context.Context, key sync.Key) (sync.Locker, error)
  • func (m *Coordinator) Publish(_ context.Context, publisherID *time.ActorID, event sync.DocEvent)
  • func (m *Coordinator) PublishToLocal(_ context.Context, publisherID *time.ActorID, event sync.DocEvent)
  • func (m *Coordinator) Subscribe(_ context.Context, subscriber types.Client, keys []*key.Key) (*sync.Subscription, map[string][]types.Client, error)
  • func (m *Coordinator) Unsubscribe(_ context.Context, keys []*key.Key, sub *sync.Subscription) error
  • func (m *Coordinator) UpdateMetadata(_ context.Context, publisher *types.Client, keys []*key.Key) (*sync.DocEvent, error)
• type PubSub
  • func NewPubSub() *PubSub
  • func (m *PubSub) BuildPeersMap(keys []*key.Key) map[string][]types.Client
  • func (m *PubSub) Publish(publisherID *time.ActorID, event sync.DocEvent)
  • func (m *PubSub) Subscribe(subscriber types.Client, keys []*key.Key) (*sync.Subscription, error)
  • func (m *PubSub) Unsubscribe(docKeys []*key.Key, sub *sync.Subscription)
  • func (m *PubSub) UpdateMetadata(publisher *types.Client, keys []*key.Key) *sync.Subscription

Types

type Coordinator

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

Coordinator is a memory-based implementation of sync.Coordinator.

func NewCoordinator

func NewCoordinator(agentInfo *sync.AgentInfo) *Coordinator

NewCoordinator creates an instance of Coordinator.

func (*Coordinator) Close

func (m *Coordinator) Close() error

Close closes all resources of this Coordinator.

func (*Coordinator) Members

func (m *Coordinator) Members() map[string]*sync.AgentInfo

Members returns the members of this cluster.

func (*Coordinator) NewLocker

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

NewLocker creates locker of the given key.

func (*Coordinator) Publish

func (m *Coordinator) Publish(
	_ context.Context,
	publisherID *time.ActorID,
	event sync.DocEvent,
)

Publish publishes the given event.

func (*Coordinator) PublishToLocal

func (m *Coordinator) PublishToLocal(
	_ context.Context,
	publisherID *time.ActorID,
	event sync.DocEvent,
)

PublishToLocal publishes the given event.

func (*Coordinator) Subscribe

func (m *Coordinator) Subscribe(
	_ context.Context,
	subscriber types.Client,
	keys []*key.Key,
) (*sync.Subscription, map[string][]types.Client, error)

Subscribe subscribes to the given documents.

func (*Coordinator) Unsubscribe

func (m *Coordinator) Unsubscribe(
	_ context.Context,
	keys []*key.Key,
	sub *sync.Subscription,
) error

Unsubscribe unsubscribes the given documents.

func (*Coordinator) UpdateMetadata

func (m *Coordinator) UpdateMetadata(
	_ context.Context,
	publisher *types.Client,
	keys []*key.Key,
) (*sync.DocEvent, error)

UpdateMetadata updates the metadata of the given client.

type PubSub

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

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

func NewPubSub

func NewPubSub() *PubSub

NewPubSub creates an instance of PubSub.

func (*PubSub) BuildPeersMap

func (m *PubSub) BuildPeersMap(keys []*key.Key) map[string][]types.Client

BuildPeersMap builds the peers map of the given keys.

func (*PubSub) Publish

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

Publish publishes the given event.

func (*PubSub) Subscribe

func (m *PubSub) Subscribe(
	subscriber types.Client,
	keys []*key.Key,
) (*sync.Subscription, error)

Subscribe subscribes to the given document keys.

func (*PubSub) Unsubscribe

func (m *PubSub) Unsubscribe(
	docKeys []*key.Key,
	sub *sync.Subscription,
)

Unsubscribe unsubscribes the given docKeys.

func (*PubSub) UpdateMetadata

func (m *PubSub) UpdateMetadata(
	publisher *types.Client,
	keys []*key.Key,
) *sync.Subscription

UpdateMetadata updates the metadata of the given client.