kernel

type Cathode interface {
	Ack(digest string) error
	Ask() ([]swarm.Bag, error)
}

type Codec[T any] interface {
	Encode(T) ([]byte, error)
	Decode([]byte) (T, error)
}

type Emitter interface {
	Enq(swarm.Bag) error
}

type Kernel struct {
	sync.WaitGroup
	sync.RWMutex

	// Kernel configuration
	Config swarm.Config

	// On the wire protocol emitter (writer) and cathode (receiver)
	Emitter Emitter
	Cathode Cathode
	// contains filtered or unexported fields
}

type Spawner interface {
	Spawn(*Kernel) error
}