logtypesapi

package

Go to main page

Versions in this module

v1

v1.16.0

Mar 10, 2021

Changes in this version

+ type DynamoDBSchemas struct

+ DB dynamodbiface.DynamoDBAPI

+ TableName string

+ func (d *DynamoDBSchemas) GetSchema(ctx context.Context, id string) (*SchemaRecord, error)

+ func (d *DynamoDBSchemas) PutSchema(ctx context.Context, id string, record *SchemaRecord) (*SchemaRecord, error)

+ func (d *DynamoDBSchemas) ScanSchemas(ctx context.Context, scan ScanSchemaFunc) error

+ type GetSchemaInput struct

+ Name string

+ type GetSchemaOutput struct

+ Error *APIError

+ Record *SchemaRecord

type InMemDB

+ func (db *InMemDB) GetSchema(_ context.Context, id string) (*SchemaRecord, error)

+ func (db *InMemDB) PutSchema(_ context.Context, name string, r *SchemaRecord) (*SchemaRecord, error)

+ func (db *InMemDB) ScanSchemas(_ context.Context, scan ScanSchemaFunc) error

type ListCustomLogsOutput

+ Records []*SchemaRecord

+ type ListManagedSchemaUpdatesInput struct

+ type ListManagedSchemaUpdatesOutput struct

+ Error *APIError

+ Releases *[]managedschemas.Release

type LogTypesAPI

+ LogTypesInUse func(ctx context.Context) ([]string, error)

+ ManagedSchemas managedschemas.ReleaseFeeder

+ func (api *LogTypesAPI) GetSchema(ctx context.Context, input *GetSchemaInput) (*GetSchemaOutput, error)

+ func (api *LogTypesAPI) ListManagedSchemaUpdates(ctx context.Context, _ *ListManagedSchemaUpdatesInput) (*ListManagedSchemaUpdatesOutput, error)

+ func (api *LogTypesAPI) UpdateManagedSchemas(ctx context.Context, input *UpdateManagedSchemasInput) (*UpdateManagedSchemasOutput, error)

type LogTypesAPILambdaClient

+ func (c *LogTypesAPILambdaClient) GetSchema(ctx context.Context, input *GetSchemaInput) (*GetSchemaOutput, error)

+ func (c *LogTypesAPILambdaClient) ListManagedSchemaUpdates(ctx context.Context, input *ListManagedSchemaUpdatesInput) (*ListManagedSchemaUpdatesOutput, error)

+ func (c *LogTypesAPILambdaClient) UpdateManagedSchemas(ctx context.Context, input *UpdateManagedSchemasInput) (*UpdateManagedSchemasOutput, error)

type LogTypesAPIPayload

+ GetSchema *GetSchemaInput

+ ListManagedSchemaUpdates *ListManagedSchemaUpdatesInput

+ UpdateManagedSchemas *UpdateManagedSchemasInput

type PutCustomLogInput

+ Description string

+ ReferenceURL string

+ Spec string

type Resolver

+ NativeLogTypes logtypes.Finder

+ type ScanSchemaFunc func(r *SchemaRecord) bool

+ type SchemaDatabase interface

+ GetSchema func(ctx context.Context, id string) (*SchemaRecord, error)

+ PutSchema func(ctx context.Context, id string, record *SchemaRecord) (*SchemaRecord, error)

+ ScanSchemas func(ctx context.Context, scan ScanSchemaFunc) error

+ type SchemaRecord struct

+ CreatedAt time.Time

+ Description string

+ Disabled bool

+ Managed bool

+ Name string

+ ReferenceURL string

+ Release string

+ Revision int64

+ Spec string

+ UpdatedAt time.Time

+ func (r *SchemaRecord) IsCustom() bool

+ func (r *SchemaRecord) IsManaged() bool

+ type UpdateManagedSchemasInput struct

+ ManifestURL string

+ Release string

+ type UpdateManagedSchemasOutput struct

+ Error *APIError

+ Records []*SchemaRecord

v1.15.3

Feb 5, 2021

v1.15.2

Jan 27, 2021

v1.15.1

