pulse

Documentation

Overview

Package pulse provides ev cluster-management service based on pubsub.

Index

• Constants
• func NewValidator(rt RoutingTable) pubsub.ValidatorEx
• type Heartbeat
  • func NewHeartbeat() Heartbeat
  • func (h *Heartbeat) Bind(msg *pubsub.Message) (err error)
  • func (h Heartbeat) Meta() (routing.Meta, error)
  • func (h *Heartbeat) ReadMessage(m *capnp.Message) (err error)
  • func (h Heartbeat) Server() routing.ID
  • func (h Heartbeat) SetMeta(fields []routing.MetaField) error
  • func (h Heartbeat) SetServer(id routing.ID)
  • func (h Heartbeat) SetTTL(d time.Duration)
  • func (h Heartbeat) TTL() (d time.Duration)
• type Preparer
• type RoutingTable

Constants

const DefaultTTL = time.Second * 10

Functions

func NewValidator

func NewValidator(rt RoutingTable) pubsub.ValidatorEx

Types

type Heartbeat

type Heartbeat struct{ api.Heartbeat }

func NewHeartbeat

func NewHeartbeat() Heartbeat

func (*Heartbeat) Bind

func (h *Heartbeat) Bind(msg *pubsub.Message) (err error)

func (Heartbeat) Meta

func (h Heartbeat) Meta() (routing.Meta, error)

func (*Heartbeat) ReadMessage

func (h *Heartbeat) ReadMessage(m *capnp.Message) (err error)

func (Heartbeat) Server

func (h Heartbeat) Server() routing.ID

func (Heartbeat) SetMeta

func (h Heartbeat) SetMeta(fields []routing.MetaField) error

func (Heartbeat) SetServer

func (h Heartbeat) SetServer(id routing.ID)

func (Heartbeat) SetTTL

func (h Heartbeat) SetTTL(d time.Duration)

func (Heartbeat) TTL

func (h Heartbeat) TTL() (d time.Duration)

type Preparer

type Preparer interface {
	Prepare(Heartbeat) error
}

type RoutingTable

type RoutingTable interface {
	Upsert(routing.Record) bool
}