zonemaster

Documentation

Index

• Variables
• func InitData(items []*kv2.ClientObjectItem) error
• func NewZoneMainJob() *injob.JobEntry
• func SetupScheduler() error
• type ApiZoneMaster
  • func (s *ApiZoneMaster) HostConfig(ctx context.Context, req *inapi.ZoneHostConfigRequest) (*inapi.ZoneHostConfigReply, error)
  • func (s *ApiZoneMaster) HostStatusSync(ctx context.Context, req *inapi.ResHost) (*inapi.ResHostBound, error)
• type ZoneMainJob
  • func (it *ZoneMainJob) Run(ctx *injob.Context) error
  • func (it *ZoneMainJob) Spec() *injob.JobSpec
  • func (it *ZoneMainJob) Status() *injob.Status

Variables

var (
	Scheduler typeScheduler.Scheduler
)

Functions

func InitData

func InitData(items []*kv2.ClientObjectItem) error

func NewZoneMainJob

func NewZoneMainJob() *injob.JobEntry

func SetupScheduler

func SetupScheduler() error

Types

type ApiZoneMaster

type ApiZoneMaster struct {
	inapi.UnimplementedApiZoneMasterServer
}

func (*ApiZoneMaster) HostConfig

func (s *ApiZoneMaster) HostConfig(
	ctx context.Context,
	req *inapi.ZoneHostConfigRequest,
) (*inapi.ZoneHostConfigReply, error)

func (*ApiZoneMaster) HostStatusSync

func (s *ApiZoneMaster) HostStatusSync(
	ctx context.Context,
	req *inapi.ResHost,
) (*inapi.ResHostBound, error)

type ZoneMainJob

type ZoneMainJob struct {
	// contains filtered or unexported fields
}

func (*ZoneMainJob) Run

func (it *ZoneMainJob) Run(ctx *injob.Context) error

func (*ZoneMainJob) Spec

func (it *ZoneMainJob) Spec() *injob.JobSpec

func (*ZoneMainJob) Status

func (it *ZoneMainJob) Status() *injob.Status