structure

Documentation

Index

• Constants
• Variables
• func CreateLink(ctx context.Context, be blenc.BE, ep *protobuf.Entrypoint) (*protobuf.Entrypoint, *protobuf.WriterInfo, error)
• func DereferenceLink(ctx context.Context, be blenc.BE, link *protobuf.Entrypoint, maxRedirects int, ...) (*protobuf.Entrypoint, error)
• func UpdateLink(ctx context.Context, be blenc.BE, wi *protobuf.WriterInfo, ...) (*protobuf.Entrypoint, error)
• func UploadStaticBlob(ctx context.Context, be blenc.BE, r io.Reader, mimeType string, ...) (*protobuf.Entrypoint, error)
• func UploadStaticDirectory(ctx context.Context, log *slog.Logger, fsys fs.FS, be blenc.BE) (*protobuf.Entrypoint, error)
• type CinodeFS
  • func (d *CinodeFS) FindEntrypoint(ctx context.Context, path string) (*protobuf.Entrypoint, error)
  • func (d *CinodeFS) OpenContent(ctx context.Context, ep *protobuf.Entrypoint) (io.ReadCloser, error)
• type HTTPHandler
  • func (h *HTTPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type StaticDir
  • func (s *StaticDir) GenerateEntrypoint(ctx context.Context, be blenc.BE) (*protobuf.Entrypoint, error)
  • func (s *StaticDir) GenerateIndex(ctx context.Context, log *slog.Logger, indexName string, be blenc.BE) error
  • func (s *StaticDir) SetEntry(name string, ep *protobuf.Entrypoint)

Constants

const (
	CinodeDirMimeType = "application/cinode-dir"
)

Variables

var (
	ErrNotFound      = blenc.ErrNotFound
	ErrNotADirectory = errors.New("entry is not a directory")
	ErrNotAFile      = errors.New("entry is not a file")
)

var (
	ErrMaxRedirectsReached    = errors.New("maximum limit of dynamic link redirects reached")
	ErrCorruptedLinkData      = errors.New("corrupted link data")
	ErrCorruptedDirectoryData = errors.New("corrupted directory data")
	ErrInvalidEntrypoint      = protobuf.ErrInvalidEntrypoint
	ErrInvalidEntrypointTime  = protobuf.ErrInvalidEntrypointTime
)

Functions

func CreateLink

func CreateLink(ctx context.Context, be blenc.BE, ep *protobuf.Entrypoint) (*protobuf.Entrypoint, *protobuf.WriterInfo, error)

func DereferenceLink

func DereferenceLink(
	ctx context.Context,
	be blenc.BE,
	link *protobuf.Entrypoint,
	maxRedirects int,
	currentTime time.Time,
) (
	*protobuf.Entrypoint,
	error,
)

func UpdateLink

func UpdateLink(ctx context.Context, be blenc.BE, wi *protobuf.WriterInfo, ep *protobuf.Entrypoint) (*protobuf.Entrypoint, error)

func UploadStaticBlob

func UploadStaticBlob(ctx context.Context, be blenc.BE, r io.Reader, mimeType string, log *slog.Logger) (*protobuf.Entrypoint, error)

UploadStaticBlob uploads blob to the associated datastore and returns entrypoint to that file

if mimeType is an empty string, it will be guessed from the content defaulting to

func UploadStaticDirectory

func UploadStaticDirectory(ctx context.Context, log *slog.Logger, fsys fs.FS, be blenc.BE) (*protobuf.Entrypoint, error)

Types

type CinodeFS

type CinodeFS struct {
	BE               blenc.BE
	RootEntrypoint   *protobuf.Entrypoint
	MaxLinkRedirects int
	CurrentTimeF     func() time.Time
}

func (*CinodeFS) FindEntrypoint

func (d *CinodeFS) FindEntrypoint(ctx context.Context, path string) (*protobuf.Entrypoint, error)

func (*CinodeFS) OpenContent

func (d *CinodeFS) OpenContent(ctx context.Context, ep *protobuf.Entrypoint) (io.ReadCloser, error)

type HTTPHandler

type HTTPHandler struct {
	FS        *CinodeFS
	IndexFile string
}

func (*HTTPHandler) ServeHTTP

func (h *HTTPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type StaticDir

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

func (*StaticDir) GenerateEntrypoint

func (s *StaticDir) GenerateEntrypoint(ctx context.Context, be blenc.BE) (*protobuf.Entrypoint, error)

func (*StaticDir) GenerateIndex

func (s *StaticDir) GenerateIndex(ctx context.Context, log *slog.Logger, indexName string, be blenc.BE) error

func (*StaticDir) SetEntry

func (s *StaticDir) SetEntry(name string, ep *protobuf.Entrypoint)