data

Documentation

Index

• Constants
• type BlobService
  • func NewBlobService() BlobService
  • func NewS3BlobService() BlobService
• type DynamoDbRepository
  • func (repository *DynamoDbRepository) SavePolicyResult(id string, data *policy.PolicyResult) error
  • func (repository *DynamoDbRepository) SaveStandardDataModel(id string, objectType string, data *map[string]interface{}) error
• type Repository
  • func NewDataRepository() Repository
• type S3BlobService
  • func (service *S3BlobService) Save(event *models.SignalEvent, target string, path string) error

Constants

const (
	Blob_engineeringsignal_data              = "engineeringsignalcollectorprddata"
	Directory_engineeringsignal_raw          = "signal_raw"
	Directory_engineeringsignal_standardized = "signal_standardized"
	Directory_engineeringpolicy_result       = "policy_result"
)

Types

type BlobService

type BlobService interface {
	Save(toSend *models.SignalEvent, target string, path string) error
}

func NewBlobService

func NewBlobService() BlobService

func NewS3BlobService

func NewS3BlobService() BlobService

type DynamoDbRepository

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

func (*DynamoDbRepository) SavePolicyResult

func (repository *DynamoDbRepository) SavePolicyResult(id string, data *policy.PolicyResult) error

func (*DynamoDbRepository) SaveStandardDataModel

func (repository *DynamoDbRepository) SaveStandardDataModel(id string, objectType string, data *map[string]interface{}) error

type Repository

type Repository interface {
	SavePolicyResult(id string, data *policy.PolicyResult) error
	SaveStandardDataModel(id string, objectType string, data *map[string]interface{}) error
}

func NewDataRepository

func NewDataRepository() Repository

type S3BlobService

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

func (*S3BlobService) Save

func (service *S3BlobService) Save(event *models.SignalEvent, target string, path string) error