conns

Documentation

Index

• func NewCache(nodeID uint64, top network.NetTopology, maxPayload int, key signature.KeyPair, ...) *cache
• func NewPool(size int, nodeID uint64, top network.NetTopology, maxPayload int, ...) *pool
• type AckID
• type Cache
• type MuConn
• type PendingAck
• type Pool

Functions

func NewCache

func NewCache(nodeID uint64, top network.NetTopology, maxPayload int, key signature.KeyPair, connection service.CONNECTION) *cache

func NewPool

func NewPool(size int, nodeID uint64, top network.NetTopology, maxPayload int, key signature.KeyPair, connection service.CONNECTION) *pool

Types

type AckID

type AckID struct {
	NodeID    uint64
	RequestID uint64
}

type Cache

type Cache interface {
	Close()
	WriteRequest(
		nodeID uint64, msg *service.Message, timeout time.Duration, ack bool,
		cb func(uint64, *service.Message)) (uint64, error)
}

type MuConn

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

type PendingAck

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

type Pool

type Pool interface {
	MessageAckPending() int
	Close()
	Borrow() Cache
}