intervalaction

Documentation

Overview

******************************************************************************

• Copyright 2019 VMware Inc. *
• Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
• in compliance with the License. You may obtain a copy of the License at *
• http://www.apache.org/licenses/LICENSE-2.0 *
• Unless required by applicable law or agreed to in writing, software distributed under the License
• is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
• or implied. See the License for the specific language governing permissions and limitations under
• the License. ******************************************************************************

******************************************************************************

• Copyright 2019 VMware Inc. *
• Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
• in compliance with the License. You may obtain a copy of the License at *
• http://www.apache.org/licenses/LICENSE-2.0 *
• Unless required by applicable law or agreed to in writing, software distributed under the License
• is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
• or implied. See the License for the specific language governing permissions and limitations under
• the License. ******************************************************************************

Index

• type AddExecutor
  • func NewAddExecutor(db IntervalActionWriter, scClient SchedulerQueueWriter, ...) AddExecutor
• type IntervalActionLoader
• type IntervalActionWriter
• type IntervalActionsExecutor
  • func NewAllExecutor(db IntervalActionLoader, config bootstrapConfig.ServiceInfo) IntervalActionsExecutor
• type SchedulerQueueLoader
• type SchedulerQueueWriter

Types

type AddExecutor

type AddExecutor interface {
	Execute() (string, error)
}

func NewAddExecutor

func NewAddExecutor(db IntervalActionWriter, scClient SchedulerQueueWriter, intervalAction contract.IntervalAction) AddExecutor

This factory method returns an executor used to add an addressable.

type IntervalActionLoader

type IntervalActionLoader interface {
	IntervalActions() ([]contract.IntervalAction, error)
	IntervalActionsWithLimit(limit int) ([]contract.IntervalAction, error)
	IntervalActionByName(name string) (contract.IntervalAction, error)
	IntervalActionById(id string) (contract.IntervalAction, error)
	interval.IntervalLoader
}

IntervalLoader provides functionality for obtaining Interval.

type IntervalActionWriter

type IntervalActionWriter interface {
	AddIntervalAction(interval contract.IntervalAction) (string, error)
	IntervalActionLoader
}

IntervalWriter adds interval.

type IntervalActionsExecutor

type IntervalActionsExecutor interface {
	Execute() ([]contract.IntervalAction, error)
}

This interface that returns a collection of interval actions

func NewAllExecutor

func NewAllExecutor(db IntervalActionLoader, config bootstrapConfig.ServiceInfo) IntervalActionsExecutor

This factory method returns an executor used to get interval actions.

type SchedulerQueueLoader

type SchedulerQueueLoader interface {
	QueryIntervalActionByID(intervalActionId string) (contract.IntervalAction, error)
	QueryIntervalActionByName(intervalActionName string) (contract.IntervalAction, error)
}

type SchedulerQueueWriter

type SchedulerQueueWriter interface {
	AddIntervalActionToQueue(interval contract.IntervalAction) error
	SchedulerQueueLoader
}

SchedulerQueueWriter adds interval in SchedulerQueue