link

Documentation

Index

• Constants
• func New(name string, params core.Params) (core.Link, error)
• type Replicator
  • func (repl *Replicator) AddLink(link core.Link) error
  • func (repl *Replicator) LinkTo(links []core.Link) error
  • func (repl *Replicator) RemoveLink(link core.Link) error

Constants

const (
	ReplMsgSendTimeout = 50 * time.Millisecond
)

Functions

func New

func New(name string, params core.Params) (core.Link, error)

Types

type Replicator

type Replicator struct {
	Name string

	*core.Connector
	// contains filtered or unexported fields
}

func (*Replicator) AddLink

func (repl *Replicator) AddLink(link core.Link) error

func (*Replicator) LinkTo

func (repl *Replicator) LinkTo(links []core.Link) error

func (*Replicator) RemoveLink

func (repl *Replicator) RemoveLink(link core.Link) error