share

package

v0.18.1 Latest Latest Go to latest Published: May 20, 2022 License: MIT Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type App struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

App of package

func New(config Config, storageApp absto.Storage, amqpClient *amqp.Client) (*App, error)

New creates new App from Config

func (a *App) AmqpHandler(message amqp.Delivery) error

AmqpHandler handle exif message

func (a *App) Create(ctx context.Context, filepath string, edit bool, password string, isDir bool, duration time.Duration) (string, error)

Create a share

func (a *App) Delete(ctx context.Context, id string) error

Delete a share

func (a *App) EventConsumer(ctx context.Context, e provider.Event)

EventConsumer handle event pushed to the event bus

func (a *App) Exclusive(ctx context.Context, name string, duration time.Duration, action func(ctx context.Context) error) (bool, error)

Exclusive does action on shares with exclusive lock

func (a *App) Get(requestPath string) provider.Share

Get returns a share based on path

func (a *App) List() (shares []provider.Share)

List shares

func (a *App) Start(done <-chan struct{})

Start worker

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

Config of package

func Flags(fs *flag.FlagSet, prefix string) Config

Flags adds flags for configuring package