handlers

Documentation

Index

• func AddDownloadHandler(libp2phost host.Host, store stores.Store, ...)
• func AddUploadHandler(libp2phost host.Host, store stores.Store, ...)
• func BuildDownloadStreamHandler(store stores.Store, ...) func(network.Stream)
• func BuildUploadStreamHandler(store stores.Store, ...) func(stream network.Stream)
• func WaitForDownloadMessage(stream network.Stream) (bool, *lib.DownloadMessage)
• func WaitForResponse(stream network.Stream) bool
• func WaitForUploadMessage(stream network.Stream) (bool, *lib.UploadMessage)
• func WriteErrorToStream(stream network.Stream, message string, err error) error
• func WriteResponseToStream(stream network.Stream, response bool) error

Functions

func AddDownloadHandler

func AddDownloadHandler(libp2phost host.Host, store stores.Store, canDownloadDag func(rootLeaf *merkle_dag.DagLeaf, pubKey *string, signature *string) bool)

func AddUploadHandler

func AddUploadHandler(libp2phost host.Host, store stores.Store, canUploadDag func(rootLeaf *merkle_dag.DagLeaf, pubKey *string, signature *string) bool, handleRecievedDag func(dag *merkle_dag.Dag, pubKey *string))

func BuildDownloadStreamHandler

func BuildDownloadStreamHandler(store stores.Store, canDownloadDag func(rootLeaf *merkle_dag.DagLeaf, pubKey *string, signature *string) bool) func(network.Stream)

func BuildUploadStreamHandler

func BuildUploadStreamHandler(store stores.Store, canUploadDag func(rootLeaf *merkle_dag.DagLeaf, pubKey *string, signature *string) bool, handleRecievedDag func(dag *merkle_dag.Dag, pubKey *string)) func(stream network.Stream)

func WaitForDownloadMessage

func WaitForDownloadMessage(stream network.Stream) (bool, *lib.DownloadMessage)

func WaitForResponse

func WaitForResponse(stream network.Stream) bool

func WaitForUploadMessage

func WaitForUploadMessage(stream network.Stream) (bool, *lib.UploadMessage)

func WriteErrorToStream

func WriteErrorToStream(stream network.Stream, message string, err error) error

func WriteResponseToStream

func WriteResponseToStream(stream network.Stream, response bool) error