rendezvous

package

v1.14.0 Latest Latest Go to latest Published: Aug 1, 2023 License: Apache-2.0, MIT Imports: 17 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/berty/weshnet

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func GenerateRendezvousPointForPeriod(topic, seed []byte, date time.Time) []byte
func NextTimePeriod(date time.Time, interval time.Duration) time.Time
func RoundTimePeriod(date time.Time, interval time.Duration) time.Time
type EmitterClientOptions
type EmitterOptions
type EmitterPubSub
- func NewEmitterServer(serverAddr string, adminKey string, options *EmitterOptions) (*EmitterPubSub, error)
type EmitterPubSubSubscriptionDetails
type Point
type RotationInterval
- func NewRotationInterval(interval time.Duration) *RotationInterval
- func NewStaticRotationInterval() *RotationInterval
type SyncClient
- func NewEmitterClient(opts *EmitterClientOptions) SyncClient

Constants ¶

View Source

const DefaultRotationInterval = time.Hour * 24

View Source

const EmitterServiceType = "emitter-io"

Variables ¶

View Source

var (
	RotationGracePeriod  = time.Minute * 10
	MinimumDelayRotation = time.Minute
)

Functions ¶

func GenerateRendezvousPointForPeriod ¶

func GenerateRendezvousPointForPeriod(topic, seed []byte, date time.Time) []byte

func NextTimePeriod ¶

func NextTimePeriod(date time.Time, interval time.Duration) time.Time

func RoundTimePeriod ¶

func RoundTimePeriod(date time.Time, interval time.Duration) time.Time

Types ¶

type EmitterClientOptions ¶

type EmitterClientOptions struct {
	Logger *zap.Logger
}

type EmitterOptions ¶

type EmitterOptions struct {
	Logger           *zap.Logger
	ServerPublicAddr string
	EmitterOptions   []func(*emitter.Client)
}

type EmitterPubSub ¶

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

func NewEmitterServer ¶

func NewEmitterServer(serverAddr string, adminKey string, options *EmitterOptions) (*EmitterPubSub, error)

func (*EmitterPubSub) Close ¶

func (p *EmitterPubSub) Close() error

func (*EmitterPubSub) GetServiceType ¶

func (p *EmitterPubSub) GetServiceType() string

func (*EmitterPubSub) Register ¶

func (p *EmitterPubSub) Register(pid peer.ID, ns string, addrs [][]byte, ttlAsSeconds int, counter uint64)

func (p *EmitterPubSub) Subscribe(ns string) (string, error)

func (*EmitterPubSub) Unregister ¶

func (p *EmitterPubSub) Unregister(_ peer.ID, _ string)

type EmitterPubSubSubscriptionDetails ¶

type EmitterPubSubSubscriptionDetails struct {
	ServerAddr  string
	ReadKey     string
	ChannelName string
}

type Point ¶

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

func (*Point) Deadline ¶

func (p *Point) Deadline() time.Time

func (*Point) IsExpired ¶

func (p *Point) IsExpired() bool

func (*Point) NextPoint ¶

func (p *Point) NextPoint() *Point

func (*Point) RawRotationTopic ¶

func (p *Point) RawRotationTopic() []byte

func (*Point) RawTopic ¶

func (p *Point) RawTopic() []byte

func (*Point) RotationTopic ¶

func (p *Point) RotationTopic() string

func (*Point) Seed ¶

func (p *Point) Seed() []byte

func (*Point) TTL ¶

func (p *Point) TTL() time.Duration

func (*Point) Topic ¶

func (p *Point) Topic() string

type RotationInterval ¶

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

func NewRotationInterval ¶

func NewRotationInterval(interval time.Duration) *RotationInterval

func NewStaticRotationInterval ¶

func NewStaticRotationInterval() *RotationInterval

func (*RotationInterval) NewRendezvousPointForPeriod ¶

func (r *RotationInterval) NewRendezvousPointForPeriod(at time.Time, topic string, seed []byte) (point *Point)

func (*RotationInterval) NextTimePeriod ¶

func (r *RotationInterval) NextTimePeriod(at time.Time) time.Time

func (*RotationInterval) PointForRawRotation ¶

func (r *RotationInterval) PointForRawRotation(rotation []byte) (*Point, error)

func (*RotationInterval) PointForRotation ¶

func (r *RotationInterval) PointForRotation(rotation string) (*Point, error)

func (*RotationInterval) PointForTopic ¶

func (r *RotationInterval) PointForTopic(topic string) (*Point, error)

func (*RotationInterval) RegisterRotation ¶

func (r *RotationInterval) RegisterRotation(at time.Time, topic string, seed []byte)

func (*RotationInterval) RoundTimePeriod ¶

func (r *RotationInterval) RoundTimePeriod(at time.Time) time.Time

type SyncClient ¶

type SyncClient interface {
	rendezvous.RendezvousSyncClient

	io.Closer
}

func NewEmitterClient ¶

func NewEmitterClient(opts *EmitterClientOptions) SyncClient

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func GenerateRendezvousPointForPeriod ¶

func NextTimePeriod ¶

func RoundTimePeriod ¶

Types ¶

type EmitterClientOptions ¶

type EmitterOptions ¶

type EmitterPubSub ¶

func NewEmitterServer ¶

func (*EmitterPubSub) Close ¶

func (*EmitterPubSub) GetServiceType ¶

func (*EmitterPubSub) Register ¶

func (*EmitterPubSub) Subscribe ¶

func (*EmitterPubSub) Unregister ¶

type EmitterPubSubSubscriptionDetails ¶

type Point ¶

func (*Point) Deadline ¶

func (*Point) IsExpired ¶

func (*Point) NextPoint ¶

func (*Point) RawRotationTopic ¶

func (*Point) RawTopic ¶

func (*Point) RotationTopic ¶

func (*Point) Seed ¶

func (*Point) TTL ¶

func (*Point) Topic ¶

type RotationInterval ¶

func NewRotationInterval ¶

func NewStaticRotationInterval ¶

func (*RotationInterval) NewRendezvousPointForPeriod ¶

func (*RotationInterval) NextTimePeriod ¶

func (*RotationInterval) PointForRawRotation ¶

func (*RotationInterval) PointForRotation ¶

func (*RotationInterval) PointForTopic ¶

func (*RotationInterval) RegisterRotation ¶

func (*RotationInterval) RoundTimePeriod ¶

type SyncClient ¶

func NewEmitterClient ¶

Source Files ¶