operation

Documentation

Index

• Constants
• func CreateOperationRequest(id uint64, operation uint64, clientName string, ...) IOperationRequest
• func CreateOperationResult(id ID, status int32, resultType uint64, payload []byte, pipeline IPipeline, ...) IOperationResult
• func NewOperationRequest() IOperationRequest
• func NewOperationResult() IOperationResult
• type AdminOperation
  • func (operation *AdminOperation) ActiveRunner() uint
  • func (operation *AdminOperation) ExecutionTimeLimits() (Duration, Duration, Duration)
  • func (operation *AdminOperation) Role() Role
  • func (operation *AdminOperation) SetActiveRunner(value uint)
  • func (operation *AdminOperation) SetRole(role Role)
• type Operation
  • func (operation *Operation) ActiveRunner() uint
  • func (operation *Operation) ExecutionTimeLimits() (Duration, Duration, Duration)
  • func (operation *Operation) Role() Role
  • func (operation *Operation) SetActiveRunner(value uint)
  • func (operation *Operation) SetRole(role Role)
• type SecureOperation
  • func (operation *SecureOperation) ActiveRunner() uint
  • func (operation *SecureOperation) ExecutionTimeLimits() (Duration, Duration, Duration)
  • func (operation *SecureOperation) Role() Role
  • func (operation *SecureOperation) SetActiveRunner(value uint)
  • func (operation *SecureOperation) SetRole(role Role)

Constants

const (
	DEFAULT_TIME_LIMIT_WARNING  time.Duration = 1000_000_000
	DEFAULT_TIME_LIMIT_ALERT    time.Duration = 1500_000_000
	DEFAULT_TIME_LIMIT_CRITICAL time.Duration = 2000_000_000
)

noinspection GoSnakeCaseUsage

Functions

func CreateOperationRequest

func CreateOperationRequest(
	id uint64,
	operation uint64,
	clientName string,
	clientVersion,
	apiVersion int32,
	token string,
	payload []byte,
) IOperationRequest

func CreateOperationResult

func CreateOperationResult(
	id ID,
	status int32,
	resultType uint64,
	payload []byte,
	pipeline IPipeline,
	duration time.Duration,
) IOperationResult

func NewOperationRequest

func NewOperationRequest() IOperationRequest

func NewOperationResult

func NewOperationResult() IOperationResult

Types

type AdminOperation

type AdminOperation struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*AdminOperation) ActiveRunner

func (operation *AdminOperation) ActiveRunner() uint

func (*AdminOperation) ExecutionTimeLimits

func (operation *AdminOperation) ExecutionTimeLimits() (Duration, Duration, Duration)

func (*AdminOperation) Role

func (operation *AdminOperation) Role() Role

func (*AdminOperation) SetActiveRunner

func (operation *AdminOperation) SetActiveRunner(value uint)

func (*AdminOperation) SetRole

func (operation *AdminOperation) SetRole(role Role)

type Operation

type Operation struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Operation) ActiveRunner

func (operation *Operation) ActiveRunner() uint

func (*Operation) ExecutionTimeLimits

func (operation *Operation) ExecutionTimeLimits() (Duration, Duration, Duration)

func (*Operation) Role

func (operation *Operation) Role() Role

func (*Operation) SetActiveRunner

func (operation *Operation) SetActiveRunner(value uint)

func (*Operation) SetRole

func (operation *Operation) SetRole(role Role)

type SecureOperation

type SecureOperation struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*SecureOperation) ActiveRunner

func (operation *SecureOperation) ActiveRunner() uint

func (*SecureOperation) ExecutionTimeLimits

func (operation *SecureOperation) ExecutionTimeLimits() (Duration, Duration, Duration)

func (*SecureOperation) Role

func (operation *SecureOperation) Role() Role

func (*SecureOperation) SetActiveRunner

func (operation *SecureOperation) SetActiveRunner(value uint)

func (*SecureOperation) SetRole

func (operation *SecureOperation) SetRole(role Role)