local

Documentation

Index

• type Local
  • func New(dsnURL *url.URL) (*Local, error)
  • func (l *Local) Close() error
  • func (l *Local) Peers() (out []*dmesh.SearchPeer)
  • func (l *Local) PublishNow(peer dmesh.Peer) error
  • func (l *Local) PublishWithin(peer dmesh.Peer, timeout time.Duration)
  • func (l *Local) RegisterPeer(peer dmesh.Peer)
  • func (l *Local) Start(ctx context.Context, watchServices []string) error

Types

type Local

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

func New

func New(dsnURL *url.URL) (*Local, error)

DNS example: `local://`

func (*Local) Close

func (l *Local) Close() error

func (*Local) Peers

func (l *Local) Peers() (out []*dmesh.SearchPeer)

func (*Local) PublishNow

func (l *Local) PublishNow(peer dmesh.Peer) error

func (*Local) PublishWithin

func (l *Local) PublishWithin(peer dmesh.Peer, timeout time.Duration)

func (*Local) RegisterPeer

func (l *Local) RegisterPeer(peer dmesh.Peer)

func (*Local) Start

func (l *Local) Start(ctx context.Context, watchServices []string) error