logtypesapi

type APIError struct {
	Code    string `json:"code" validate:"required"`
	Message string `json:"message" validate:"required"`
	// contains filtered or unexported fields
}

type AvailableLogTypes struct {
	LogTypes []string `json:"logTypes"`
}

type DelCustomLogInput struct {
	LogType  string `json:"logType" validate:"required,startswith=Custom." description:"The log type id"`
	Revision int64  `json:"revision" validate:"min=1" description:"Log record revision"`
}

type DelCustomLogOutput struct {
	Error *APIError `json:"error,omitempty" description:"The delete record"`
}

type DeletedCustomLogs struct {
	LogTypes []string  `json:"logTypes,omitempty" description:"A list of ids of deleted log types (omitted if an error occurred)"`
	Error    *APIError `json:"error,omitempty" description:"An error that occurred while fetching the list"`
}

type DynamoDBSchemas struct {
	DB        dynamodbiface.DynamoDBAPI
	TableName string
}

type ErrorReply struct {
	Error *APIError `json:"error"`
}

type GetCustomLogInput struct {
	LogType string `json:"logType" validate:"required,startswith=Custom." description:"The log type id"`
}

type GetCustomLogOutput struct {
	Result *SchemaRecord `json:"record,omitempty" description:"The custom log record (field omitted if an error occurred)"`
	Error  *APIError     `json:"error,omitempty" description:"An error that occurred while fetching the record"`
}

type GetSchemaInput struct {
	Name string `json:"name" validate:"required" description:"The schema id"`
}

type GetSchemaOutput struct {
	Record *SchemaRecord `json:"record,omitempty" description:"The schema record (field omitted if an error occurred)"`
	Error  *APIError     `json:"error,omitempty" description:"An error that occurred while fetching the record"`
}

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

type ListCustomLogsOutput struct {
	Records []*SchemaRecord `json:"customLogs" description:"Custom log records stored"`
	Error   *APIError       `json:"error,omitempty" description:"An error that occurred during the operation"`
}

type ListManagedSchemaUpdatesInput struct{}

type ListManagedSchemaUpdatesOutput struct {
	Releases *[]managedschemas.Release `json:"releases,omitempty" description:"Available release updates"`
	Error    *APIError                 `json:"error,omitempty" description:"An error that occurred while fetching the record"`
}

type LogTypesAPI struct {
	Database          SchemaDatabase
	UpdateDataCatalog func(ctx context.Context, logType string, from, to []logschema.FieldSchema) error
	LogTypesInUse     func(ctx context.Context) ([]string, error)
	ManagedSchemas    managedschemas.ReleaseFeeder
}

type LogTypesAPILambdaClient struct {
	LambdaName string
	LambdaAPI  lambdaiface.LambdaAPI
	Validate   func(interface{}) error
	JSON       jsoniter.API
}

type LogTypesAPIPayload struct {
	ListAvailableLogTypes    *struct{}                      `json:"ListAvailableLogTypes,omitempty"`
	ListDeletedCustomLogs    *struct{}                      `json:"ListDeletedCustomLogs,omitempty"`
	GetCustomLog             *GetCustomLogInput             `json:"GetCustomLog,omitempty"`
	PutCustomLog             *PutCustomLogInput             `json:"PutCustomLog,omitempty"`
	DelCustomLog             *DelCustomLogInput             `json:"DelCustomLog,omitempty"`
	ListCustomLogs           *struct{}                      `json:"ListCustomLogs,omitempty"`
	ListManagedSchemaUpdates *ListManagedSchemaUpdatesInput `json:"ListManagedSchemaUpdates,omitempty"`
	UpdateManagedSchemas     *UpdateManagedSchemasInput     `json:"UpdateManagedSchemas,omitempty"`
	GetSchema                *GetSchemaInput                `json:"GetSchema,omitempty"`
}

type PutCustomLogInput struct {
	LogType string `json:"logType" validate:"required,startswith=Custom." description:"The log type id"`
	// Revision is required when updating a custom log record.
	// If  is omitted a new custom log record will be created.
	Revision     int64  `` /* 145-byte string literal not displayed */
	Description  string `json:"description" description:"Log type description"`
	ReferenceURL string `json:"referenceURL" description:"A URL with reference docs for the schema"`
	// For compatibility we use 'logSpec' as the JSON and DDB field names
	Spec string `json:"logSpec" dynamodbav:"logSpec" validate:"required" description:"The schema spec in YAML or JSON format"`
}

type PutCustomLogOutput struct {
	Result *SchemaRecord `json:"record,omitempty" description:"The modified record (field is omitted if an error occurred)"`
	Error  *APIError     `json:"error,omitempty" description:"An error that occurred during the operation"`
}

type Resolver struct {
	LogTypesAPI    *LogTypesAPILambdaClient
	NativeLogTypes logtypes.Finder
}

type ScanSchemaFunc func(r *SchemaRecord) bool

type SchemaDatabase interface {
	// GetSchema gets a single schema record
	GetSchema(ctx context.Context, id string) (*SchemaRecord, error)
	// PutSchema puts a single schema record
	PutSchema(ctx context.Context, id string, record *SchemaRecord) (*SchemaRecord, error)
	// ScanSchemas iterates through all schema records as long as scan returns true
	ScanSchemas(ctx context.Context, scan ScanSchemaFunc) error
}

type SchemaRecord struct {
	// For compatibility we use 'logType' as the DDB field name
	Name      string    `json:"logType" dynamodbav:"logType" validate:"required" description:"The schema id"`
	Revision  int64     `json:"revision" validate:"required,min=1" description:"Schema record revision"`
	Release   string    `json:"release,omitempty" description:"Managed schema release version"`
	UpdatedAt time.Time `json:"updatedAt" description:"Last update timestamp of the record"`
	CreatedAt time.Time `json:"createdAt" description:"Creation timestamp of the record"`
	Managed   bool      `json:"managed,omitempty" description:"Schema is managed by Panther"`
	// For compatibility we use 'IsDeleted' as the DDB field name
	Disabled     bool   `json:"disabled,omitempty" dynamodbav:"IsDeleted"  description:"Log record is deleted"`
	Description  string `json:"description" description:"Log type description"`
	ReferenceURL string `json:"referenceURL" description:"A URL with reference docs for the schema"`
	// For compatibility we use 'logSpec' as the JSON and DDB field names
	Spec string `json:"logSpec" dynamodbav:"logSpec" validate:"required" description:"The schema spec in YAML or JSON format"`
}

type UpdateManagedSchemasInput struct {
	Release     string `json:"release" validate:"required" description:"The release of the schema"`
	ManifestURL string `json:"manifestURL,omitempty" validate:"omitempty,url" description:"The URL to download the manifest archive from"`
}

type UpdateManagedSchemasOutput struct {
	Records []*SchemaRecord `json:"records"`
	Error   *APIError       `json:"error,omitempty" description:"An error that occurred while fetching the record"`
}