purgeman

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 6, 2021 License: BSD-3-Clause Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FSEventHandler

type FSEventHandler func(eventtype string, path string, uuid string)

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL