meeting

Dec 13, 2022

Changes in this version

+ var Clock clock.Clock = clock.WallClock

+ type Metrics interface

+ RequestCompleted func(startTime time.Time)

+ RequestsExpired func(count int)

+ type Params struct

+ DisableGC bool

+ ExpiryDuration time.Duration

+ ListenAddr string

+ Metrics Metrics

+ Store Store

+ WaitTimeout time.Duration

+ type Place struct

+ func NewPlace(params Params) (*Place, error)

+ func (p *Place) Close()

+ func (p *Place) Done(ctx context.Context, id string, data []byte) error

+ func (p *Place) NewRendezvous(ctx context.Context, id string, data []byte) error

+ func (p *Place) Wait(ctx context.Context, id string) (data0, data1 []byte, err error)

+ type Store interface

+ Context func(ctx context.Context) (_ context.Context, close func())

+ Get func(ctx context.Context, id string) (address string, err error)

+ Put func(ctx context.Context, id, address string) error

+ Remove func(ctx context.Context, id string) (time.Time, error)

+ RemoveOld func(ctx context.Context, address string, olderThan time.Time) (ids []string, err error)