journal

Documentation

Index

• Constants
• Variables
• func FindOffsetsByTimeRange(from, till time.Time, idx appdef.QName, s istructs.IState) (fo, lo int64, err error)
• func Provide(cfg *istructsmem.AppConfigType, ep extensionpoints.IExtensionPoint)
• type EventObject
  • func NewEventObject(event istructs.IWLogEvent, appDef appdef.IAppDef, f Filter, ...) (o *EventObject, err error)
  • func (o *EventObject) AsInt64(name string) int64
  • func (o *EventObject) AsString(string) string
• type Filter
  • func NewFilter(iws appdef.IWorkspace, eventTypes []string, ...) (Filter, error)

Constants

const (
	Field_EventTypes = "EventTypes"

	Field_Offset    = "Offset"
	Field_EventTime = "EventTime"
	Field_Event     = "Event"
)

const (
	EPJournalIndices    extensionpoints.EPKey = "JournalIndices"
	EPJournalPredicates extensionpoints.EPKey = "JournalPredicates"
)

Variables

var (
	QNameViewWLogDates      = appdef.NewQName(appdef.SysPackage, "WLogDates")
	QNameProjectorWLogDates = appdef.NewQName(appdef.SysPackage, "ProjectorWLogDates")
)

Functions

func FindOffsetsByTimeRange

func FindOffsetsByTimeRange(from, till time.Time, idx appdef.QName, s istructs.IState) (fo, lo int64, err error)

func Provide

func Provide(cfg *istructsmem.AppConfigType, ep extensionpoints.IExtensionPoint)

Types

type EventObject

type EventObject struct {
	istructs.NullObject
	Data  map[string]int64
	JSON  string
	Empty bool
}

func NewEventObject

func NewEventObject(event istructs.IWLogEvent, appDef appdef.IAppDef, f Filter, opts ...coreutils.MapperOpt) (o *EventObject, err error)

func (*EventObject) AsInt64

func (o *EventObject) AsInt64(name string) int64

func (*EventObject) AsString

func (o *EventObject) AsString(string) string

type Filter

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

func NewFilter

func NewFilter(iws appdef.IWorkspace, eventTypes []string, epJournalPredicates extensionpoints.IExtensionPoint) (Filter, error)