jointinference

Documentation

Index

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

Constants

const (
	// KindName is kind of joint-inference-service resource
	KindName = "jointinferenceservice"
)

Functions

func New

func New(client clienttypes.ClientI) types.FeatureManager

New creates a joint inference manager

Types

type Manager

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

JointInferenceManager defines joint-inference-service manager

func (*Manager) AddWorkerMessage

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

AddWorkerMessage adds worker messages

func (*Manager) Delete

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

Delete deletes joint-inference-service config in db

func (*Manager) GetName

func (jm *Manager) GetName() string

GetName gets kind of the manager

func (*Manager) Insert

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

Insert inserts joint-inference-service config in db

func (*Manager) Start

func (jm *Manager) Start() error

Start starts joint-inference-service manager