Versions in this module Expand all Collapse all v2 v2.10.2 Dec 18, 2025 v2.10.1 Oct 20, 2025 v2.10.0 Oct 8, 2025 v2.9.1 Jul 9, 2025 v2.9.0 Apr 7, 2025 v2.8.5 Nov 7, 2024 v2.8.4 Oct 11, 2024 v2.8.2 Jun 26, 2024 v2.8.0 Feb 28, 2024 v2.7.0 Jan 22, 2024 v2.4.0 Apr 18, 2023 Changes in this version + const DefaultNamespace + const KafkaConfigProtocolSASLPlaintxt + const KafkaConfigProtocolSASLSSL + const KafkaConfigProtocolSSL + const SeldonDefaultTopicPrefix + const Undefined type KafkaConfig + Namespace string + Protocol string + SaslPassword string + SaslUsername string + TopicPrefix string type SchedulerClient + func (sc *SchedulerClient) Load(data []byte, showRequest bool, showResponse bool) error + func (sc *SchedulerClient) Status(data []byte, showRequest bool, showResponse bool, wait bool) error + func (sc *SchedulerClient) Unload(data []byte, showRequest bool, showResponse bool) error + type SeldonCLIConfigs struct + Active *string + Configs map[string]string + func LoadSeldonCLIConfigs() (*SeldonCLIConfigs, error) + func (sc *SeldonCLIConfigs) Activate(key string) error + func (sc *SeldonCLIConfigs) Add(key string, configPath string) error + func (sc *SeldonCLIConfigs) Deactivate(key string) error + func (sc *SeldonCLIConfigs) List(key string) error + func (sc *SeldonCLIConfigs) Remove(key string) error v2.0.0 Dec 2, 2022 Changes in this version + const HeaderSeparator + const InputsSpecifier + const InspectFormatJson + const InspectFormatRaw + const ModelSpecifier + const OutputsSpecifier + const PipelineSpecifier + const SeldonModelHeader + const SeldonPipelineHeader + const SeldonPrefix + const SeldonRouteHeader + type CallOptions struct + InferProtocol string + InferType InferType + Iterations int + Seconds int64 + StickySession bool + type ControlPlane struct + CaPath string + CrtPath string + KeyPath string + SchedulerHost string + Tls bool + type Dataplane struct + CaPath string + CrtPath string + InferHost string + KeyPath string + SkipSSLVerify bool + Tls bool + type InferType uint32 + const InferExplainer + const InferModel + const InferPipeline + type InferenceClient struct + func NewInferenceClient(host string, hostIsSet bool) (*InferenceClient, error) + 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 struct + func NewKafkaClient(kafkaBroker string, kafkaBrokerIsSet bool, schedulerHost string, ...) (*KafkaClient, error) + func (kc *KafkaClient) InspectStep(pipelineStep string, offset int64, key string, format string, verbose bool, ...) error + type KafkaConfig struct + Bootstrap string + CaPath string + CrtPath string + KeyPath string + Tls bool + type KafkaInspect struct + Topics []*KafkaInspectTopic + type KafkaInspectTopic struct + Msgs []*KafkaInspectTopicMessage + Name string + type KafkaInspectTopicMessage struct + Headers map[string]string + Key string + Value json.RawMessage + type LogOptions struct + ShowHeaders bool + ShowRequest bool + ShowResponse bool + type PipelineTopics struct + type SchedulerClient struct + func NewSchedulerClient(schedulerHost string, schedulerHostIsSet bool, authority string) (*SchedulerClient, error) + 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) 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) StopExperiment(experimentName string, showRequest bool, showResponse bool) error + func (sc *SchedulerClient) UnloadModel(modelName string, showRequest bool, showResponse bool) error + func (sc *SchedulerClient) UnloadPipeline(pipelineName string, showRequest bool, showResponse bool) error + type SeldonCLIConfig struct + Controlplane *ControlPlane + Dataplane *Dataplane + Kafka *KafkaConfig + func LoadSeldonCLIConfig() (*SeldonCLIConfig, error) + type V2Error struct + Error string + type V2InferenceResponse struct + Id string + ModelName string + ModelVersion string + Outputs []interface{} + Parameters map[string]interface{} + type V2Metadata struct + Inputs []V2MetadataTensor + Name string + Outputs []V2MetadataTensor + Platform string + Versions []string + type V2MetadataTensor struct + Datatype string + Name string + Shape []int