processor

Documentation

Index

• type P
  • func NewP(engineID string, client v1.InferenceWorkerServiceClient, ollamaAddr string, ...) *P
  • func (p *P) Run(ctx context.Context) error

Types

type P

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

P processes tasks.

func NewP

func NewP(
	engineID string,
	client v1.InferenceWorkerServiceClient,
	ollamaAddr string,
	modelLister modelLister,
) *P

NewP returns a new processor.

func (*P) Run

func (p *P) Run(ctx context.Context) error

Run runs the processor.