Documentation
¶
Index ¶
- Constants
- type CallOptions
- type ControlPlane
- type Dataplane
- type InferType
- type InferenceClient
- func (ic *InferenceClient) Infer(modelName string, data []byte, headers []string, authority string, ...) error
- func (ic *InferenceClient) InferGrpc(resourceName string, data []byte, headers []string, authority string, ...) error
- func (ic *InferenceClient) InferRest(resourceName string, data []byte, headers []string, authority string, ...) error
- func (ic *InferenceClient) ModelMetadata(modelName string, authority string) error
- type KafkaClient
- type KafkaConfig
- type KafkaInspect
- type KafkaInspectTopic
- type KafkaInspectTopicMessage
- type LogOptions
- type PipelineTopics
- type SchedulerClient
- func (sc *SchedulerClient) ExperimentStatus(experimentName string, showRequest bool, showResponse bool, wait bool) error
- func (sc *SchedulerClient) ListExperiments() error
- func (sc *SchedulerClient) ListModels() error
- func (sc *SchedulerClient) ListPipelines() error
- func (sc *SchedulerClient) ListServers() error
- func (sc *SchedulerClient) Load(data []byte, showRequest bool, showResponse bool) error
- func (sc *SchedulerClient) LoadModel(data []byte, showRequest bool, showResponse bool) error
- func (sc *SchedulerClient) LoadPipeline(data []byte, showRequest bool, showResponse bool) error
- func (sc *SchedulerClient) ModelStatus(modelName string, showRequest bool, showResponse bool, waitCondition string) error
- func (sc *SchedulerClient) PipelineStatus(pipelineName string, showRequest bool, showResponse bool, waitCondition string) error
- func (sc *SchedulerClient) ServerStatus(serverName string, showRequest bool, showResponse bool) error
- func (sc *SchedulerClient) StartExperiment(data []byte, showRequest bool, showResponse bool) error
- func (sc *SchedulerClient) Status(data []byte, showRequest bool, showResponse bool, wait bool) error
- func (sc *SchedulerClient) StopExperiment(experimentName string, experimentBytes []byte, showRequest bool, ...) error
- func (sc *SchedulerClient) Unload(data []byte, showRequest bool, showResponse bool) error
- func (sc *SchedulerClient) UnloadModel(modelName string, modelBytes []byte, showRequest bool, showResponse bool) error
- func (sc *SchedulerClient) UnloadPipeline(pipelineName string, pipelineBytes []byte, showRequest bool, showResponse bool) error
- type SeldonCLIConfig
- type SeldonCLIConfigs
- type V2Error
- type V2InferenceResponse
- type V2Metadata
- type V2MetadataTensor
Constants ¶
View Source
const ( KafkaConfigProtocolSSL = "ssl" KafkaConfigProtocolSASLSSL = "sasl_ssl" KafkaConfigProtocolSASLPlaintxt = "sasl_plaintxt" )
View Source
const ( InspectFormatRaw = "raw" InspectFormatJson = "json" )
CLI constants
View Source
const ( SeldonModelHeader = "seldon-model" SeldonRouteHeader = "x-seldon-route" SeldonPipelineHeader = "pipeline" HeaderSeparator = "=" )
View Source
const ( SeldonDefaultTopicPrefix = "seldon" InputsSpecifier = "inputs" OutputsSpecifier = "outputs" PipelineSpecifier = "pipeline" ModelSpecifier = "model" DefaultNamespace = "default" )
View Source
const (
Undefined seldonKind = iota
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CallOptions ¶
type ControlPlane ¶
type InferenceClient ¶
type InferenceClient struct {
// contains filtered or unexported fields
}
func NewInferenceClient ¶
func NewInferenceClient(host string, hostIsSet bool) (*InferenceClient, error)
func (*InferenceClient) Infer ¶
func (ic *InferenceClient) Infer( modelName string, data []byte, headers []string, authority string, callOptions *CallOptions, logOptions *LogOptions, ) error
func (*InferenceClient) InferGrpc ¶
func (ic *InferenceClient) InferGrpc( resourceName string, data []byte, headers []string, authority string, stickySessionKeys []string, callOptions *CallOptions, logOptions *LogOptions, ) error
func (*InferenceClient) InferRest ¶
func (ic *InferenceClient) InferRest( resourceName string, data []byte, headers []string, authority string, stickySessionKeys []string, callOptions *CallOptions, logOptions *LogOptions, ) error
func (*InferenceClient) ModelMetadata ¶
func (ic *InferenceClient) ModelMetadata(modelName string, authority string) error
type KafkaClient ¶
type KafkaClient struct {
// contains filtered or unexported fields
}
func NewKafkaClient ¶
type KafkaConfig ¶
type KafkaConfig struct {
Bootstrap string `json:"bootstrap,omitempty"`
Namespace string `json:"namespace,omitempty"`
Protocol string `json:"protocol,omitempty"`
KeyPath string `json:"keyPath,omitempty"`
CrtPath string `json:"crtPath,omitempty"`
CaPath string `json:"caPath,omitempty"`
SaslUsername string `json:"saslUsername,omitempty"`
SaslPassword string `json:"saslPassword,omitempty"`
TopicPrefix string `json:"topicPrefix,omitempty"`
}
type KafkaInspect ¶
type KafkaInspect struct {
Topics []*KafkaInspectTopic `json:"topics"`
}
type KafkaInspectTopic ¶
type KafkaInspectTopic struct {
Name string `json:"name"`
Msgs []*KafkaInspectTopicMessage `json:"msgs"`
}
type KafkaInspectTopicMessage ¶
type KafkaInspectTopicMessage struct {
Headers map[string][]string `json:"headers"`
Key string `json:"key"`
Value json.RawMessage `json:"value"`
}
type LogOptions ¶
type PipelineTopics ¶
type PipelineTopics struct {
// contains filtered or unexported fields
}
type SchedulerClient ¶
type SchedulerClient struct {
// contains filtered or unexported fields
}
func NewSchedulerClient ¶
func NewSchedulerClient(schedulerHost string, schedulerHostIsSet bool, authority string) (*SchedulerClient, error)
func (*SchedulerClient) ExperimentStatus ¶
func (*SchedulerClient) ListExperiments ¶
func (sc *SchedulerClient) ListExperiments() error
func (*SchedulerClient) ListModels ¶
func (sc *SchedulerClient) ListModels() error
func (*SchedulerClient) ListPipelines ¶
func (sc *SchedulerClient) ListPipelines() error
func (*SchedulerClient) ListServers ¶
func (sc *SchedulerClient) ListServers() error
func (*SchedulerClient) Load ¶ added in v2.4.0
func (sc *SchedulerClient) Load(data []byte, showRequest bool, showResponse bool) error
func (*SchedulerClient) LoadModel ¶
func (sc *SchedulerClient) LoadModel(data []byte, showRequest bool, showResponse bool) error
func (*SchedulerClient) LoadPipeline ¶
func (sc *SchedulerClient) LoadPipeline(data []byte, showRequest bool, showResponse bool) error
func (*SchedulerClient) ModelStatus ¶
func (*SchedulerClient) PipelineStatus ¶
func (*SchedulerClient) ServerStatus ¶
func (sc *SchedulerClient) ServerStatus(serverName string, showRequest bool, showResponse bool) error
func (*SchedulerClient) StartExperiment ¶
func (sc *SchedulerClient) StartExperiment(data []byte, showRequest bool, showResponse bool) error
func (*SchedulerClient) StopExperiment ¶
func (*SchedulerClient) Unload ¶ added in v2.4.0
func (sc *SchedulerClient) Unload(data []byte, showRequest bool, showResponse bool) error
func (*SchedulerClient) UnloadModel ¶
func (*SchedulerClient) UnloadPipeline ¶
type SeldonCLIConfig ¶
type SeldonCLIConfig struct {
Dataplane *Dataplane `json:"dataplane,omitempty"`
Controlplane *ControlPlane `json:"controlplane,omitempty"`
Kafka *KafkaConfig `json:"kafka,omitempty"`
}
start config struct
func LoadSeldonCLIConfig ¶
func LoadSeldonCLIConfig() (*SeldonCLIConfig, error)
type SeldonCLIConfigs ¶ added in v2.4.0
type SeldonCLIConfigs struct {
Configs map[string]string `json:"configs,omitempty"`
Active *string `json:"active,omitempty"`
}
func LoadSeldonCLIConfigs ¶ added in v2.4.0
func LoadSeldonCLIConfigs() (*SeldonCLIConfigs, error)
func (*SeldonCLIConfigs) Activate ¶ added in v2.4.0
func (sc *SeldonCLIConfigs) Activate(key string) error
func (*SeldonCLIConfigs) Add ¶ added in v2.4.0
func (sc *SeldonCLIConfigs) Add(key string, configPath string) error
func (*SeldonCLIConfigs) Deactivate ¶ added in v2.4.0
func (sc *SeldonCLIConfigs) Deactivate(key string) error
func (*SeldonCLIConfigs) List ¶ added in v2.4.0
func (sc *SeldonCLIConfigs) List(key string) error
func (*SeldonCLIConfigs) Remove ¶ added in v2.4.0
func (sc *SeldonCLIConfigs) Remove(key string) error
type V2InferenceResponse ¶
type V2Metadata ¶
type V2Metadata struct {
Name string `json:"name"`
Versions []string `json:"versions,omitempty"`
Platform string `json:"platform,omitempty"`
Inputs []V2MetadataTensor `json:"inputs,omitempty"`
Outputs []V2MetadataTensor `json:"outputs,omitempty"`
}
type V2MetadataTensor ¶
Click to show internal directories.
Click to hide internal directories.