mock

Documentation

Index

• type Option
  • func WithAutoReply() Option
  • func WithCursors(v []uint64) Option
  • func WithLateSyncReply(r ...SyncReply) Option
  • func WithLiveSyncBlock() Option
  • func WithLiveSyncReplies(r ...uint64) Option
• type PullSyncMock
  • func NewPullSync(opts ...Option) *PullSyncMock
  • func (p *PullSyncMock) CancelRuid(ctx context.Context, peer penguin.Address, ruid uint32) error
  • func (p *PullSyncMock) Close() error
  • func (p *PullSyncMock) CursorsCalls(peer penguin.Address) bool
  • func (p *PullSyncMock) GetCursors(_ context.Context, peer penguin.Address) ([]uint64, error)
  • func (p *PullSyncMock) LiveSyncCalls(peer penguin.Address) (res []SyncCall)
  • func (p *PullSyncMock) SyncCalls(peer penguin.Address) (res []SyncCall)
  • func (p *PullSyncMock) SyncInterval(ctx context.Context, peer penguin.Address, bin uint8, from, to uint64) (topmost uint64, ruid uint32, err error)
  • func (p *PullSyncMock) TriggerChange()
• type SyncCall
• type SyncReply
  • func NewReply(bin uint8, from, top uint64, block bool) SyncReply

Types

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithAutoReply

func WithAutoReply() Option

WithAutoReply means that the pull syncer will automatically reply to incoming range requests with a top = from+limit. This is in order to force the requester to request a subsequent range.

func WithCursors

func WithCursors(v []uint64) Option

func WithLateSyncReply

func WithLateSyncReply(r ...SyncReply) Option

func WithLiveSyncBlock

func WithLiveSyncBlock() Option

WithLiveSyncBlock makes the protocol mock block on incoming live sync requests (identified by the math.MaxUint64 `to` field).

func WithLiveSyncReplies

func WithLiveSyncReplies(r ...uint64) Option

type PullSyncMock

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

func NewPullSync

func NewPullSync(opts ...Option) *PullSyncMock

func (*PullSyncMock) CancelRuid

func (p *PullSyncMock) CancelRuid(ctx context.Context, peer penguin.Address, ruid uint32) error

func (*PullSyncMock) Close

func (p *PullSyncMock) Close() error

func (*PullSyncMock) CursorsCalls

func (p *PullSyncMock) CursorsCalls(peer penguin.Address) bool

func (*PullSyncMock) GetCursors

func (p *PullSyncMock) GetCursors(_ context.Context, peer penguin.Address) ([]uint64, error)

func (*PullSyncMock) LiveSyncCalls

func (p *PullSyncMock) LiveSyncCalls(peer penguin.Address) (res []SyncCall)

func (*PullSyncMock) SyncCalls

func (p *PullSyncMock) SyncCalls(peer penguin.Address) (res []SyncCall)

func (*PullSyncMock) SyncInterval

func (p *PullSyncMock) SyncInterval(ctx context.Context, peer penguin.Address, bin uint8, from, to uint64) (topmost uint64, ruid uint32, err error)

func (*PullSyncMock) TriggerChange

func (p *PullSyncMock) TriggerChange()

type SyncCall

type SyncCall struct {
	Peer     penguin.Address
	Bin      uint8
	From, To uint64
	Live     bool
}

type SyncReply

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

func NewReply

func NewReply(bin uint8, from, top uint64, block bool) SyncReply