connection

Documentation

Index

• type Connection
  • func New(peers map[peerpb.PeerID]*transport.ExternalClient, logger logger.Logger) *Connection
  • func (c *Connection) Run()
  • func (c *Connection) Send(to peerpb.PeerID, ctx context.Context, cmd *commandpb.Command, ...) error
  • func (c *Connection) SendToAll(ctx context.Context, cmd *commandpb.Command, ...)

Types

type Connection

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

func New

func New(peers map[peerpb.PeerID]*transport.ExternalClient, logger logger.Logger) *Connection

func (*Connection) Run

func (c *Connection) Run()

func (*Connection) Send

func (c *Connection) Send(to peerpb.PeerID,
	ctx context.Context, cmd *commandpb.Command,
	resC chan *commandpb.CommandResult, errC chan peerpb.PeerID,
) error

func (*Connection) SendToAll

func (c *Connection) SendToAll(
	ctx context.Context, cmd *commandpb.Command,
	resC chan *commandpb.CommandResult, errC chan peerpb.PeerID,
)