monitor

Documentation

Index

• func IncrementActivity()
• type ActivityMonitorV1
  • func NewActivityMonitorV1(db *gorm.DB, transferRequest mcmodel.TransferRequest) *ActivityMonitorV1
  • func (m *ActivityMonitorV1) Start(ctx context.Context)
• type CloseActivityHandlerFN
• type TransferMonitor
  • func NewTransferMonitor(optFNs ...TransferMonitorOptionFN) *TransferMonitor
  • func (m *TransferMonitor) Run(c context.Context)
• 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
  • func NewTransferRequestMonitor(db *gorm.DB, ctx context.Context, transferRequest mcmodel.TransferRequest, ...) *TransferRequestMonitor
  • func (m *TransferRequestMonitor) Start()

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()