federatedlearning

Documentation

Index

• Constants
• func New(client clienttypes.ClientI) types.FeatureManager
• type FederatedLearning
• type Manager
  • func (fm *Manager) AddWorkerMessage(message workertypes.MessageContent)
  • func (fm *Manager) Delete(message *clienttypes.Message) error
  • func (fm *Manager) GetName() string
  • func (fm *Manager) Insert(message *clienttypes.Message) error
  • func (fm *Manager) Start() error

Constants

const (
	//KindName is kind of federated-learning-job resource
	KindName = "federatedlearningjob"
)

Functions

func New

func New(client clienttypes.ClientI) types.FeatureManager

New creates a federated-learning-job types

Types

type FederatedLearning

type FederatedLearning struct {
	*sednav1.FederatedLearningJob
}

FederatedLearning defines config for federated-learning-job

type Manager

type Manager struct {
	Client               clienttypes.ClientI
	WorkerMessageChannel chan workertypes.MessageContent
}

FederatedLearningManager defines federated-learning-job manager

func (*Manager) AddWorkerMessage

func (fm *Manager) AddWorkerMessage(message workertypes.MessageContent)

AddWorkerMessage adds worker messages to the channel

func (*Manager) Delete

func (fm *Manager) Delete(message *clienttypes.Message) error

Delete deletes federated-learning-job config in db

func (*Manager) GetName

func (fm *Manager) GetName() string

GetName returns the name of the manager

func (*Manager) Insert

func (fm *Manager) Insert(message *clienttypes.Message) error

Insert inserts federated-learning-job config in db

func (*Manager) Start

func (fm *Manager) Start() error

Start starts federated-learning-job manager