lib

type Claims struct {
	Sub         string              `json:"sub,omitempty"`
	RealmAccess map[string][]string `json:"realm_access,omitempty"`
}

type Driver interface {
	CreateInstance(instance *Instance, dataFields string, tagFields string) (serviceId string, err error)
	DeleteInstance(instance *Instance) (err error)
}

type ExportDatabase struct {
	ID            string `gorm:"primary_key;type:varchar(255);column:id"`
	Name          string `gorm:"type:varchar(255)"`
	Description   string `gorm:"type:varchar(255)"`
	Type          string `gorm:"type:varchar(255)"`
	Deployment    string `gorm:"type:varchar(255)"`
	Url           string `gorm:"type:varchar(255)"`
	EwFilterTopic string `gorm:"type:varchar(255)"`
	UserId        string `gorm:"type:varchar(255)"`
	Public        bool   `gorm:"type:bool;DEFAULT:false"`
}

type ExportDatabaseRequest struct {
	Name          string `json:"Name" validate:"required"`
	Description   string `json:"Description"`
	Type          string `json:"Type" validate:"required"`
	Deployment    string `json:"deployment" validate:"required"`
	Url           string `json:"Url" validate:"required"`
	EwFilterTopic string `json:"EwFilterTopic" validate:"required"`
	Public        bool   `json:"Public"`
}

type ExportWorkerKafkaApi interface {
	CreateFilterTopic(topic string, checkExists bool) error
	InitFilterTopics(serving *Serving) error
}

type ImportDeployService interface {
	UserHasImportAccess(id string, authorization string) (bool, error)
}

type Influx interface {
	ForceDeleteMeasurement(id string, userId string, instance Instance) (errs []error)
}

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

type Instance struct {
	ID               uuid.UUID      `gorm:"primary_key;type:char(36);column:id"`
	Name             string         `gorm:"type:varchar(255)"`
	Description      string         `gorm:"type:varchar(255)"`
	EntityName       string         `gorm:"type:varchar(255)"`
	ServiceName      string         `gorm:"type:varchar(255)"`
	Topic            string         `gorm:"type:varchar(255)"`
	ApplicationId    uuid.UUID      `gorm:"type:char(36)"`
	Database         string         `gorm:"type:varchar(255)"`
	Measurement      string         `gorm:"type:varchar(255)"`
	Filter           string         `gorm:"type:varchar(255)"`
	FilterType       string         `gorm:"type:varchar(255)"`
	TimePath         string         `gorm:"type:varchar(255)"`
	TimePrecision    *string        `gorm:"type:varchar(255)"`
	UserId           string         `gorm:"type:varchar(255)"`
	Generated        bool           `gorm:"type:bool;DEFAULT:false"`
	RancherServiceId string         `gorm:"type:varchar(255)"`
	Offset           string         `gorm:"type:varchar(255)"`
	ExportDatabaseID string         `gorm:"type:varchar(255)"`
	ExportDatabase   ExportDatabase `gorm:"association_autoupdate:false;association_autocreate:false"`
	TimestampFormat  string         `gorm:"type:varchar(255)"`
	Values           []Value        `gorm:"foreignkey:InstanceID;association_foreignkey:ID"`
	CreatedAt        time.Time
	UpdatedAt        time.Time
}

type Instances []Instance

type InstancesResponse struct {
	Total     int64     `json:"total,omitempty"`
	Count     int       `json:"count,omitempty"`
	Instances Instances `json:"instances,omitempty"`
}

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

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

type MigrationInfo struct {
	ID            string `json:"id"`
	Name          string `json:"name"`
	Description   string `json:"description"`
	Type          string `json:"type"`
	Deployment    string `json:"deployment"`
	Url           string `json:"url"`
	EwFilterTopic string `json:"ew_filter_topic"`
	UserID        string `json:"user_id"`
	Public        bool   `json:"public"`
}

type PermissionApiService interface {
	UserHasDevicesReadAccess(ids []string, authorization string) (bool, error)
}

type PipelineApiService interface {
	UserHasPipelineAccess(id string, authorization string) (bool, error)
}

type Response struct {
	Message string `json:"message,omitempty" validate:"required"`
}

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

type ServingRequest struct {
	FilterType       string                `json:"FilterType,omitempty" validate:"required"`
	Filter           string                `json:"Filter,omitempty" validate:"required"`
	Name             string                `json:"Name,omitempty" validate:"required"`
	EntityName       string                `json:"EntityName,omitempty" validate:"required"`
	ServiceName      string                `json:"ServiceName,omitempty" validate:"required"`
	Description      string                `json:"Description,omitempty"`
	Topic            string                `json:"Topic,omitempty" validate:"required"`
	TimePath         string                `json:"TimePath,omitempty"`
	TimePrecision    string                `json:"TimePrecision,omitempty"`
	Generated        bool                  `json:"generated,omitempty"`
	Offset           string                `json:"Offset,omitempty" validate:"required"`
	ForceUpdate      bool                  `json:"ForceUpdate,omitempty"`
	Values           []ServingRequestValue `json:"Values,omitempty"`
	ExportDatabaseID string                `json:"ExportDatabaseID,omitempty"`
	TimestampFormat  string                `json:"TimestampFormat,omitempty"`
}

type ServingRequestValue struct {
	Name string `json:"Name,omitempty"`
	Type string `json:"Type,omitempty"`
	Path string `json:"Path,omitempty"`
	Tag  bool   `json:"Tag"`
}

type Value struct {
	InstanceID uuid.UUID `gorm:"type:char(36)"`
	Name       string    `gorm:"type:varchar(255)"`
	Type       string    `gorm:"type:varchar(255)"`
	Path       string    `gorm:"type:varchar(255)"`
	Tag        bool      `gorm:"type:bool;DEFAULT:false"`
}