p2p

Documentation

Index

• type Config
  • func DevConfig() Config
  • func (cfg *Config) Init()
• type Host
  • func New(ctx context.Context, db *store.Store, cfg *Config) (*Host, error)
• type TopicHandler
  • func NewChannelDiscovery(pctx context.Context, h *Host, cfg *Config) (*TopicHandler, error)
  • func NewTopicHandler(h *Host, channel *store.Channel, start []byte, onRecv, onPublish entryHandler) (*TopicHandler, error)
  • func (th *TopicHandler) Done()
  • func (th *TopicHandler) ID() helpers.UUID
  • func (th *TopicHandler) Publish(entry *pb.Msg)

Types

type Config

type Config struct {
	MDNS     bool
	URI      string
	TCPAddr  string
	TCPPort  int
	QUICAddr string
	QUICPort int
	KeyFile  string
	Log      *log.Entry
}

func DevConfig

func DevConfig() Config

func (*Config) Init

func (cfg *Config) Init()

Init overrides the configuration values of the Config object with those passed in as flags

type Host

type Host struct {
	host.Host
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, db *store.Store, cfg *Config) (*Host, error)

type TopicHandler

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

func NewChannelDiscovery

func NewChannelDiscovery(pctx context.Context, h *Host, cfg *Config) (*TopicHandler, error)

func NewTopicHandler

func NewTopicHandler(h *Host, channel *store.Channel, start []byte, onRecv, onPublish entryHandler) (*TopicHandler, error)

func (*TopicHandler) Done

func (th *TopicHandler) Done()

Done is required to implement Store.SubscriptionTarget

func (*TopicHandler) ID

func (th *TopicHandler) ID() helpers.UUID

ID is required to implement Store.SubscriptionTarget

func (*TopicHandler) Publish

func (th *TopicHandler) Publish(entry *pb.Msg)

Publish is the callback required to implement Store.SubscriptionTarget. It gets called by the Store every time our subscription has a new entry to handle.