loaders

Documentation

Index

• Constants
• type FileLoader
  • func NewFileLoader(getters types.DirGetters) *FileLoader
  • func (loader *FileLoader) Clone() Loader
  • func (loader *FileLoader) ProcessExisting(process ProcessFunction, typeToProcess types.LoaderObjectType) error
  • func (loader *FileLoader) ProcessStream(process ProcessFunction, typeToProcess types.LoaderObjectType, ...) error
  • func (loader *FileLoader) SetAppUUID(appUUID uuid.UUID)
  • func (loader *FileLoader) SetRemoteCache(cache cachers.CacheProcessor)
  • func (loader *FileLoader) SetUUID(devUUID uuid.UUID)
• type Loader
• type ProcessFunction
• type RedisLoader
  • func NewRedisLoader(addr string, password string, databaseID int, ...) *RedisLoader
  • func (loader *RedisLoader) Clone() Loader
  • func (loader *RedisLoader) ProcessExisting(process ProcessFunction, typeToProcess types.LoaderObjectType) error
  • func (loader *RedisLoader) ProcessStream(process ProcessFunction, typeToProcess types.LoaderObjectType, ...) (err error)
  • func (loader *RedisLoader) SetAppUUID(appUUID uuid.UUID)
  • func (loader *RedisLoader) SetRemoteCache(cache cachers.CacheProcessor)
  • func (loader *RedisLoader) SetUUID(devUUID uuid.UUID)
• type RemoteLoader
  • func NewRemoteLoader(getClient getClient, urlGetters types.URLGetters) *RemoteLoader
  • func (loader *RemoteLoader) Clone() Loader
  • func (loader *RemoteLoader) ProcessExisting(process ProcessFunction, typeToProcess types.LoaderObjectType) error
  • func (loader *RemoteLoader) ProcessStream(process ProcessFunction, typeToProcess types.LoaderObjectType, ...) (err error)
  • func (loader *RemoteLoader) SetAppUUID(appUUID uuid.UUID)
  • func (loader *RemoteLoader) SetRemoteCache(cache cachers.CacheProcessor)
  • func (loader *RemoteLoader) SetUUID(devUUID uuid.UUID)

Constants

const (
	//StreamHeader to pass for observe stream via http
	StreamHeader = "X-Stream"
	//StreamValue enable stream
	StreamValue = "true"
)

Types

type FileLoader

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

FileLoader implements loader from file backend of controller

func NewFileLoader

func NewFileLoader(getters types.DirGetters) *FileLoader

NewFileLoader return loader from files

func (*FileLoader) Clone

func (loader *FileLoader) Clone() Loader

Clone create copy

func (*FileLoader) ProcessExisting

func (loader *FileLoader) ProcessExisting(process ProcessFunction, typeToProcess types.LoaderObjectType) error

ProcessExisting for observe existing files

func (*FileLoader) ProcessStream

func (loader *FileLoader) ProcessStream(process ProcessFunction, typeToProcess types.LoaderObjectType, timeoutSeconds time.Duration) error

ProcessStream for observe new files

func (*FileLoader) SetAppUUID

func (loader *FileLoader) SetAppUUID(appUUID uuid.UUID)

SetAppUUID set app UUID

func (*FileLoader) SetRemoteCache

func (loader *FileLoader) SetRemoteCache(cache cachers.CacheProcessor)

SetRemoteCache add cache layer

func (*FileLoader) SetUUID

func (loader *FileLoader) SetUUID(devUUID uuid.UUID)

SetUUID set device UUID

type Loader

type Loader interface {
	SetAppUUID(devUUID uuid.UUID)
	SetUUID(devUUID uuid.UUID)
	ProcessStream(process ProcessFunction, typeToProcess types.LoaderObjectType, timeoutSeconds time.Duration) error
	ProcessExisting(process ProcessFunction, typeToProcess types.LoaderObjectType) error
	SetRemoteCache(cache cachers.CacheProcessor)
	Clone() Loader
}

Loader interface fo controller

type ProcessFunction

type ProcessFunction func(bytes []byte) (bool, error)

ProcessFunction is prototype of processing function

type RedisLoader

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

RedisLoader implements loader from redis backend of controller

func NewRedisLoader

func NewRedisLoader(addr string, password string, databaseID int, streamGetters types.StreamGetters) *RedisLoader

NewRedisLoader return loader from redis

func (*RedisLoader) Clone

func (loader *RedisLoader) Clone() Loader

Clone create copy

func (*RedisLoader) ProcessExisting

func (loader *RedisLoader) ProcessExisting(process ProcessFunction, typeToProcess types.LoaderObjectType) error

ProcessExisting for observe existing files

func (*RedisLoader) ProcessStream

func (loader *RedisLoader) ProcessStream(process ProcessFunction, typeToProcess types.LoaderObjectType, timeoutSeconds time.Duration) (err error)

ProcessStream for observe new files

func (*RedisLoader) SetAppUUID

func (loader *RedisLoader) SetAppUUID(appUUID uuid.UUID)

SetAppUUID set app UUID

func (*RedisLoader) SetRemoteCache

func (loader *RedisLoader) SetRemoteCache(cache cachers.CacheProcessor)

SetRemoteCache add cache layer

func (*RedisLoader) SetUUID

func (loader *RedisLoader) SetUUID(devUUID uuid.UUID)

SetUUID set device UUID

type RemoteLoader

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

RemoteLoader implements loader from http backend of controller

func NewRemoteLoader

func NewRemoteLoader(getClient getClient, urlGetters types.URLGetters) *RemoteLoader

NewRemoteLoader return loader from files

func (*RemoteLoader) Clone

func (loader *RemoteLoader) Clone() Loader

Clone create copy

func (*RemoteLoader) ProcessExisting

func (loader *RemoteLoader) ProcessExisting(process ProcessFunction, typeToProcess types.LoaderObjectType) error

ProcessExisting for observe existing files

func (*RemoteLoader) ProcessStream

func (loader *RemoteLoader) ProcessStream(process ProcessFunction, typeToProcess types.LoaderObjectType, timeoutSeconds time.Duration) (err error)

ProcessStream for observe new files

func (*RemoteLoader) SetAppUUID

func (loader *RemoteLoader) SetAppUUID(appUUID uuid.UUID)

SetAppUUID set app UUID

func (*RemoteLoader) SetRemoteCache

func (loader *RemoteLoader) SetRemoteCache(cache cachers.CacheProcessor)

SetRemoteCache add cache layer

func (*RemoteLoader) SetUUID

func (loader *RemoteLoader) SetUUID(devUUID uuid.UUID)

SetUUID set device UUID