Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FSEventHandler ¶
FSEventHandler is a handler for file system events
type IRODSMessageQueueConfig ¶
type IRODSMessageQueueConfig struct { Username string Password string Host string Port int VHost string Exchange string // can be empty Queue string // can be empty }
IRODSMessageQueueConfig is a configuration object for iRODS message queue
type IRODSMessageQueueConnection ¶
type IRODSMessageQueueConnection struct { Config *IRODSMessageQueueConfig AMQPConnection *amqp.Connection AMQPChannel *amqp.Channel StartMonitor bool }
IRODSMessageQueueConnection is a connection object for iRODS message queue
func ConnectIRODSMessageQueue ¶
func ConnectIRODSMessageQueue(config *IRODSMessageQueueConfig) (*IRODSMessageQueueConnection, error)
NewIRODSMessageQueue creates a new message queue conneciton
func (*IRODSMessageQueueConnection) Disconnect ¶
func (conn *IRODSMessageQueueConnection) Disconnect()
Destroy destroys the purgeman service
func (*IRODSMessageQueueConnection) MonitorFSChanges ¶
func (conn *IRODSMessageQueueConnection) MonitorFSChanges(handler FSEventHandler) error
MonitorFSChanges monitors iRODS changes
type PurgemanService ¶
type PurgemanService struct { Config *commons.Config IRODSClient *irodsfs_clientfs.FileSystem MessageQueueConnection *IRODSMessageQueueConnection Terminate bool Mutex sync.Mutex }
PurgemanService is a service object
func NewPurgeman ¶
func NewPurgeman(config *commons.Config) (*PurgemanService, error)
NewPurgeman creates a new purgeman service
func (*PurgemanService) Destroy ¶
func (svc *PurgemanService) Destroy()
Destroy destroys the purgeman service
func (*PurgemanService) Start ¶
func (svc *PurgemanService) Start() error
Click to show internal directories.
Click to hide internal directories.