Jan 22, 2021

v1.15.0

Jan 22, 2021

Changes in this version

+ const ErrAlreadyExists

+ const ErrInUse

+ const ErrInvalidLogSchema

+ const ErrInvalidMetadata

+ const ErrInvalidSyntax

+ const ErrInvalidUpdate

+ const ErrNotFound

+ const ErrRevisionConflict

+ const ErrServerError

+ type APIError struct

+ Code string

+ Message string

+ func AsAPIError(err error) *APIError

+ func NewAPIError(code, message string) *APIError

+ func WrapAPIError(err error) *APIError

+ func (e *APIError) Error() string

+ func (e *APIError) Unwrap() error

+ type CustomLog struct

+ Description string

+ LogSpec string

+ ReferenceURL string

+ type CustomLogRecord struct

+ LogType string

+ Revision int64

+ UpdatedAt time.Time

+ type DelCustomLogInput struct

+ LogType string

+ Revision int64

+ type DelCustomLogOutput struct

+ Error *APIError

+ type DeletedCustomLogs struct

+ Error *APIError

+ LogTypes []string

type DynamoDBLogTypes

+ func (d *DynamoDBLogTypes) BatchGetCustomLogs(ctx context.Context, ids ...string) ([]*CustomLogRecord, error)

+ func (d *DynamoDBLogTypes) CreateCustomLog(ctx context.Context, id string, params *CustomLog) (*CustomLogRecord, error)

+ func (d *DynamoDBLogTypes) DeleteCustomLog(ctx context.Context, id string, revision int64) error

+ func (d *DynamoDBLogTypes) GetCustomLog(ctx context.Context, id string, revision int64) (*CustomLogRecord, error)

+ func (d *DynamoDBLogTypes) ListDeletedLogTypes(ctx context.Context) ([]string, error)

+ func (d *DynamoDBLogTypes) UpdateCustomLog(ctx context.Context, id string, revision int64, params *CustomLog) (*CustomLogRecord, error)

+ type ErrorReply struct

+ Error *APIError

+ type GetCustomLogInput struct

+ LogType string

+ Revision int64

+ type GetCustomLogOutput struct

+ Error *APIError

+ Result *CustomLogRecord

+ type InMemDB struct

+ func NewInMemory() *InMemDB

+ func (db *InMemDB) BatchGetCustomLogs(ctx context.Context, ids ...string) ([]*CustomLogRecord, error)

+ func (db *InMemDB) CreateCustomLog(_ context.Context, id string, params *CustomLog) (*CustomLogRecord, error)

+ func (db *InMemDB) DeleteCustomLog(_ context.Context, id string, revision int64) error

+ func (db *InMemDB) GetCustomLog(_ context.Context, id string, revision int64) (*CustomLogRecord, error)

+ func (db *InMemDB) IndexLogTypes(_ context.Context) ([]string, error)

+ func (db *InMemDB) ListDeletedLogTypes(ctx context.Context) ([]string, error)

+ func (db *InMemDB) UpdateCustomLog(_ context.Context, id string, revision int64, params *CustomLog) (*CustomLogRecord, error)

+ type ListCustomLogsOutput struct

+ CustomLogs []*CustomLogRecord

+ Error *APIError

type LogTypesAPI

+ LogTypeInUse func(ctx context.Context) ([]string, error)

+ UpdateDataCatalog func(ctx context.Context, logType string, from, to []logschema.FieldSchema) error

+ func (api *LogTypesAPI) DelCustomLog(ctx context.Context, input *DelCustomLogInput) (*DelCustomLogOutput, error)

+ func (api *LogTypesAPI) GetCustomLog(ctx context.Context, input *GetCustomLogInput) (*GetCustomLogOutput, error)

+ func (api *LogTypesAPI) ListCustomLogs(ctx context.Context) (*ListCustomLogsOutput, error)

+ func (api *LogTypesAPI) ListDeletedCustomLogs(ctx context.Context) (*DeletedCustomLogs, error)

+ func (api *LogTypesAPI) PutCustomLog(ctx context.Context, input *PutCustomLogInput) (*PutCustomLogOutput, error)

