streaming_rpc

type Context struct {
	KadId   kademlia.ID
	Headers map[string]string
	Body    io.ReadCloser
	// contains filtered or unexported fields
}

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

type DataPacket struct {
	StreamID uint32 // stream id
	Data     []byte // payload
}

type Handler func(ctx *Context)

type HandshakePacket struct {
	KadId     *kademlia.ID
	Services  []string
	Signature kademlia.Signature
}

type NetProtocolType = uint8

type OpCode = uint8

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

type Providers struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type ServiceRequestPacket struct {
	StreamId uint32            // stream id
	Services []string          // services this packet may be processed through
	Headers  map[string]string // headers for this packet
}

type ServiceResponsePacket struct {
	StreamId uint32            // stream id
	Handled  bool              // whether or not the service was handled
	Headers  map[string]string // headers for this packet
}

type Stream struct {
	ID     uint32
	Reader *pipeReader
	Writer *pipeWriter

	Header *ServiceResponsePacket
	// contains filtered or unexported fields
}

type StreamNode struct {

	// A 32-byte Ed25519 private key. A secret key must be provided to allow for peers to reach you.
	// A secret key may be generated by calling `streaming_rpc.GenerateSecretKey()`.
	// It was used to sign for the HandshakePacket
	SecretKey   kademlia.PrivateKey
	NetProtocol NetProtocolType // Such as TCP,UDP,IP

	KadId *kademlia.ID

	Srv *st.Server

	// A mapping of service names to their respective handlers.
	Services map[string]Handler
	// contains filtered or unexported fields
}