watch

Documentation

Index

• type EtcdShardWatch
  • func (w *EtcdShardWatch) RegisteringEventCallback(eventCallback ShardEventCallback)
  • func (w *EtcdShardWatch) Start(ctx context.Context) error
  • func (w *EtcdShardWatch) Stop(_ context.Context) error
• type NoopShardWatch
  • func (n NoopShardWatch) RegisteringEventCallback(_ ShardEventCallback)
  • func (n NoopShardWatch) Start(_ context.Context) error
  • func (n NoopShardWatch) Stop(_ context.Context) error
• type ShardEventCallback
• type ShardExpireEvent
• type ShardRegisterEvent
• type ShardWatch
  • func NewEtcdShardWatch(logger *zap.Logger, clusterName string, rootPath string, ...) ShardWatch
  • func NewNoopShardWatch() ShardWatch

Types

type EtcdShardWatch

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

EtcdShardWatch used to watch the distributed lock of shard, and provide the corresponding callback function.

func (*EtcdShardWatch) RegisteringEventCallback

func (w *EtcdShardWatch) RegisteringEventCallback(eventCallback ShardEventCallback)

func (*EtcdShardWatch) Start

func (w *EtcdShardWatch) Start(ctx context.Context) error

func (*EtcdShardWatch) Stop

func (w *EtcdShardWatch) Stop(_ context.Context) error

type NoopShardWatch

type NoopShardWatch struct{}

func (NoopShardWatch) RegisteringEventCallback

func (n NoopShardWatch) RegisteringEventCallback(_ ShardEventCallback)

func (NoopShardWatch) Start

func (n NoopShardWatch) Start(_ context.Context) error

func (NoopShardWatch) Stop

func (n NoopShardWatch) Stop(_ context.Context) error

type ShardEventCallback

type ShardEventCallback interface {
	OnShardRegistered(ctx context.Context, event ShardRegisterEvent) error
	OnShardExpired(ctx context.Context, event ShardExpireEvent) error
}

type ShardExpireEvent

type ShardExpireEvent struct {
	ShardID       storage.ShardID
	OldLeaderNode string
	// contains filtered or unexported fields
}

type ShardRegisterEvent

type ShardRegisterEvent struct {
	ShardID       storage.ShardID
	NewLeaderNode string
	// contains filtered or unexported fields
}

type ShardWatch

type ShardWatch interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	RegisteringEventCallback(eventCallback ShardEventCallback)
}

func NewEtcdShardWatch

func NewEtcdShardWatch(logger *zap.Logger, clusterName string, rootPath string, client *clientv3.Client) ShardWatch

func NewNoopShardWatch

func NewNoopShardWatch() ShardWatch