Versions in this module Expand all Collapse all v1 v1.0.21 Apr 28, 2026 Changes in this version + const DefaultBufferSize + const MaxBufferSize + func RegisterKey(def KeyDefinition) + func ResetRegistryForTest() + func SanitizeAppID(appID string) string + func UnregisterKeyForTest(key string) + type APIClient interface + CallAPI func(ctx context.Context, method, path string, body interface{}) (json.RawMessage, error) + type DedupFilter struct + func NewDedupFilter() *DedupFilter + func NewDedupFilterWithSize(ringSize int, ttl time.Duration) *DedupFilter + func (d *DedupFilter) IsDuplicate(eventID string) bool + type KeyDefinition struct + AuthTypes []string + BufferSize int + Description string + DisplayName string + EventType string + Key string + Params []ParamDef + PreConsume func(ctx context.Context, rt APIClient, params map[string]string) (cleanup func(), err error) + Process func(ctx context.Context, rt APIClient, raw *RawEvent, params map[string]string) (json.RawMessage, error) + RequiredConsoleEvents []string + Schema SchemaDef + Scopes []string + Workers int + func ListAll() []*KeyDefinition + func Lookup(key string) (*KeyDefinition, bool) + type ParamDef struct + Default string + Description string + Name string + Required bool + Type ParamType + Values []ParamValue + type ParamType string + const ParamBool + const ParamEnum + const ParamInt + const ParamMulti + const ParamString + type ParamValue struct + Desc string + Value string + type ProcessFunc = func(ctx context.Context, rt APIClient, raw *RawEvent, params map[string]string) (json.RawMessage, error) + type RawEvent struct + EventID string + EventType string + Payload json.RawMessage + SourceTime string + Timestamp time.Time + type SchemaDef struct + Custom *SchemaSpec + FieldOverrides map[string]schemas.FieldMeta + Native *SchemaSpec + type SchemaSpec struct + Raw json.RawMessage + Type reflect.Type
Go to main page