scuttlebutt

type Accept struct {
	Whitelist []string `json:"whitelist"`
	Blacklist []string `json:"blacklist"`
}

type CreateIdFn func() SourceId

type IsAccepted func(update *Update) bool

type Option func(*Scuttlebutt)

type Protocol interface {
	IsAccepted(peerAccept *Accept, update *Update) bool
	// 更新己方消息
	ApplyUpdates(update *Update) bool
	// 根据对端传来的 clock，计算出来的 delta。而 delta 是 Update 集合
	// 每个 stream 上记录对端传来的 clock，并且会随着后续从 stream 收到的 Update 不断更新
	History(peerSources Sources, accept *Accept) []*Update
}

type Scuttlebutt struct {
	Protocol
	*event.Emitter

	Accept  *Accept
	Sources Sources

	Streams int
	// contains filtered or unexported fields
}

type Sign func(update *Update) (string, error)

type SourceId string

type Sources map[SourceId]Timestamp

type Timestamp int64

type Update struct {
	Data      map[string]interface{} `json:"data"`
	Timestamp Timestamp              `json:"timestamp"`
	SourceId  SourceId               `json:"source_id"`
	From      SourceId               `json:"from"`
	Digest    string                 `json:"digest"`
}

type Verify func(update *Update) bool