adapter

Documentation

Index

• func MustListenAndServe(srv *http.Server)
• func NewHttpServer(h http.Handler, addr string) *http.Server
• func SetupTracing() (io.Closer, error)
• type ObjectStorage
  • func SetupObjectStorage(endpoint, accessKeyPath, secretKeyPath string, useSSL bool, ...) (*ObjectStorage, error)
  • func (o *ObjectStorage) Exists(ctx context.Context, path string) error
  • func (o *ObjectStorage) Presign(ctx context.Context, path string) (string, error)
  • func (o *ObjectStorage) Upload(ctx context.Context, path string, file io.ReadSeeker, contentType string) error

Functions

func MustListenAndServe

func MustListenAndServe(srv *http.Server)

func NewHttpServer

func NewHttpServer(h http.Handler, addr string) *http.Server

func SetupTracing

func SetupTracing() (io.Closer, error)

SetupTracing sets up jaeger as a global tracer for opentracing, a closer func is returned that can be used to flush buffers before shutdown.

Types

type ObjectStorage

type ObjectStorage struct {
	Client *s3.S3
	Bucket string
}

func SetupObjectStorage

func SetupObjectStorage(endpoint, accessKeyPath, secretKeyPath string, useSSL bool, region, bucket string) (*ObjectStorage, error)

func (*ObjectStorage) Exists

func (o *ObjectStorage) Exists(ctx context.Context, path string) error

func (*ObjectStorage) Presign

func (o *ObjectStorage) Presign(ctx context.Context, path string) (string, error)

func (*ObjectStorage) Upload

func (o *ObjectStorage) Upload(ctx context.Context, path string, file io.ReadSeeker, contentType string) error