watch

Documentation

Index

• type EventTransformer
• type Mux
  • func NewMux(gapTimeout time.Duration, bufferLen int, et EventTransformer) *Mux
  • func (m *Mux) Run(ctx context.Context)
  • func (m *Mux) StartWatch(ctx context.Context, client *clientv3.Client) (*Status, error)
  • func (m *Mux) Watch(ctx context.Context, req *etcdserverpb.WatchCreateRequest, ...) (func(), int64)
• type Status
  • func (s *Status) Close()

Types

type EventTransformer

type EventTransformer interface {
	MungeEvents([]*clientv3.Event) (metaRev int64, events []*mvccpb.Event, ok bool)
}

type Mux

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

Mux bridges between incoming watch connections from clients and outgoing watch connections to member clusters.

func NewMux

func NewMux(gapTimeout time.Duration, bufferLen int, et EventTransformer) *Mux

func (*Mux) Run

func (m *Mux) Run(ctx context.Context)

func (*Mux) StartWatch

func (m *Mux) StartWatch(ctx context.Context, client *clientv3.Client) (*Status, error)

func (*Mux) Watch

func (m *Mux) Watch(ctx context.Context, req *etcdserverpb.WatchCreateRequest, ch chan<- *etcdserverpb.WatchResponse) (func(), int64)

type Status

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

func (*Status) Close

func (s *Status) Close()