snapmirror

Documentation

Index

• Constants
• func New(p *plugin.AbstractPlugin) plugin.Plugin
• type Peer
• type SnapMirror
  • func (m *SnapMirror) Init(remote conf.Remote) error
  • func (m *SnapMirror) Run(dataMap map[string]*matrix.Matrix) ([]*matrix.Matrix, *util.Metadata, error)

Constants

const PluginInvocationRate = 10

Functions

func New

func New(p *plugin.AbstractPlugin) plugin.Plugin

Types

type Peer

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

type SnapMirror

type SnapMirror struct {
	*plugin.AbstractPlugin
	// contains filtered or unexported fields
}

func (*SnapMirror) Init

func (m *SnapMirror) Init(remote conf.Remote) error

func (*SnapMirror) Run

func (m *SnapMirror) Run(dataMap map[string]*matrix.Matrix) ([]*matrix.Matrix, *util.Metadata, error)