world

Documentation

Index

• Constants
• func PrepareUploadData(ctx context.Context) error
• type Decompressor
• type ExtractionPipeline
  • func (p *ExtractionPipeline) Run(r io.Reader) error
• type FileCreator
  • func NewFileCreator(outDir string) (*FileCreator, error)
  • func (c *FileCreator) CreateFile(path string, isDir bool, content io.Reader) error
  • func (c *FileCreator) Finalize() error
• type TarUnarchiver
  • func (*TarUnarchiver) Unarchive(r io.Reader, c *FileCreator) error
• type Unarchiver
• type WorldService
  • func New(endpoint, authKey string) *WorldService
  • func (w *WorldService) DownloadWorldData(ctx context.Context, config *runner.Config) error
  • func (w *WorldService) GetLatestKey(ctx context.Context, world string) (string, error)
  • func (w *WorldService) UploadWorldData(ctx context.Context, config *runner.Config) (string, error)
• type XZDecompressor
  • func (*XZDecompressor) ToDecompressed(r io.Reader) (io.Reader, error)
• type ZipUnarchiver
  • func (z *ZipUnarchiver) Unarchive(r io.Reader, c *FileCreator) error
• type ZstdDecompressor
  • func (*ZstdDecompressor) ToDecompressed(r io.Reader) (io.Reader, error)

Constants

const ScopeName = "github.com/kofuk/premises/runner/internal/commands/mclauncher/world"

Functions

func PrepareUploadData

func PrepareUploadData(ctx context.Context) error

Types

type Decompressor

type Decompressor interface {
	ToDecompressed(io.Reader) (io.Reader, error)
}

type ExtractionPipeline

type ExtractionPipeline struct {
	D Decompressor
	U Unarchiver
	C *FileCreator
}

func (*ExtractionPipeline) Run

func (p *ExtractionPipeline) Run(r io.Reader) error

type FileCreator

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

func NewFileCreator

func NewFileCreator(outDir string) (*FileCreator, error)

func (*FileCreator) CreateFile

func (c *FileCreator) CreateFile(path string, isDir bool, content io.Reader) error

func (*FileCreator) Finalize

func (c *FileCreator) Finalize() error

type TarUnarchiver

type TarUnarchiver struct{}

func (*TarUnarchiver) Unarchive

func (*TarUnarchiver) Unarchive(r io.Reader, c *FileCreator) error

type Unarchiver

type Unarchiver interface {
	Unarchive(io.Reader, *FileCreator) error
}

type WorldService

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

func New

func New(endpoint, authKey string) *WorldService

func (*WorldService) DownloadWorldData

func (w *WorldService) DownloadWorldData(ctx context.Context, config *runner.Config) error

func (*WorldService) GetLatestKey

func (w *WorldService) GetLatestKey(ctx context.Context, world string) (string, error)

func (*WorldService) UploadWorldData

func (w *WorldService) UploadWorldData(ctx context.Context, config *runner.Config) (string, error)

type XZDecompressor

type XZDecompressor struct{}

func (*XZDecompressor) ToDecompressed

func (*XZDecompressor) ToDecompressed(r io.Reader) (io.Reader, error)

type ZipUnarchiver

type ZipUnarchiver struct{}

func (*ZipUnarchiver) Unarchive

func (z *ZipUnarchiver) Unarchive(r io.Reader, c *FileCreator) error

type ZstdDecompressor

type ZstdDecompressor struct{}

func (*ZstdDecompressor) ToDecompressed

func (*ZstdDecompressor) ToDecompressed(r io.Reader) (io.Reader, error)