network

type DataForwardEnvelope struct {
	Metadata object.Metadata  `nimona:"@metadata:m,type=nimona.io/network.DataForwardEnvelope"`
	Sender   crypto.PublicKey `nimona:"sender:s"`
	Data     []byte           `nimona:"data:d"`
}

type DataForwardRequest struct {
	Metadata  object.Metadata  `nimona:"@metadata:m,type=nimona.io/network.DataForwardRequest"`
	RequestID string           `nimona:"requestID:s"`
	Recipient crypto.PublicKey `nimona:"recipient:s"`
	Payload   *object.Object   `nimona:"payload:m"`
}

type DataForwardResponse struct {
	Metadata  object.Metadata `nimona:"@metadata:m,type=nimona.io/network.DataForwardResponse"`
	RequestID string          `nimona:"requestID:s"`
	Success   bool            `nimona:"success:b"`
}

type Envelope struct {
	Sender  crypto.PublicKey
	Payload *object.Object
}

type EnvelopeFilter func(*Envelope) bool

type EnvelopePubSub interface {
	Publish(*Envelope)
	Subscribe(...EnvelopeFilter) EnvelopeSubscription
}

type EnvelopeSubscription interface {
	Channel() <-chan *Envelope
	Next() (*Envelope, error)
	Cancel()
}

type ListenOption func(c *listenConfig)

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

type Network interface {
	Subscribe(
		filters ...EnvelopeFilter,
	) EnvelopeSubscription
	SubscribeOnce(
		ctx context.Context,
		filters ...EnvelopeFilter,
	) (*Envelope, error)
	Send(
		ctx context.Context,
		object *object.Object,
		publicKey crypto.PublicKey,
		sendOptions ...SendOption,
	) error
	Listen(
		ctx context.Context,
		bindAddress string,
		options ...ListenOption,
	) (net.Listener, error)
	RegisterResolver(
		resolver Resolver,
	)
	GetAddresses() []string
	RegisterAddresses(...string)
	GetRelays() []*peer.ConnectionInfo
	RegisterRelays(...*peer.ConnectionInfo)
	GetPeerKey() crypto.PrivateKey
	GetConnectionInfo() *peer.ConnectionInfo
	Close() error
}

type Option func(*network)

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

type Resolver interface {
	LookupPeer(
		ctx context.Context,
		publicKey crypto.PublicKey,
	) (*peer.ConnectionInfo, error)
}

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

type SendOption func(*sendOptions)

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