destinations

Documentation

Index

• type PaginateDestinationsParams
• type Service
  • func New(env *config.Env, dbgen *dbgen.Queries, ints *integration.Integration, ...) *Service
  • func (s *Service) CreateDestination(ctx context.Context, params dbgen.DestinationsServiceCreateDestinationParams) (dbgen.Destination, error)
  • func (s *Service) DeleteDestination(ctx context.Context, id uuid.UUID) error
  • func (s *Service) GetAllDestinations(ctx context.Context) ([]dbgen.DestinationsServiceGetAllDestinationsRow, error)
  • func (s *Service) GetDestination(ctx context.Context, id uuid.UUID) (dbgen.DestinationsServiceGetDestinationRow, error)
  • func (s *Service) GetDestinationsQty(ctx context.Context) (dbgen.DestinationsServiceGetDestinationsQtyRow, error)
  • func (s *Service) PaginateDestinations(ctx context.Context, params PaginateDestinationsParams) (paginateutil.PaginateResponse, ...)
  • func (s *Service) TestAllDestinations()
  • func (s *Service) TestDestination(accessKey, secretKey, region, endpoint, bucketName string) error
  • func (s *Service) TestDestinationAndStoreResult(ctx context.Context, destinationID uuid.UUID) error
  • func (s *Service) UpdateDestination(ctx context.Context, params dbgen.DestinationsServiceUpdateDestinationParams) (dbgen.Destination, error)

Types

type PaginateDestinationsParams

type PaginateDestinationsParams struct {
	Page  int
	Limit int
}

type Service

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

func New

func New(
	env *config.Env, dbgen *dbgen.Queries, ints *integration.Integration,
	webhooksService *webhooks.Service,
) *Service

func (*Service) CreateDestination

func (s *Service) CreateDestination(
	ctx context.Context, params dbgen.DestinationsServiceCreateDestinationParams,
) (dbgen.Destination, error)

func (*Service) DeleteDestination

func (s *Service) DeleteDestination(
	ctx context.Context, id uuid.UUID,
) error

func (*Service) GetAllDestinations

func (s *Service) GetAllDestinations(
	ctx context.Context,
) ([]dbgen.DestinationsServiceGetAllDestinationsRow, error)

func (*Service) GetDestination

func (s *Service) GetDestination(
	ctx context.Context, id uuid.UUID,
) (dbgen.DestinationsServiceGetDestinationRow, error)

func (*Service) GetDestinationsQty

func (s *Service) GetDestinationsQty(
	ctx context.Context,
) (dbgen.DestinationsServiceGetDestinationsQtyRow, error)

func (*Service) PaginateDestinations

func (s *Service) PaginateDestinations(
	ctx context.Context, params PaginateDestinationsParams,
) (paginateutil.PaginateResponse, []dbgen.DestinationsServicePaginateDestinationsRow, error)

func (*Service) TestAllDestinations

func (s *Service) TestAllDestinations()

func (*Service) TestDestination

func (s *Service) TestDestination(
	accessKey, secretKey, region, endpoint, bucketName string,
) error

func (*Service) TestDestinationAndStoreResult

func (s *Service) TestDestinationAndStoreResult(
	ctx context.Context, destinationID uuid.UUID,
) error

func (*Service) UpdateDestination

func (s *Service) UpdateDestination(
	ctx context.Context, params dbgen.DestinationsServiceUpdateDestinationParams,
) (dbgen.Destination, error)