dirwatch

Documentation

Index

• func GetSource() api.Source
• type FileDirSource
  • func (f *FileDirSource) Close(ctx api.StreamContext) error
  • func (f *FileDirSource) Connect(ctx api.StreamContext, sch api.StatusChangeHandler) error
  • func (f *FileDirSource) GetOffset() (any, error)
  • func (f *FileDirSource) Provision(ctx api.StreamContext, configs map[string]any) error
  • func (f *FileDirSource) ResetOffset(input map[string]any) error
  • func (f *FileDirSource) Rewind(offset any) error
  • func (f *FileDirSource) Subscribe(ctx api.StreamContext, ingest api.TupleIngest, ingestError api.ErrorIngest) error
• type FileDirSourceConfig
• type FileDirSourceRewindMeta
• type FileSourceTask
• type FileTaskType
• type FileWithTime
• type FileWithTimeSlice
  • func (f FileWithTimeSlice) Len() int
  • func (f FileWithTimeSlice) Less(i, j int) bool
  • func (f FileWithTimeSlice) Swap(i, j int)

Functions

func GetSource

func GetSource() api.Source

Types

type FileDirSource

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

func (*FileDirSource) Close

func (f *FileDirSource) Close(ctx api.StreamContext) error

func (*FileDirSource) Connect

func (f *FileDirSource) Connect(ctx api.StreamContext, sch api.StatusChangeHandler) error

func (*FileDirSource) GetOffset

func (f *FileDirSource) GetOffset() (any, error)

func (*FileDirSource) Provision

func (f *FileDirSource) Provision(ctx api.StreamContext, configs map[string]any) error

func (*FileDirSource) ResetOffset

func (f *FileDirSource) ResetOffset(input map[string]any) error

func (*FileDirSource) Rewind

func (f *FileDirSource) Rewind(offset any) error

func (*FileDirSource) Subscribe

func (f *FileDirSource) Subscribe(ctx api.StreamContext, ingest api.TupleIngest, ingestError api.ErrorIngest) error

type FileDirSourceConfig

type FileDirSourceConfig struct {
	Path             string   `json:"path"`
	AllowedExtension []string `json:"allowedExtension"`
}

type FileDirSourceRewindMeta

type FileDirSourceRewindMeta struct {
	LastModifyTime time.Time `json:"lastModifyTime"`
}

type FileSourceTask

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

type FileTaskType

type FileTaskType int

const (
	CreateFile FileTaskType = iota
	WriteFile
)

type FileWithTime

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

type FileWithTimeSlice

type FileWithTimeSlice []FileWithTime

func (FileWithTimeSlice) Len

func (f FileWithTimeSlice) Len() int

func (FileWithTimeSlice) Less

func (f FileWithTimeSlice) Less(i, j int) bool

func (FileWithTimeSlice) Swap

func (f FileWithTimeSlice) Swap(i, j int)