Documentation
¶
Index ¶
- func IncrementActivity()
- type ActivityMonitorV1
- type CloseActivityHandlerFN
- type TransferMonitor
- type TransferMonitorOptionFN
- func WithAllowedInactivityDuration(inactivityDuration time.Duration) TransferMonitorOptionFN
- func WithCloseTransferHandler(f CloseActivityHandlerFN) TransferMonitorOptionFN
- func WithFSState(fsState *fsstate.FSState) TransferMonitorOptionFN
- func WithGlobuTransferStor(gtStor stor.GlobusTransferStor) TransferMonitorOptionFN
- func WithGlobusClient(gc *globus.Client) TransferMonitorOptionFN
- func WithGlobusEndpointID(endpointID string) TransferMonitorOptionFN
- func WithGlobusTaskWindowDuration(taskWindowDuration time.Duration) TransferMonitorOptionFN
- func WithTransferRequestStor(trStor stor.TransferRequestStor) TransferMonitorOptionFN
- type TransferRequestMonitor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IncrementActivity ¶
func IncrementActivity()
Types ¶
type ActivityMonitorV1 ¶
type ActivityMonitorV1 struct {
// contains filtered or unexported fields
}
func NewActivityMonitorV1 ¶
func NewActivityMonitorV1(db *gorm.DB, transferRequest mcmodel.TransferRequest) *ActivityMonitorV1
func (*ActivityMonitorV1) Start ¶
func (m *ActivityMonitorV1) Start(ctx context.Context)
type CloseActivityHandlerFN ¶
type CloseActivityHandlerFN func(activityKey string)
type TransferMonitor ¶
type TransferMonitor struct {
// contains filtered or unexported fields
}
func NewTransferMonitor ¶
func NewTransferMonitor(optFNs ...TransferMonitorOptionFN) *TransferMonitor
func (*TransferMonitor) Run ¶
func (m *TransferMonitor) Run(c context.Context)
type TransferMonitorOptionFN ¶
type TransferMonitorOptionFN func(*TransferMonitor)
func WithAllowedInactivityDuration ¶
func WithAllowedInactivityDuration(inactivityDuration time.Duration) TransferMonitorOptionFN
func WithCloseTransferHandler ¶
func WithCloseTransferHandler(f CloseActivityHandlerFN) TransferMonitorOptionFN
func WithFSState ¶
func WithFSState(fsState *fsstate.FSState) TransferMonitorOptionFN
func WithGlobuTransferStor ¶
func WithGlobuTransferStor(gtStor stor.GlobusTransferStor) TransferMonitorOptionFN
func WithGlobusClient ¶
func WithGlobusClient(gc *globus.Client) TransferMonitorOptionFN
func WithGlobusEndpointID ¶
func WithGlobusEndpointID(endpointID string) TransferMonitorOptionFN
func WithGlobusTaskWindowDuration ¶
func WithGlobusTaskWindowDuration(taskWindowDuration time.Duration) TransferMonitorOptionFN
func WithTransferRequestStor ¶
func WithTransferRequestStor(trStor stor.TransferRequestStor) TransferMonitorOptionFN
type TransferRequestMonitor ¶
type TransferRequestMonitor struct {
// contains filtered or unexported fields
}
func NewTransferRequestMonitor ¶
func NewTransferRequestMonitor(db *gorm.DB, ctx context.Context, transferRequest mcmodel.TransferRequest, handleFn func()) *TransferRequestMonitor
func (*TransferRequestMonitor) Start ¶
func (m *TransferRequestMonitor) Start()
Source Files
Click to show internal directories.
Click to hide internal directories.