resource

Documentation

Index

• Constants
• Variables
• type Service
  • func NewService(deps ServiceDeps) *Service
  • func (s *Service) BatchDelete(ctx context.Context, ids []string) error
  • func (s *Service) BulkUpsert(ctx context.Context, resources []*domain.Resource) error
  • func (s *Service) Delete(ctx context.Context, id string) error
  • func (s *Service) Find(ctx context.Context, filter domain.ListResourcesFilter) ([]*domain.Resource, error)
  • func (s *Service) Get(ctx context.Context, ri *domain.ResourceIdentifier) (*domain.Resource, error)
  • func (s *Service) GetOne(ctx context.Context, id string) (*domain.Resource, error)
  • func (s *Service) GetResourcesTotalCount(ctx context.Context, filters domain.ListResourcesFilter) (int64, error)
  • func (s *Service) Update(ctx context.Context, r *domain.Resource) error
• type ServiceDeps

Constants

const (
	AuditKeyResoruceBulkUpsert  = "resource.bulkUpsert"
	AuditKeyResourceUpdate      = "resource.update"
	AuditKeyResourceDelete      = "resource.delete"
	AuditKeyResourceBatchDelete = "resource.batchDelete"

	ReservedDetailsKeyMetadata = "__metadata"
)

Variables

var (
	// ErrEmptyIDParam is the error value if the resource id is empty
	ErrEmptyIDParam = errors.New("id can't be empty")
	// ErrRecordNotFound is the error value if the designated record id is not exists
	ErrRecordNotFound = errors.New("record not found")
)

Types

type Service

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

Service handles the business logic for resource

func NewService

func NewService(deps ServiceDeps) *Service

NewService returns *Service

func (*Service) BatchDelete

func (s *Service) BatchDelete(ctx context.Context, ids []string) error

func (*Service) BulkUpsert

func (s *Service) BulkUpsert(ctx context.Context, resources []*domain.Resource) error

BulkUpsert inserts or updates records

func (*Service) Delete

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

func (*Service) Find

func (s *Service) Find(ctx context.Context, filter domain.ListResourcesFilter) ([]*domain.Resource, error)

Find records based on filters

func (*Service) Get

func (s *Service) Get(ctx context.Context, ri *domain.ResourceIdentifier) (*domain.Resource, error)

func (*Service) GetOne

func (s *Service) GetOne(ctx context.Context, id string) (*domain.Resource, error)

func (*Service) GetResourcesTotalCount

func (s *Service) GetResourcesTotalCount(ctx context.Context, filters domain.ListResourcesFilter) (int64, error)

func (*Service) Update

func (s *Service) Update(ctx context.Context, r *domain.Resource) error

Update updates only details and labels of a resource by ID

type ServiceDeps

type ServiceDeps struct {
	Repository repository

	Logger      log.Logger
	AuditLogger auditLogger
}