base

Documentation

Index

• type Paths
• type Service
  • func (*Service) BuildFailed(errCode, errMsg string) *models.BaseResponse
  • func (*Service) BuildSucess(data interface{}) *models.BaseResponse
  • func (s *Service) FixDatabaseLockd() error
  • func (s *Service) GetCachedS3Client(connectionId string) (*s3.Client, error)
  • func (s *Service) GetTimeoutContext() (context.Context, context.CancelFunc)
  • func (s *Service) InitAndCacheS3Client(connectionId string) (*s3.Client, error)
  • func (s *Service) InitDbClient() error
  • func (s *Service) QueryEncryptionKey() (string, error)

Types

type Paths

type Paths struct {
	HomeDir     string
	ConfDir     string
	DbDir       string
	LogDir      string
	TmpDir      string
	DownloadDir string
}

type Service

type Service struct {
	Paths       *Paths
	Log         *zap.SugaredLogger
	S3ClientMap map[string]*s3.Client
	DbClient    *sql.DB
	Ctx         context.Context
}

func (*Service) BuildFailed

func (*Service) BuildFailed(errCode, errMsg string) *models.BaseResponse

func (*Service) BuildSucess

func (*Service) BuildSucess(data interface{}) *models.BaseResponse

func (*Service) FixDatabaseLockd

func (s *Service) FixDatabaseLockd() error

func (*Service) GetCachedS3Client

func (s *Service) GetCachedS3Client(connectionId string) (*s3.Client, error)

func (*Service) GetTimeoutContext

func (s *Service) GetTimeoutContext() (context.Context, context.CancelFunc)

func (*Service) InitAndCacheS3Client

func (s *Service) InitAndCacheS3Client(connectionId string) (*s3.Client, error)

func (*Service) InitDbClient

func (s *Service) InitDbClient() error

func (*Service) QueryEncryptionKey

func (s *Service) QueryEncryptionKey() (string, error)