type LogTypesAPILambdaClient

+ func (c *LogTypesAPILambdaClient) DelCustomLog(ctx context.Context, input *DelCustomLogInput) (*DelCustomLogOutput, error)

+ func (c *LogTypesAPILambdaClient) GetCustomLog(ctx context.Context, input *GetCustomLogInput) (*GetCustomLogOutput, error)

+ func (c *LogTypesAPILambdaClient) ListCustomLogs(ctx context.Context) (*ListCustomLogsOutput, error)

+ func (c *LogTypesAPILambdaClient) ListDeletedCustomLogs(ctx context.Context) (*DeletedCustomLogs, error)

+ func (c *LogTypesAPILambdaClient) PutCustomLog(ctx context.Context, input *PutCustomLogInput) (*PutCustomLogOutput, error)

type LogTypesAPIPayload

+ DelCustomLog *DelCustomLogInput

+ GetCustomLog *GetCustomLogInput

+ ListCustomLogs *struct{}

+ ListDeletedCustomLogs *struct{}

+ PutCustomLog *PutCustomLogInput

type LogTypesDatabase

+ BatchGetCustomLogs func(ctx context.Context, ids ...string) ([]*CustomLogRecord, error)

+ CreateCustomLog func(ctx context.Context, id string, params *CustomLog) (*CustomLogRecord, error)

+ DeleteCustomLog func(ctx context.Context, id string, currentRevision int64) error

+ GetCustomLog func(ctx context.Context, id string, revision int64) (*CustomLogRecord, error)

+ ListDeletedLogTypes func(ctx context.Context) ([]string, error)

+ UpdateCustomLog func(ctx context.Context, id string, currentRevision int64, params *CustomLog) (*CustomLogRecord, error)

+ type PutCustomLogInput struct

+ LogType string

+ Revision int64

+ type PutCustomLogOutput struct

+ Error *APIError

+ Result *CustomLogRecord

+ type Resolver struct

+ LogTypesAPI *LogTypesAPILambdaClient

+ func (r *Resolver) Resolve(ctx context.Context, name string) (logtypes.Entry, error)

v1.14.3

Dec 19, 2020

v1.14.2

Dec 15, 2020

v1.14.1

Dec 11, 2020

v1.14.0

Dec 9, 2020

Changes in this version

+ const LambdaName

v1.13.0

Nov 30, 2020

v1.12.1

Nov 13, 2020

v1.12.0

Nov 12, 2020

v1.11.0

Oct 28, 2020

v1.10.1

Oct 15, 2020

v1.10.0

Oct 14, 2020

v1.10.0-RC2

Oct 13, 2020

v1.10.0-RC1

Oct 9, 2020

v1.9.0

Oct 7, 2020

v1.9.0-RC2

Oct 1, 2020

v1.9.0-RC1

Sep 23, 2020

v1.8.0

Sep 14, 2020

Changes in this version

+ var L = lambdalogger.FromContext

+ type AvailableLogTypes struct

+ LogTypes []string

+ type DynamoDBLogTypes struct

+ DB dynamodbiface.DynamoDBAPI

+ TableName string

+ func (d *DynamoDBLogTypes) IndexLogTypes(ctx context.Context) ([]string, error)

+ type LogTypesAPI struct

+ Database LogTypesDatabase

+ NativeLogTypes func() []string

+ func (api *LogTypesAPI) ListAvailableLogTypes(ctx context.Context) (*AvailableLogTypes, error)

+ type LogTypesAPILambdaClient struct

+ JSON jsoniter.API

+ LambdaAPI *lambda.Lambda

+ LambdaName string

+ Validate func(interface{}) error

+ func (c *LogTypesAPILambdaClient) ListAvailableLogTypes(ctx context.Context) (*AvailableLogTypes, error)

+ type LogTypesAPIPayload struct

+ ListAvailableLogTypes *struct{}

+ type LogTypesDatabase interface

+ IndexLogTypes func(ctx context.Context) ([]string, error)

v1.8.0-beta

Sep 14, 2020

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL