watchers

Documentation

Overview

Copyright 2022 CodeNotary, Inc. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Variables
• type WatchersHub
  • func New(doneUpto uint64, maxWaiting int) *WatchersHub
  • func (w *WatchersHub) Close() error
  • func (w *WatchersHub) DoneUpto(t uint64) error
  • func (w *WatchersHub) Status() (doneUpto uint64, waiting int, err error)
  • func (w *WatchersHub) WaitFor(t uint64, cancellation <-chan struct{}) error

Variables

var ErrAlreadyClosed = errors.New("already closed")

var ErrCancellationRequested = errors.New("cancellation requested")

var ErrMaxWaitessLimitExceeded = errors.New("max waiting limit exceeded")

Types

type WatchersHub

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

func New

func New(doneUpto uint64, maxWaiting int) *WatchersHub

func (*WatchersHub) Close

func (w *WatchersHub) Close() error

func (*WatchersHub) DoneUpto

func (w *WatchersHub) DoneUpto(t uint64) error

func (*WatchersHub) Status

func (w *WatchersHub) Status() (doneUpto uint64, waiting int, err error)

func (*WatchersHub) WaitFor

func (w *WatchersHub) WaitFor(t uint64, cancellation <-chan struct{}) error