scionic

Documentation

Index

• func BuildErrorMessage(message string, err error) types.ErrorMessage
• func BuildResponseMessage(response bool) types.ResponseMessage
• func CheckFilter(leaf *merkle_dag.DagLeaf, filter *types.DownloadFilter) (bool, error)
• func ReadMessageFromStream[T any](stream types.Stream) (*T, error)
• func WaitForDownloadMessage(stream types.Stream) (*types.DownloadMessage, error)
• func WaitForQueryMessage(stream types.Stream) (*types.QueryMessage, error)
• func WaitForResponse(stream types.Stream) (*types.ResponseMessage, error)
• func WaitForUploadMessage(stream types.Stream) (*types.UploadMessage, error)
• func WriteErrorToStream(stream types.Stream, message string, err error) error
• func WriteMessageToStream[T any](stream types.Stream, message T) error
• func WriteResponseToStream(stream types.Stream, response bool) error
• type DagWriter
• type DownloadDagHandler
• type DownloadDagReader
• type QueryDagHandler
• type QueryDagReader
• type UploadDagHandler
• type UploadDagReader

Functions

func BuildErrorMessage

func BuildErrorMessage(message string, err error) types.ErrorMessage

func BuildResponseMessage

func BuildResponseMessage(response bool) types.ResponseMessage

func CheckFilter

func CheckFilter(leaf *merkle_dag.DagLeaf, filter *types.DownloadFilter) (bool, error)

func ReadMessageFromStream

func ReadMessageFromStream[T any](stream types.Stream) (*T, error)

func WaitForDownloadMessage

func WaitForDownloadMessage(stream types.Stream) (*types.DownloadMessage, error)

func WaitForQueryMessage

func WaitForQueryMessage(stream types.Stream) (*types.QueryMessage, error)

func WaitForResponse

func WaitForResponse(stream types.Stream) (*types.ResponseMessage, error)

func WaitForUploadMessage

func WaitForUploadMessage(stream types.Stream) (*types.UploadMessage, error)

func WriteErrorToStream

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

func WriteMessageToStream

func WriteMessageToStream[T any](stream types.Stream, message T) error

func WriteResponseToStream

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

Types

type DagWriter

type DagWriter func(message interface{}) error

type DownloadDagHandler

type DownloadDagHandler func(read DownloadDagReader, write DagWriter)

type DownloadDagReader

type DownloadDagReader func() (*types.DownloadMessage, error)

type QueryDagHandler

type QueryDagHandler func(read QueryDagReader, write DagWriter)

type QueryDagReader

type QueryDagReader func() (*types.QueryMessage, error)

type UploadDagHandler

type UploadDagHandler func(read UploadDagReader, write DagWriter)

type UploadDagReader

type UploadDagReader func() (*types.UploadMessage, error)