client

Documentation

Index

• type Client
• type SearchClient
  • func New(dsnString string) (SearchClient, error)

Types

type Client

type Client interface {
	PublishWithin(peer dmesh.Peer, timeout time.Duration)
	PublishNow(peer dmesh.Peer) error
}

type SearchClient

type SearchClient interface {
	Client
	Peers() (out []*dmesh.SearchPeer)
	Start(ctx context.Context, watchServices []string) error
	Close() error
}

func New

func New(dsnString string) (SearchClient, error)