bcnet

package

v0.0.2 Latest Latest Go to latest Published: Dec 15, 2025 License: GPL-3.0 Imports: 19 Imported by: 0

Details

bcnet implements the Blobcache Protocol (BCP).

This section is empty.

This section is empty.

This section is empty.

type AccessFunc func(blobcache.PeerID) blobcache.Service

AccessFun is called to get a service to access

type Marshaller interface {
	Marshal(out []byte) []byte
}

type Message = bcp.Message

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

func New(privateKey ed25519.PrivateKey, pc net.PacketConn) *Node

func (n *Node) Ask(ctx context.Context, remote blobcache.Endpoint, req Message, resp *Message) error

Ask opens a bidirectional stream to the given peer and sends the given request, then waits for a response.

func (n *Node) LocalAddr() netip.AddrPort

func (n *Node) LocalEndpoint() blobcache.Endpoint

func (n *Node) LocalID() blobcache.PeerID

func (n *Node) Serve(ctx context.Context, srv Server) error

Serve blocks handling all incoming connections, until ctx is cancelled.

func (n *Node) Tell(ctx context.Context, remote blobcache.Endpoint, req bcp.Message) error

Tell opens a uni-stream to the given peer and sends the given request.

type Server struct {
	Access  AccessFunc
	Deliver func(ctx context.Context, from blobcache.Endpoint, ttm bcp.TopicTellMsg) error
}

type TopicMessage = blobcache.Message

type Unmarshaller interface {
	Unmarshal(data []byte) error
}