stoprestart

Documentation

Index

• func Topology(commType fsc.P2PCommunicationType, ...) []api.Topology
• type Initiator
  • func (p *Initiator) Call(context view.Context) (interface{}, error)
• type InitiatorViewFactory
  • func (i *InitiatorViewFactory) NewView(in []byte) (view.View, error)
• type Responder
  • func (p *Responder) Call(context view.Context) (interface{}, error)

Functions

func Topology

func Topology(commType fsc.P2PCommunicationType, replicationOpts *integration.ReplicationOptions) []api.Topology

Types

type Initiator

type Initiator struct{}

func (*Initiator) Call

func (p *Initiator) Call(context view.Context) (interface{}, error)

type InitiatorViewFactory

type InitiatorViewFactory struct{}

func (*InitiatorViewFactory) NewView

func (i *InitiatorViewFactory) NewView(in []byte) (view.View, error)

type Responder

type Responder struct{}

func (*Responder) Call

func (p *Responder) Call(context view.Context) (interface{}, error)