dataplane

type BufferBlob struct {
	BlobNumber int64
	Contents   []byte
	Error      error

	// For Writing
	PreviousCumulativeHash chan string
	CurrentCumulativeHash  chan string

	// For Reading
	EncodedMD5Hash      string
	EncodedMD5ChainHash string
}

type BufferEndMetadata struct {
	Status BufferStatus `json:"status"`
}

type BufferStartMetadata struct {
	Version string `json:"version"`
}

type BufferStatus string

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

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

type DownloadProgressReader struct {
	Reader          io.ReadCloser
	TransferMetrics *TransferMetrics
}

type InvalidAccessUrlError struct {
	Reason string
}

type MergedContext struct {
	context.Context // The context that is is used for deadlines and cancellation
	// contains filtered or unexported fields
}

type PartiallyBufferedReader struct {
	io.Reader
	// contains filtered or unexported fields
}

type ReadOption func(o *readOptions)

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

type SasAction int

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

type UploadProgressReader struct {
	Reader          *bytes.Reader
	TransferMetrics *TransferMetrics
}

type ValidateSignatureFunc func(data []byte, signature []byte) bool

type ValueOrError[A any] struct {
	Value A
	Err   error
}

type WriteOption func(o *writeOptions)