share

Documentation

Index

• type Config
  • func Flags(fs *flag.FlagSet, prefix string) *Config
• type GetNow
• type Service
  • func New(config *Config, storageService absto.Storage, redisClient redis.Client, ...) (*Service, error)
  • func (s *Service) Create(ctx context.Context, filepath string, edit, story bool, password string, ...) (string, error)
  • func (s *Service) Delete(ctx context.Context, id string) error
  • func (s *Service) Done() <-chan struct{}
  • func (s *Service) EventConsumer(ctx context.Context, e provider.Event)
  • func (s *Service) Exclusive(ctx context.Context, name string, duration time.Duration, ...) (bool, error)
  • func (s *Service) Get(requestPath string) provider.Share
  • func (s *Service) List() (output []provider.Share)
  • func (s *Service) PubSubHandle(share provider.Share, err error)
  • func (s *Service) Start(ctx context.Context)
  • func (s *Service) UpdatePassword(ctx context.Context, id, password string) error

Types

type Config

type Config struct {
	PubsubChannel string
}

func Flags

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

type GetNow

type GetNow func() time.Time

type Service

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

func New

func New(config *Config, storageService absto.Storage, redisClient redis.Client, exclusiveService exclusive.Service) (*Service, error)

func (*Service) Create

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

func (*Service) Delete

func (s *Service) Delete(ctx context.Context, id string) error

func (*Service) Done

func (s *Service) Done() <-chan struct{}

func (*Service) EventConsumer

func (s *Service) EventConsumer(ctx context.Context, e provider.Event)

func (*Service) Exclusive

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

func (*Service) Get

func (s *Service) Get(requestPath string) provider.Share

func (*Service) List

func (s *Service) List() (output []provider.Share)

func (*Service) PubSubHandle

func (s *Service) PubSubHandle(share provider.Share, err error)

func (*Service) Start

func (s *Service) Start(ctx context.Context)

func (*Service) UpdatePassword

func (s *Service) UpdatePassword(ctx context.Context, id, password string) error