tsafe

Documentation

Index

• type Listener
• type Manager
  • func NewTSafeReplica() Manager

Types

type Listener

type Listener interface {
	On() <-chan struct{}
	Close()
}

type Manager

type Manager interface {
	Get(vChannel string) (Timestamp, error)
	Set(vChannel string, timestamp Timestamp) error
	Add(ctx context.Context, vChannel string, timestamp Timestamp)
	Remove(ctx context.Context, vChannel string)
	Watch() Listener
	WatchChannel(channel string) Listener

	Min() (string, Timestamp)
}

Manager is the interface for tsafe manager.

func NewTSafeReplica

func NewTSafeReplica() Manager