termination

Documentation

Index

• type Handler
  • func NewHandler(l Leaver) *Handler
  • func (t *Handler) Abort(ctx context.Context, reason string)
  • func (t *Handler) Leave(ctx context.Context, leaveAfter pulse.Number)
  • func (t *Handler) OnLeaveApproved(ctx context.Context)
  • func (t *Handler) Terminating() bool
• type Leaver
• type LeaverMock
  • func NewLeaverMock(t minimock.Tester) *LeaverMock
  • func (mmLeave *LeaverMock) Leave(ctx context.Context, ETA pulse.Number)
  • func (mmLeave *LeaverMock) LeaveAfterCounter() uint64
  • func (mmLeave *LeaverMock) LeaveBeforeCounter() uint64
  • func (m *LeaverMock) MinimockFinish()
  • func (m *LeaverMock) MinimockLeaveDone() bool
  • func (m *LeaverMock) MinimockLeaveInspect()
  • func (m *LeaverMock) MinimockWait(timeout mm_time.Duration)
• type LeaverMockLeaveExpectation
• type LeaverMockLeaveParams

Types

type Handler

type Handler struct {
	sync.Mutex

	Leaver        Leaver
	PulseAccessor beat.History `inject:""`
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(l Leaver) *Handler

func (*Handler) Abort

func (t *Handler) Abort(ctx context.Context, reason string)

func (*Handler) Leave

func (t *Handler) Leave(ctx context.Context, leaveAfter pulse.Number)

TODO take ETA by role of node

func (*Handler) OnLeaveApproved

func (t *Handler) OnLeaveApproved(ctx context.Context)

func (*Handler) Terminating

func (t *Handler) Terminating() bool

type Leaver

type Leaver interface {
	// Leave notify other nodes that this node want to leave and doesn't want to receive new tasks
	Leave(ctx context.Context, ETA pulse.Number)
}

type LeaverMock

type LeaverMock struct {
	LeaveMock mLeaverMockLeave
	// contains filtered or unexported fields
}

LeaverMock implements Leaver

func NewLeaverMock

func NewLeaverMock(t minimock.Tester) *LeaverMock

NewLeaverMock returns a mock for Leaver

func (*LeaverMock) Leave

func (mmLeave *LeaverMock) Leave(ctx context.Context, ETA pulse.Number)

Leave implements Leaver

func (*LeaverMock) LeaveAfterCounter

func (mmLeave *LeaverMock) LeaveAfterCounter() uint64

LeaveAfterCounter returns a count of finished LeaverMock.Leave invocations

func (*LeaverMock) LeaveBeforeCounter

func (mmLeave *LeaverMock) LeaveBeforeCounter() uint64

LeaveBeforeCounter returns a count of LeaverMock.Leave invocations

func (*LeaverMock) MinimockFinish

func (m *LeaverMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*LeaverMock) MinimockLeaveDone

func (m *LeaverMock) MinimockLeaveDone() bool

MinimockLeaveDone returns true if the count of the Leave invocations corresponds the number of defined expectations

func (*LeaverMock) MinimockLeaveInspect

func (m *LeaverMock) MinimockLeaveInspect()

MinimockLeaveInspect logs each unmet expectation

func (*LeaverMock) MinimockWait

func (m *LeaverMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

type LeaverMockLeaveExpectation

type LeaverMockLeaveExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

LeaverMockLeaveExpectation specifies expectation struct of the Leaver.Leave

type LeaverMockLeaveParams

type LeaverMockLeaveParams struct {
	ETA pulse.Number
	// contains filtered or unexported fields
}

LeaverMockLeaveParams contains parameters of the Leaver.Leave