app

Documentation

Index

• type App
  • func New(ctx context.Context, logger *zap.Logger, cfg Config) (*App, error)
  • func (a *App) Close(ctx context.Context) error
  • func (a *App) Health(ctx context.Context) error
  • func (a *App) NewSession() *Session
• type CloudPlatformType
  • func (c CloudPlatformType) String() string
• type Config
  • func (c Config) Validate() error
• type Session
  • func (s *Session) Context() context.Context
  • func (sess *Session) DoAwsRequest(req *http.Request) (*http.Response, bool, error)
  • func (sess *Session) DoRequest(req *http.Request) (*http.Response, bool, error)
  • func (s *Session) Logger() *zap.Logger
  • func (s *Session) WithContext(ctx context.Context) *Session
  • func (s *Session) WithLogger(logger *zap.Logger) *Session

Types

type App

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

func New

func New(ctx context.Context, logger *zap.Logger, cfg Config) (*App, error)

func (*App) Close

func (a *App) Close(ctx context.Context) error

func (*App) Health

func (a *App) Health(ctx context.Context) error

func (*App) NewSession

func (a *App) NewSession() *Session

type CloudPlatformType

type CloudPlatformType string

const (
	AwsCloudPlatform CloudPlatformType = "AWS"
	GcpCloudPlatform CloudPlatformType = "GCP"
)

func (CloudPlatformType) String

func (c CloudPlatformType) String() string

type Config

type Config struct {
	CloudPlatform string `yaml:"CloudPlatform"`
	NoCrunchErr   bool   `yaml:"NoCrunchErr"`
}

func (Config) Validate

func (c Config) Validate() error

type Session

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

func (*Session) Context

func (s *Session) Context() context.Context

func (*Session) DoAwsRequest

func (sess *Session) DoAwsRequest(req *http.Request) (*http.Response, bool, error)

DoAwsRequest makes a request to AWS Does a request to the source bucket and if it returns 404, tries the crunched bucket Returns the response and a boolean indicating if the response is from the crunched bucket

func (*Session) DoRequest

func (sess *Session) DoRequest(req *http.Request) (*http.Response, bool, error)

DoRequest makes a request to the cloud platform Does a request to the source bucket and if it returns 404, tries the crunched bucket Returns the response and a boolean indicating if the response is from the crunched bucket

func (*Session) Logger

func (s *Session) Logger() *zap.Logger

func (*Session) WithContext

func (s *Session) WithContext(ctx context.Context) *Session

func (*Session) WithLogger

func (s *Session) WithLogger(logger *zap.Logger) *Session