rustfs

Documentation

Index

• Constants
• Variables
• func New(p RequestParams) (*testcontainers.GenericContainerRequest, error)
• func WithBucket(bucketName string) testcontainers.CustomizeRequestOption
• func WithObjectStorageCredentials(credentials RustFSCredentials) testcontainers.CustomizeRequestOption
• type ContainerParams
• type RequestParams
• type Result
  • func Actualize(p ContainerParams) (Result, error)
• type RustFSCredentials

Constants

const (
	Tag         = "rustfs"
	Image       = "rustfs/rustfs"
	Port        = "9000/tcp"
	ConsolePort = "9001/tcp"

	ContainerPrettyName = "RustFS"
)

Variables

var Module = mockestra.BuildContainerModule(
	Tag,
	fx.Provide(
		fx.Annotate(
			New,
			fx.ResultTags(`name:"rustfs"`),
		),
		Actualize,
	),
)

var WithPostReadyHook = mockestra.WithPostReadyHook

Functions

func New

func New(p RequestParams) (*testcontainers.GenericContainerRequest, error)

func WithBucket

func WithBucket(bucketName string) testcontainers.CustomizeRequestOption

func WithObjectStorageCredentials

func WithObjectStorageCredentials(credentials RustFSCredentials) testcontainers.CustomizeRequestOption

Types

type ContainerParams

type ContainerParams struct {
	fx.In
	Lifecycle fx.Lifecycle
	Request   *testcontainers.GenericContainerRequest `name:"rustfs"`
}

type RequestParams

type RequestParams struct {
	fx.In
	Prefix  string                               `name:"prefix"`
	Version string                               `name:"rustfs_version"`
	Opts    []testcontainers.ContainerCustomizer `group:"rustfs"`
}

type Result

type Result struct {
	fx.Out
	Container      testcontainers.Container `name:"rustfs"`
	ContainerGroup testcontainers.Container `group:"containers"`
}

func Actualize

func Actualize(p ContainerParams) (Result, error)

type RustFSCredentials

type RustFSCredentials struct {
	AccessKeyID     string
	SecretAccessKey string
}