tensorflow_serving

package
v0.0.0-...-018471a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 16, 2020 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthClassRegistrationTest        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowClassRegistrationTest          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupClassRegistrationTest = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthClassification        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowClassification          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupClassification = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthFileSystemStoragePathSource        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFileSystemStoragePathSource          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFileSystemStoragePathSource = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGetModelMetadata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGetModelMetadata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGetModelMetadata = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGetModelStatus        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGetModelStatus          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGetModelStatus = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthInference        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowInference          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupInference = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthInput        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowInput          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupInput = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthLogCollectorConfig        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogCollectorConfig          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLogCollectorConfig = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthLogging        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogging          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLogging = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthLoggingConfig        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLoggingConfig          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLoggingConfig = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthModel        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowModel          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupModel = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthModelManagement        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowModelManagement          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupModelManagement = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthModelServerConfig        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowModelServerConfig          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupModelServerConfig = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMonitoringConfig        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMonitoringConfig          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMonitoringConfig = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPlatformConfig        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPlatformConfig          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPlatformConfig = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPredict        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPredict          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPredict = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPredictionLog        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPredictionLog          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPredictionLog = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRegression        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRegression          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRegression = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSessionService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSessionService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSessionService = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSslConfig        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSslConfig          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSslConfig = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthStaticStoragePathSource        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStaticStoragePathSource          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStaticStoragePathSource = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthStatus        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStatus          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStatus = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ModelType_name = map[int32]string{
	0: "MODEL_TYPE_UNSPECIFIED",
	1: "TENSORFLOW",
	2: "OTHER",
}
View Source 
var ModelType_value = map[string]int32{
	"MODEL_TYPE_UNSPECIFIED": 0,
	"TENSORFLOW":             1,
	"OTHER":                  2,
}
View Source 
var ModelVersionStatus_State_name = map[int32]string{
	0:  "UNKNOWN",
	10: "START",
	20: "LOADING",
	30: "AVAILABLE",
	40: "UNLOADING",
	50: "END",
}
View Source 
var ModelVersionStatus_State_value = map[string]int32{
	"UNKNOWN":   0,
	"START":     10,
	"LOADING":   20,
	"AVAILABLE": 30,
	"UNLOADING": 40,
	"END":       50,
}

Functions

func RegisterModelServiceServer 

func RegisterModelServiceServer(s *grpc.Server, srv ModelServiceServer)

func RegisterPredictionServiceServer 

func RegisterPredictionServiceServer(s *grpc.Server, srv PredictionServiceServer)

func RegisterSessionServiceServer 

func RegisterSessionServiceServer(s *grpc.Server, srv SessionServiceServer)

Types

type Class 

type Class struct {
	// Label or name of the class.
	Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	// Score for this class (e.g., the probability the item belongs to this
	// class). As per the proto3 default-value semantics, if the score is missing,
	// it should be treated as 0.
	Score float32 `protobuf:"fixed32,2,opt,name=score,proto3" json:"score,omitempty"`
}

A single class.

func (*Class) Descriptor 

func (*Class) Descriptor() ([]byte, []int)

func (*Class) GetLabel 

func (m *Class) GetLabel() string

func (*Class) GetScore 

func (m *Class) GetScore() float32

func (*Class) Marshal 

func (m *Class) Marshal() (dAtA []byte, err error)

func (*Class) MarshalTo 

func (m *Class) MarshalTo(dAtA []byte) (int, error)

func (*Class) MarshalToSizedBuffer 

func (m *Class) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Class) ProtoMessage 

func (*Class) ProtoMessage()

func (*Class) Reset 

func (m *Class) Reset()

func (*Class) Size 

func (m *Class) Size() (n int)

func (*Class) String 

func (m *Class) String() string

func (*Class) Unmarshal 

func (m *Class) Unmarshal(dAtA []byte) error

func (*Class) XXX_DiscardUnknown 

func (m *Class) XXX_DiscardUnknown()

func (*Class) XXX_Marshal 

func (m *Class) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Class) XXX_Merge 

func (m *Class) XXX_Merge(src proto.Message)

func (*Class) XXX_Size 

func (m *Class) XXX_Size() int

func (*Class) XXX_Unmarshal 

func (m *Class) XXX_Unmarshal(b []byte) error

type ClassificationRequest 

type ClassificationRequest struct {
	// Model Specification. If version is not specified, will use the latest
	// (numerical) version.
	ModelSpec *ModelSpec `protobuf:"bytes,1,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	// Input data.
	Input *Input `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
}

func (*ClassificationRequest) Descriptor 

func (*ClassificationRequest) Descriptor() ([]byte, []int)

func (*ClassificationRequest) GetInput 

func (m *ClassificationRequest) GetInput() *Input

func (*ClassificationRequest) GetModelSpec 

func (m *ClassificationRequest) GetModelSpec() *ModelSpec

func (*ClassificationRequest) Marshal 

func (m *ClassificationRequest) Marshal() (dAtA []byte, err error)

func (*ClassificationRequest) MarshalTo 

func (m *ClassificationRequest) MarshalTo(dAtA []byte) (int, error)

func (*ClassificationRequest) MarshalToSizedBuffer 

func (m *ClassificationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClassificationRequest) ProtoMessage 

func (*ClassificationRequest) ProtoMessage()

func (*ClassificationRequest) Reset 

func (m *ClassificationRequest) Reset()

func (*ClassificationRequest) Size 

func (m *ClassificationRequest) Size() (n int)

func (*ClassificationRequest) String 

func (m *ClassificationRequest) String() string

func (*ClassificationRequest) Unmarshal 

func (m *ClassificationRequest) Unmarshal(dAtA []byte) error

func (*ClassificationRequest) XXX_DiscardUnknown 

func (m *ClassificationRequest) XXX_DiscardUnknown()

func (*ClassificationRequest) XXX_Marshal 

func (m *ClassificationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClassificationRequest) XXX_Merge 

func (m *ClassificationRequest) XXX_Merge(src proto.Message)

func (*ClassificationRequest) XXX_Size 

func (m *ClassificationRequest) XXX_Size() int

func (*ClassificationRequest) XXX_Unmarshal 

func (m *ClassificationRequest) XXX_Unmarshal(b []byte) error

type ClassificationResponse 

type ClassificationResponse struct {
	// Effective Model Specification used for classification.
	ModelSpec *ModelSpec `protobuf:"bytes,2,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	// Result of the classification.
	Result *ClassificationResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*ClassificationResponse) Descriptor 

func (*ClassificationResponse) Descriptor() ([]byte, []int)

func (*ClassificationResponse) GetModelSpec 

func (m *ClassificationResponse) GetModelSpec() *ModelSpec

func (*ClassificationResponse) GetResult 

func (m *ClassificationResponse) GetResult() *ClassificationResult

func (*ClassificationResponse) Marshal 

func (m *ClassificationResponse) Marshal() (dAtA []byte, err error)

func (*ClassificationResponse) MarshalTo 

func (m *ClassificationResponse) MarshalTo(dAtA []byte) (int, error)

func (*ClassificationResponse) MarshalToSizedBuffer 

func (m *ClassificationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClassificationResponse) ProtoMessage 

func (*ClassificationResponse) ProtoMessage()

func (*ClassificationResponse) Reset 

func (m *ClassificationResponse) Reset()

func (*ClassificationResponse) Size 

func (m *ClassificationResponse) Size() (n int)

func (*ClassificationResponse) String 

func (m *ClassificationResponse) String() string

func (*ClassificationResponse) Unmarshal 

func (m *ClassificationResponse) Unmarshal(dAtA []byte) error

func (*ClassificationResponse) XXX_DiscardUnknown 

func (m *ClassificationResponse) XXX_DiscardUnknown()

func (*ClassificationResponse) XXX_Marshal 

func (m *ClassificationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClassificationResponse) XXX_Merge 

func (m *ClassificationResponse) XXX_Merge(src proto.Message)

func (*ClassificationResponse) XXX_Size 

func (m *ClassificationResponse) XXX_Size() int

func (*ClassificationResponse) XXX_Unmarshal 

func (m *ClassificationResponse) XXX_Unmarshal(b []byte) error

type ClassificationResult 

type ClassificationResult struct {
	Classifications []*Classifications `protobuf:"bytes,1,rep,name=classifications,proto3" json:"classifications,omitempty"`
}

Contains one result per input example, in the same order as the input in ClassificationRequest.

func (*ClassificationResult) Descriptor 

func (*ClassificationResult) Descriptor() ([]byte, []int)

func (*ClassificationResult) GetClassifications 

func (m *ClassificationResult) GetClassifications() []*Classifications

func (*ClassificationResult) Marshal 

func (m *ClassificationResult) Marshal() (dAtA []byte, err error)

func (*ClassificationResult) MarshalTo 

func (m *ClassificationResult) MarshalTo(dAtA []byte) (int, error)

func (*ClassificationResult) MarshalToSizedBuffer 

func (m *ClassificationResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClassificationResult) ProtoMessage 

func (*ClassificationResult) ProtoMessage()

func (*ClassificationResult) Reset 

func (m *ClassificationResult) Reset()

func (*ClassificationResult) Size 

func (m *ClassificationResult) Size() (n int)

func (*ClassificationResult) String 

func (m *ClassificationResult) String() string

func (*ClassificationResult) Unmarshal 

func (m *ClassificationResult) Unmarshal(dAtA []byte) error

func (*ClassificationResult) XXX_DiscardUnknown 

func (m *ClassificationResult) XXX_DiscardUnknown()

func (*ClassificationResult) XXX_Marshal 

func (m *ClassificationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClassificationResult) XXX_Merge 

func (m *ClassificationResult) XXX_Merge(src proto.Message)

func (*ClassificationResult) XXX_Size 

func (m *ClassificationResult) XXX_Size() int

func (*ClassificationResult) XXX_Unmarshal 

func (m *ClassificationResult) XXX_Unmarshal(b []byte) error

type Classifications 

type Classifications struct {
	Classes []*Class `protobuf:"bytes,1,rep,name=classes,proto3" json:"classes,omitempty"`
}

List of classes for a single item (tensorflow.Example).

func (*Classifications) Descriptor 

func (*Classifications) Descriptor() ([]byte, []int)

func (*Classifications) GetClasses 

func (m *Classifications) GetClasses() []*Class

func (*Classifications) Marshal 

func (m *Classifications) Marshal() (dAtA []byte, err error)

func (*Classifications) MarshalTo 

func (m *Classifications) MarshalTo(dAtA []byte) (int, error)

func (*Classifications) MarshalToSizedBuffer 

func (m *Classifications) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Classifications) ProtoMessage 

func (*Classifications) ProtoMessage()

func (*Classifications) Reset 

func (m *Classifications) Reset()

func (*Classifications) Size 

func (m *Classifications) Size() (n int)

func (*Classifications) String 

func (m *Classifications) String() string

func (*Classifications) Unmarshal 

func (m *Classifications) Unmarshal(dAtA []byte) error

func (*Classifications) XXX_DiscardUnknown 

func (m *Classifications) XXX_DiscardUnknown()

func (*Classifications) XXX_Marshal 

func (m *Classifications) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Classifications) XXX_Merge 

func (m *Classifications) XXX_Merge(src proto.Message)

func (*Classifications) XXX_Size 

func (m *Classifications) XXX_Size() int

func (*Classifications) XXX_Unmarshal 

func (m *Classifications) XXX_Unmarshal(b []byte) error

type ClassifyLog 

type ClassifyLog struct {
	Request  *ClassificationRequest  `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Response *ClassificationResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
}

func (*ClassifyLog) Descriptor 

func (*ClassifyLog) Descriptor() ([]byte, []int)

func (*ClassifyLog) GetRequest 

func (m *ClassifyLog) GetRequest() *ClassificationRequest

func (*ClassifyLog) GetResponse 

func (m *ClassifyLog) GetResponse() *ClassificationResponse

func (*ClassifyLog) Marshal 

func (m *ClassifyLog) Marshal() (dAtA []byte, err error)

func (*ClassifyLog) MarshalTo 

func (m *ClassifyLog) MarshalTo(dAtA []byte) (int, error)

func (*ClassifyLog) MarshalToSizedBuffer 

func (m *ClassifyLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClassifyLog) ProtoMessage 

func (*ClassifyLog) ProtoMessage()

func (*ClassifyLog) Reset 

func (m *ClassifyLog) Reset()

func (*ClassifyLog) Size 

func (m *ClassifyLog) Size() (n int)

func (*ClassifyLog) String 

func (m *ClassifyLog) String() string

func (*ClassifyLog) Unmarshal 

func (m *ClassifyLog) Unmarshal(dAtA []byte) error

func (*ClassifyLog) XXX_DiscardUnknown 

func (m *ClassifyLog) XXX_DiscardUnknown()

func (*ClassifyLog) XXX_Marshal 

func (m *ClassifyLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClassifyLog) XXX_Merge 

func (m *ClassifyLog) XXX_Merge(src proto.Message)

func (*ClassifyLog) XXX_Size 

func (m *ClassifyLog) XXX_Size() int

func (*ClassifyLog) XXX_Unmarshal 

func (m *ClassifyLog) XXX_Unmarshal(b []byte) error

type Config1 

type Config1 struct {
	StringField string `protobuf:"bytes,1,opt,name=string_field,json=stringField,proto3" json:"string_field,omitempty"`
}

func (*Config1) Descriptor 

func (*Config1) Descriptor() ([]byte, []int)

func (*Config1) GetStringField 

func (m *Config1) GetStringField() string

func (*Config1) Marshal 

func (m *Config1) Marshal() (dAtA []byte, err error)

func (*Config1) MarshalTo 

func (m *Config1) MarshalTo(dAtA []byte) (int, error)

func (*Config1) MarshalToSizedBuffer 

func (m *Config1) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Config1) ProtoMessage 

func (*Config1) ProtoMessage()

func (*Config1) Reset 

func (m *Config1) Reset()

func (*Config1) Size 

func (m *Config1) Size() (n int)

func (*Config1) String 

func (m *Config1) String() string

func (*Config1) Unmarshal 

func (m *Config1) Unmarshal(dAtA []byte) error

func (*Config1) XXX_DiscardUnknown 

func (m *Config1) XXX_DiscardUnknown()

func (*Config1) XXX_Marshal 

func (m *Config1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Config1) XXX_Merge 

func (m *Config1) XXX_Merge(src proto.Message)

func (*Config1) XXX_Size 

func (m *Config1) XXX_Size() int

func (*Config1) XXX_Unmarshal 

func (m *Config1) XXX_Unmarshal(b []byte) error

type Config2 

type Config2 struct {
	StringField string `protobuf:"bytes,1,opt,name=string_field,json=stringField,proto3" json:"string_field,omitempty"`
}

func (*Config2) Descriptor 

func (*Config2) Descriptor() ([]byte, []int)

func (*Config2) GetStringField 

func (m *Config2) GetStringField() string

func (*Config2) Marshal 

func (m *Config2) Marshal() (dAtA []byte, err error)

func (*Config2) MarshalTo 

func (m *Config2) MarshalTo(dAtA []byte) (int, error)

func (*Config2) MarshalToSizedBuffer 

func (m *Config2) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Config2) ProtoMessage 

func (*Config2) ProtoMessage()

func (*Config2) Reset 

func (m *Config2) Reset()

func (*Config2) Size 

func (m *Config2) Size() (n int)

func (*Config2) String 

func (m *Config2) String() string

func (*Config2) Unmarshal 

func (m *Config2) Unmarshal(dAtA []byte) error

func (*Config2) XXX_DiscardUnknown 

func (m *Config2) XXX_DiscardUnknown()

func (*Config2) XXX_Marshal 

func (m *Config2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Config2) XXX_Merge 

func (m *Config2) XXX_Merge(src proto.Message)

func (*Config2) XXX_Size 

func (m *Config2) XXX_Size() int

func (*Config2) XXX_Unmarshal 

func (m *Config2) XXX_Unmarshal(b []byte) error

type ExampleList 

type ExampleList struct {
	Examples []*example.Example `protobuf:"bytes,1,rep,name=examples,proto3" json:"examples,omitempty"`
}

Specifies one or more fully independent input Examples. See examples at: 

https://github.com/tensorflow/tensorflow/blob/master/tensorflow/core/example/example.proto

func (*ExampleList) Descriptor 

func (*ExampleList) Descriptor() ([]byte, []int)

func (*ExampleList) GetExamples 

func (m *ExampleList) GetExamples() []*example.Example

func (*ExampleList) Marshal 

func (m *ExampleList) Marshal() (dAtA []byte, err error)

func (*ExampleList) MarshalTo 

func (m *ExampleList) MarshalTo(dAtA []byte) (int, error)

func (*ExampleList) MarshalToSizedBuffer 

func (m *ExampleList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExampleList) ProtoMessage 

func (*ExampleList) ProtoMessage()

func (*ExampleList) Reset 

func (m *ExampleList) Reset()

func (*ExampleList) Size 

func (m *ExampleList) Size() (n int)

func (*ExampleList) String 

func (m *ExampleList) String() string

func (*ExampleList) Unmarshal 

func (m *ExampleList) Unmarshal(dAtA []byte) error

func (*ExampleList) XXX_DiscardUnknown 

func (m *ExampleList) XXX_DiscardUnknown()

func (*ExampleList) XXX_Marshal 

func (m *ExampleList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExampleList) XXX_Merge 

func (m *ExampleList) XXX_Merge(src proto.Message)

func (*ExampleList) XXX_Size 

func (m *ExampleList) XXX_Size() int

func (*ExampleList) XXX_Unmarshal 

func (m *ExampleList) XXX_Unmarshal(b []byte) error

type ExampleListWithContext 

type ExampleListWithContext struct {
	Examples []*example.Example `protobuf:"bytes,1,rep,name=examples,proto3" json:"examples,omitempty"`
	Context  *example.Example   `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
}

Specifies one or more independent input Examples, with a common context Example.

The common use case for context is to cleanly and optimally specify some features that are common across multiple examples.

See example below with a search query as the context and multiple restaurants to perform some inference on. 

context: {
  features: {
    feature: {
      key  : "query"
      value: {
        bytes_list: {
          value: [ "pizza" ]
        }
      }
    }
  }
}

examples: {
  features: {
    feature: {
      key  : "cuisine"
      value: {
        bytes_list: {
          value: [ "Pizzeria" ]
        }
      }
    }
  }
}

examples: {
  features: {
    feature: {
      key  : "cuisine"
      value: {
        bytes_list: {
          value: [ "Taqueria" ]
        }
      }
    }
  }
}

Implementations of ExampleListWithContext merge the context Example into each of the Examples. Note that feature keys must not be duplicated between the Examples and context Example, or the behavior is undefined.

See also: 

tensorflow/core/example/example.proto
https://developers.google.com/protocol-buffers/docs/proto3#maps

func (*ExampleListWithContext) Descriptor 

func (*ExampleListWithContext) Descriptor() ([]byte, []int)

func (*ExampleListWithContext) GetContext 

func (m *ExampleListWithContext) GetContext() *example.Example

func (*ExampleListWithContext) GetExamples 

func (m *ExampleListWithContext) GetExamples() []*example.Example

func (*ExampleListWithContext) Marshal 

func (m *ExampleListWithContext) Marshal() (dAtA []byte, err error)

func (*ExampleListWithContext) MarshalTo 

func (m *ExampleListWithContext) MarshalTo(dAtA []byte) (int, error)

func (*ExampleListWithContext) MarshalToSizedBuffer 

func (m *ExampleListWithContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExampleListWithContext) ProtoMessage 

func (*ExampleListWithContext) ProtoMessage()

func (*ExampleListWithContext) Reset 

func (m *ExampleListWithContext) Reset()

func (*ExampleListWithContext) Size 

func (m *ExampleListWithContext) Size() (n int)

func (*ExampleListWithContext) String 

func (m *ExampleListWithContext) String() string

func (*ExampleListWithContext) Unmarshal 

func (m *ExampleListWithContext) Unmarshal(dAtA []byte) error

func (*ExampleListWithContext) XXX_DiscardUnknown 

func (m *ExampleListWithContext) XXX_DiscardUnknown()

func (*ExampleListWithContext) XXX_Marshal 

func (m *ExampleListWithContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExampleListWithContext) XXX_Merge 

func (m *ExampleListWithContext) XXX_Merge(src proto.Message)

func (*ExampleListWithContext) XXX_Size 

func (m *ExampleListWithContext) XXX_Size() int

func (*ExampleListWithContext) XXX_Unmarshal 

func (m *ExampleListWithContext) XXX_Unmarshal(b []byte) error

type FileSystemStoragePathSourceConfig 

type FileSystemStoragePathSourceConfig struct {
	// The servables to monitor for new versions, and aspire.
	Servables []*FileSystemStoragePathSourceConfig_ServableToMonitor `protobuf:"bytes,5,rep,name=servables,proto3" json:"servables,omitempty"`
	// A single servable name/base_path pair to monitor.
	// DEPRECATED: Use 'servables' instead.
	// TODO(b/30898016): Stop using these fields, and ultimately remove them here.
	ServableName string `protobuf:"bytes,1,opt,name=servable_name,json=servableName,proto3" json:"servable_name,omitempty"` // Deprecated: Do not use.
	BasePath     string `protobuf:"bytes,2,opt,name=base_path,json=basePath,proto3" json:"base_path,omitempty"`             // Deprecated: Do not use.
	// How long to wait between file-system polling to look for children of
	// 'base_path', in seconds.
	//
	// If set to zero, filesystem will be polled exactly once. If set to a
	// negative value (for testing use only), polling will be entirely disabled.
	FileSystemPollWaitSeconds int64 `` /* 143-byte string literal not displayed */
	// If true, then FileSystemStoragePathSource::Create() and ::UpdateConfig()
	// fail if, for any configured servables, the file system doesn't currently
	// contain at least one version under the base path.
	// (Otherwise, it will emit a warning and keep pinging the file system to
	// check for a version to appear later.)
	// DEPRECATED: Use 'servable_versions_always_present' instead, which includes
	// this behavior.
	// TODO(b/30898016): Remove 2019-10-31 or later.
	FailIfZeroVersionsAtStartup bool `` // Deprecated: Do not use.
	/* 151-byte string literal not displayed */
	// If true, the servable is always expected to exist on the underlying
	// filesystem. FileSystemStoragePathSource::Create() and ::UpdateConfig() will
	// fail if, for any configured servables, the file system doesn't currently
	// contain at least one version under the base path. In addition, if a polling
	// loop find the base path empty, it will not unload existing servables.
	ServableVersionsAlwaysPresent bool `` /* 153-byte string literal not displayed */
}

Config proto for FileSystemStoragePathSource.

func (*FileSystemStoragePathSourceConfig) Descriptor 

func (*FileSystemStoragePathSourceConfig) Descriptor() ([]byte, []int)

func (*FileSystemStoragePathSourceConfig) GetBasePath deprecated 

func (m *FileSystemStoragePathSourceConfig) GetBasePath() string

Deprecated: Do not use.

func (*FileSystemStoragePathSourceConfig) GetFailIfZeroVersionsAtStartup deprecated 

func (m *FileSystemStoragePathSourceConfig) GetFailIfZeroVersionsAtStartup() bool

Deprecated: Do not use.

func (*FileSystemStoragePathSourceConfig) GetFileSystemPollWaitSeconds 

func (m *FileSystemStoragePathSourceConfig) GetFileSystemPollWaitSeconds() int64

func (*FileSystemStoragePathSourceConfig) GetServableName deprecated 

func (m *FileSystemStoragePathSourceConfig) GetServableName() string

Deprecated: Do not use.

func (*FileSystemStoragePathSourceConfig) GetServableVersionsAlwaysPresent 

func (m *FileSystemStoragePathSourceConfig) GetServableVersionsAlwaysPresent() bool

func (*FileSystemStoragePathSourceConfig) GetServables 

func (m *FileSystemStoragePathSourceConfig) GetServables() []*FileSystemStoragePathSourceConfig_ServableToMonitor

func (*FileSystemStoragePathSourceConfig) Marshal 

func (m *FileSystemStoragePathSourceConfig) Marshal() (dAtA []byte, err error)

func (*FileSystemStoragePathSourceConfig) MarshalTo 

func (m *FileSystemStoragePathSourceConfig) MarshalTo(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig) MarshalToSizedBuffer 

func (m *FileSystemStoragePathSourceConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig) ProtoMessage 

func (*FileSystemStoragePathSourceConfig) ProtoMessage()

func (*FileSystemStoragePathSourceConfig) Reset 

func (m *FileSystemStoragePathSourceConfig) Reset()

func (*FileSystemStoragePathSourceConfig) Size 

func (m *FileSystemStoragePathSourceConfig) Size() (n int)

func (*FileSystemStoragePathSourceConfig) String 

func (m *FileSystemStoragePathSourceConfig) String() string

func (*FileSystemStoragePathSourceConfig) Unmarshal 

func (m *FileSystemStoragePathSourceConfig) Unmarshal(dAtA []byte) error

func (*FileSystemStoragePathSourceConfig) XXX_DiscardUnknown 

func (m *FileSystemStoragePathSourceConfig) XXX_DiscardUnknown()

func (*FileSystemStoragePathSourceConfig) XXX_Marshal 

func (m *FileSystemStoragePathSourceConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileSystemStoragePathSourceConfig) XXX_Merge 

func (m *FileSystemStoragePathSourceConfig) XXX_Merge(src proto.Message)

func (*FileSystemStoragePathSourceConfig) XXX_Size 

func (m *FileSystemStoragePathSourceConfig) XXX_Size() int

func (*FileSystemStoragePathSourceConfig) XXX_Unmarshal 

func (m *FileSystemStoragePathSourceConfig) XXX_Unmarshal(b []byte) error

type FileSystemStoragePathSourceConfig_ServableToMonitor 

type FileSystemStoragePathSourceConfig_ServableToMonitor struct {
	// The servable name to supply in aspired-versions callback calls. Child
	// paths of 'base_path' are considered to be versions of this servable.
	ServableName string `protobuf:"bytes,1,opt,name=servable_name,json=servableName,proto3" json:"servable_name,omitempty"`
	// The path to monitor, i.e. look for child paths of the form base_path/123.
	BasePath string `protobuf:"bytes,2,opt,name=base_path,json=basePath,proto3" json:"base_path,omitempty"`
	// The policy to determines the number of versions of the servable to be
	// served at the same time.
	ServableVersionPolicy *FileSystemStoragePathSourceConfig_ServableVersionPolicy `` /* 126-byte string literal not displayed */
}

A servable name and base path to look for versions of the servable.

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) Descriptor 

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) Descriptor() ([]byte, []int)

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) GetBasePath 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) GetBasePath() string

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) GetServableName 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) GetServableName() string

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) GetServableVersionPolicy 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) GetServableVersionPolicy() *FileSystemStoragePathSourceConfig_ServableVersionPolicy

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) Marshal 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) Marshal() (dAtA []byte, err error)

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) MarshalTo 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) MarshalTo(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) MarshalToSizedBuffer 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) ProtoMessage 

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) ProtoMessage()

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) Reset 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) Reset()

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) Size 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) Size() (n int)

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) String 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) String() string

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) Unmarshal 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) Unmarshal(dAtA []byte) error

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) XXX_DiscardUnknown 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) XXX_DiscardUnknown()

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) XXX_Marshal 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) XXX_Merge 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) XXX_Merge(src proto.Message)

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) XXX_Size 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) XXX_Size() int

func (*FileSystemStoragePathSourceConfig_ServableToMonitor) XXX_Unmarshal 

func (m *FileSystemStoragePathSourceConfig_ServableToMonitor) XXX_Unmarshal(b []byte) error

type FileSystemStoragePathSourceConfig_ServableVersionPolicy 

type FileSystemStoragePathSourceConfig_ServableVersionPolicy struct {
	// Types that are valid to be assigned to PolicyChoice:
	//	*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest_
	//	*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All_
	//	*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific_
	PolicyChoice isFileSystemStoragePathSourceConfig_ServableVersionPolicy_PolicyChoice `protobuf_oneof:"policy_choice"`
}

A policy that dictates which version(s) of a servable should be served.

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) Descriptor 

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) Descriptor() ([]byte, []int)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) GetAll 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) GetAll() *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) GetLatest 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) GetLatest() *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) GetPolicyChoice 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) GetPolicyChoice() isFileSystemStoragePathSourceConfig_ServableVersionPolicy_PolicyChoice

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) GetSpecific 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) GetSpecific() *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) Marshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) Marshal() (dAtA []byte, err error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) MarshalTo 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) MarshalTo(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) MarshalToSizedBuffer 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) ProtoMessage 

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) ProtoMessage()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) Reset 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) Reset()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) Size 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) Size() (n int)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) String 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) String() string

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) Unmarshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) Unmarshal(dAtA []byte) error

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_DiscardUnknown 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_DiscardUnknown()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_Marshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_Merge 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_Merge(src proto.Message)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_OneofWrappers 

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_Size 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_Size() int

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_Unmarshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy) XXX_Unmarshal(b []byte) error

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_All 

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_All struct {
}

Serve all versions found on disk.

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) Descriptor 

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) Descriptor() ([]byte, []int)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) Marshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) Marshal() (dAtA []byte, err error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) MarshalTo 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) MarshalTo(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) MarshalToSizedBuffer 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) ProtoMessage 

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) ProtoMessage()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) Reset 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) Reset()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) Size 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) Size() (n int)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) String 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) String() string

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) Unmarshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) Unmarshal(dAtA []byte) error

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) XXX_DiscardUnknown 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) XXX_DiscardUnknown()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) XXX_Marshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) XXX_Merge 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) XXX_Merge(src proto.Message)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) XXX_Size 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) XXX_Size() int

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) XXX_Unmarshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All) XXX_Unmarshal(b []byte) error

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_All_ 

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_All_ struct {
	All *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All `protobuf:"bytes,101,opt,name=all,proto3,oneof" json:"all,omitempty"`
}

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All_) MarshalTo 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All_) MarshalTo(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All_) MarshalToSizedBuffer 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_All_) Size 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_All_) Size() (n int)

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest 

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest struct {
	// Number of latest versions to serve. (The default is 1.)
	NumVersions uint32 `protobuf:"varint,1,opt,name=num_versions,json=numVersions,proto3" json:"num_versions,omitempty"`
}

Serve the latest versions (i.e. the ones with the highest version numbers), among those found on disk.

This is the default policy, with the default number of versions as 1.

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) Descriptor 

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) Descriptor() ([]byte, []int)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) GetNumVersions 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) GetNumVersions() uint32

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) Marshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) Marshal() (dAtA []byte, err error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) MarshalTo 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) MarshalTo(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) MarshalToSizedBuffer 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) ProtoMessage 

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) ProtoMessage()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) Reset 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) Reset()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) Size 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) Size() (n int)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) String 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) String() string

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) Unmarshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) Unmarshal(dAtA []byte) error

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) XXX_DiscardUnknown 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) XXX_DiscardUnknown()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) XXX_Marshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) XXX_Merge 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) XXX_Merge(src proto.Message)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) XXX_Size 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) XXX_Size() int

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) XXX_Unmarshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest) XXX_Unmarshal(b []byte) error

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest_ 

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest_ struct {
	Latest *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest `protobuf:"bytes,100,opt,name=latest,proto3,oneof" json:"latest,omitempty"`
}

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest_) MarshalTo 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest_) MarshalTo(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest_) MarshalToSizedBuffer 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest_) Size 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Latest_) Size() (n int)

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific 

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific struct {
	// The version numbers to serve.
	Versions []int64 `protobuf:"varint,1,rep,packed,name=versions,proto3" json:"versions,omitempty"`
}

Serve a specific version (or set of versions).

This policy is useful for rolling back to a specific version, or for canarying a specific version while still serving a separate stable version.

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) Descriptor 

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) Descriptor() ([]byte, []int)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) GetVersions 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) GetVersions() []int64

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) Marshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) Marshal() (dAtA []byte, err error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) MarshalTo 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) MarshalTo(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) MarshalToSizedBuffer 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) ProtoMessage 

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) ProtoMessage()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) Reset 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) Reset()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) Size 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) Size() (n int)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) String 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) String() string

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) Unmarshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) Unmarshal(dAtA []byte) error

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) XXX_DiscardUnknown 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) XXX_DiscardUnknown()

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) XXX_Marshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) XXX_Merge 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) XXX_Merge(src proto.Message)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) XXX_Size 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) XXX_Size() int

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) XXX_Unmarshal 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific) XXX_Unmarshal(b []byte) error

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific_ 

type FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific_ struct {
	Specific *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific `protobuf:"bytes,102,opt,name=specific,proto3,oneof" json:"specific,omitempty"`
}

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific_) MarshalTo 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific_) MarshalTo(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific_) MarshalToSizedBuffer 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific_) Size 

func (m *FileSystemStoragePathSourceConfig_ServableVersionPolicy_Specific_) Size() (n int)

type GetModelMetadataRequest 

type GetModelMetadataRequest struct {
	// Model Specification indicating which model we are querying for metadata.
	// If version is not specified, will use the latest (numerical) version.
	ModelSpec *ModelSpec `protobuf:"bytes,1,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	// Metadata fields to get. Currently supported: "signature_def".
	MetadataField []string `protobuf:"bytes,2,rep,name=metadata_field,json=metadataField,proto3" json:"metadata_field,omitempty"`
}

func (*GetModelMetadataRequest) Descriptor 

func (*GetModelMetadataRequest) Descriptor() ([]byte, []int)

func (*GetModelMetadataRequest) GetMetadataField 

func (m *GetModelMetadataRequest) GetMetadataField() []string

func (*GetModelMetadataRequest) GetModelSpec 

func (m *GetModelMetadataRequest) GetModelSpec() *ModelSpec

func (*GetModelMetadataRequest) Marshal 

func (m *GetModelMetadataRequest) Marshal() (dAtA []byte, err error)

func (*GetModelMetadataRequest) MarshalTo 

func (m *GetModelMetadataRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetModelMetadataRequest) MarshalToSizedBuffer 

func (m *GetModelMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetModelMetadataRequest) ProtoMessage 

func (*GetModelMetadataRequest) ProtoMessage()

func (*GetModelMetadataRequest) Reset 

func (m *GetModelMetadataRequest) Reset()

func (*GetModelMetadataRequest) Size 

func (m *GetModelMetadataRequest) Size() (n int)

func (*GetModelMetadataRequest) String 

func (m *GetModelMetadataRequest) String() string

func (*GetModelMetadataRequest) Unmarshal 

func (m *GetModelMetadataRequest) Unmarshal(dAtA []byte) error

func (*GetModelMetadataRequest) XXX_DiscardUnknown 

func (m *GetModelMetadataRequest) XXX_DiscardUnknown()

func (*GetModelMetadataRequest) XXX_Marshal 

func (m *GetModelMetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetModelMetadataRequest) XXX_Merge 

func (m *GetModelMetadataRequest) XXX_Merge(src proto.Message)

func (*GetModelMetadataRequest) XXX_Size 

func (m *GetModelMetadataRequest) XXX_Size() int

func (*GetModelMetadataRequest) XXX_Unmarshal 

func (m *GetModelMetadataRequest) XXX_Unmarshal(b []byte) error

type GetModelMetadataResponse 

type GetModelMetadataResponse struct {
	// Model Specification indicating which model this metadata belongs to.
	ModelSpec *ModelSpec `protobuf:"bytes,1,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	// Map of metadata field name to metadata field. The options for metadata
	// field name are listed in GetModelMetadataRequest. Currently supported:
	// "signature_def".
	Metadata map[string]*types.Any `` /* 157-byte string literal not displayed */
}

func (*GetModelMetadataResponse) Descriptor 

func (*GetModelMetadataResponse) Descriptor() ([]byte, []int)

func (*GetModelMetadataResponse) GetMetadata 

func (m *GetModelMetadataResponse) GetMetadata() map[string]*types.Any

func (*GetModelMetadataResponse) GetModelSpec 

func (m *GetModelMetadataResponse) GetModelSpec() *ModelSpec

func (*GetModelMetadataResponse) Marshal 

func (m *GetModelMetadataResponse) Marshal() (dAtA []byte, err error)

func (*GetModelMetadataResponse) MarshalTo 

func (m *GetModelMetadataResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetModelMetadataResponse) MarshalToSizedBuffer 

func (m *GetModelMetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetModelMetadataResponse) ProtoMessage 

func (*GetModelMetadataResponse) ProtoMessage()

func (*GetModelMetadataResponse) Reset 

func (m *GetModelMetadataResponse) Reset()

func (*GetModelMetadataResponse) Size 

func (m *GetModelMetadataResponse) Size() (n int)

func (*GetModelMetadataResponse) String 

func (m *GetModelMetadataResponse) String() string

func (*GetModelMetadataResponse) Unmarshal 

func (m *GetModelMetadataResponse) Unmarshal(dAtA []byte) error

func (*GetModelMetadataResponse) XXX_DiscardUnknown 

func (m *GetModelMetadataResponse) XXX_DiscardUnknown()

func (*GetModelMetadataResponse) XXX_Marshal 

func (m *GetModelMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetModelMetadataResponse) XXX_Merge 

func (m *GetModelMetadataResponse) XXX_Merge(src proto.Message)

func (*GetModelMetadataResponse) XXX_Size 

func (m *GetModelMetadataResponse) XXX_Size() int

func (*GetModelMetadataResponse) XXX_Unmarshal 

func (m *GetModelMetadataResponse) XXX_Unmarshal(b []byte) error

type GetModelStatusRequest 

type GetModelStatusRequest struct {
	// Model Specification. If version is not specified, information about all
	// versions of the model will be returned. If a version is specified, the
	// status of only that version will be returned.
	ModelSpec *ModelSpec `protobuf:"bytes,1,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
}

GetModelStatusRequest contains a ModelSpec indicating the model for which to get status.

func (*GetModelStatusRequest) Descriptor 

func (*GetModelStatusRequest) Descriptor() ([]byte, []int)

func (*GetModelStatusRequest) GetModelSpec 

func (m *GetModelStatusRequest) GetModelSpec() *ModelSpec

func (*GetModelStatusRequest) Marshal 

func (m *GetModelStatusRequest) Marshal() (dAtA []byte, err error)

func (*GetModelStatusRequest) MarshalTo 

func (m *GetModelStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetModelStatusRequest) MarshalToSizedBuffer 

func (m *GetModelStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetModelStatusRequest) ProtoMessage 

func (*GetModelStatusRequest) ProtoMessage()

func (*GetModelStatusRequest) Reset 

func (m *GetModelStatusRequest) Reset()

func (*GetModelStatusRequest) Size 

func (m *GetModelStatusRequest) Size() (n int)

func (*GetModelStatusRequest) String 

func (m *GetModelStatusRequest) String() string

func (*GetModelStatusRequest) Unmarshal 

func (m *GetModelStatusRequest) Unmarshal(dAtA []byte) error

func (*GetModelStatusRequest) XXX_DiscardUnknown 

func (m *GetModelStatusRequest) XXX_DiscardUnknown()

func (*GetModelStatusRequest) XXX_Marshal 

func (m *GetModelStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetModelStatusRequest) XXX_Merge 

func (m *GetModelStatusRequest) XXX_Merge(src proto.Message)

func (*GetModelStatusRequest) XXX_Size 

func (m *GetModelStatusRequest) XXX_Size() int

func (*GetModelStatusRequest) XXX_Unmarshal 

func (m *GetModelStatusRequest) XXX_Unmarshal(b []byte) error

type GetModelStatusResponse 

type GetModelStatusResponse struct {
	// Version number and status information for applicable model version(s).
	ModelVersionStatus []*ModelVersionStatus `protobuf:"bytes,1,rep,name=model_version_status,proto3" json:"model_version_status,omitempty"`
}

Response for ModelStatusRequest on successful run.

func (*GetModelStatusResponse) Descriptor 

func (*GetModelStatusResponse) Descriptor() ([]byte, []int)

func (*GetModelStatusResponse) GetModelVersionStatus 

func (m *GetModelStatusResponse) GetModelVersionStatus() []*ModelVersionStatus

func (*GetModelStatusResponse) Marshal 

func (m *GetModelStatusResponse) Marshal() (dAtA []byte, err error)

func (*GetModelStatusResponse) MarshalTo 

func (m *GetModelStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetModelStatusResponse) MarshalToSizedBuffer 

func (m *GetModelStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetModelStatusResponse) ProtoMessage 

func (*GetModelStatusResponse) ProtoMessage()

func (*GetModelStatusResponse) Reset 

func (m *GetModelStatusResponse) Reset()

func (*GetModelStatusResponse) Size 

func (m *GetModelStatusResponse) Size() (n int)

func (*GetModelStatusResponse) String 

func (m *GetModelStatusResponse) String() string

func (*GetModelStatusResponse) Unmarshal 

func (m *GetModelStatusResponse) Unmarshal(dAtA []byte) error

func (*GetModelStatusResponse) XXX_DiscardUnknown 

func (m *GetModelStatusResponse) XXX_DiscardUnknown()

func (*GetModelStatusResponse) XXX_Marshal 

func (m *GetModelStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetModelStatusResponse) XXX_Merge 

func (m *GetModelStatusResponse) XXX_Merge(src proto.Message)

func (*GetModelStatusResponse) XXX_Size 

func (m *GetModelStatusResponse) XXX_Size() int

func (*GetModelStatusResponse) XXX_Unmarshal 

func (m *GetModelStatusResponse) XXX_Unmarshal(b []byte) error

type InferenceResult 

type InferenceResult struct {
	ModelSpec *ModelSpec `protobuf:"bytes,1,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	// Types that are valid to be assigned to Result:
	//	*InferenceResult_ClassificationResult
	//	*InferenceResult_RegressionResult
	Result isInferenceResult_Result `protobuf_oneof:"result"`
}

Inference result, matches the type of request or is an error.

func (*InferenceResult) Descriptor 

func (*InferenceResult) Descriptor() ([]byte, []int)

func (*InferenceResult) GetClassificationResult 

func (m *InferenceResult) GetClassificationResult() *ClassificationResult

func (*InferenceResult) GetModelSpec 

func (m *InferenceResult) GetModelSpec() *ModelSpec

func (*InferenceResult) GetRegressionResult 

func (m *InferenceResult) GetRegressionResult() *RegressionResult

func (*InferenceResult) GetResult 

func (m *InferenceResult) GetResult() isInferenceResult_Result

func (*InferenceResult) Marshal 

func (m *InferenceResult) Marshal() (dAtA []byte, err error)

func (*InferenceResult) MarshalTo 

func (m *InferenceResult) MarshalTo(dAtA []byte) (int, error)

func (*InferenceResult) MarshalToSizedBuffer 

func (m *InferenceResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InferenceResult) ProtoMessage 

func (*InferenceResult) ProtoMessage()

func (*InferenceResult) Reset 

func (m *InferenceResult) Reset()

func (*InferenceResult) Size 

func (m *InferenceResult) Size() (n int)

func (*InferenceResult) String 

func (m *InferenceResult) String() string

func (*InferenceResult) Unmarshal 

func (m *InferenceResult) Unmarshal(dAtA []byte) error

func (*InferenceResult) XXX_DiscardUnknown 

func (m *InferenceResult) XXX_DiscardUnknown()

func (*InferenceResult) XXX_Marshal 

func (m *InferenceResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InferenceResult) XXX_Merge 

func (m *InferenceResult) XXX_Merge(src proto.Message)

func (*InferenceResult) XXX_OneofWrappers 

func (*InferenceResult) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*InferenceResult) XXX_Size 

func (m *InferenceResult) XXX_Size() int

func (*InferenceResult) XXX_Unmarshal 

func (m *InferenceResult) XXX_Unmarshal(b []byte) error

type InferenceResult_ClassificationResult 

type InferenceResult_ClassificationResult struct {
	ClassificationResult *ClassificationResult `` /* 127-byte string literal not displayed */
}

func (*InferenceResult_ClassificationResult) MarshalTo 

func (m *InferenceResult_ClassificationResult) MarshalTo(dAtA []byte) (int, error)

func (*InferenceResult_ClassificationResult) MarshalToSizedBuffer 

func (m *InferenceResult_ClassificationResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InferenceResult_ClassificationResult) Size 

func (m *InferenceResult_ClassificationResult) Size() (n int)

type InferenceResult_RegressionResult 

type InferenceResult_RegressionResult struct {
	RegressionResult *RegressionResult `protobuf:"bytes,3,opt,name=regression_result,json=regressionResult,proto3,oneof" json:"regression_result,omitempty"`
}

func (*InferenceResult_RegressionResult) MarshalTo 

func (m *InferenceResult_RegressionResult) MarshalTo(dAtA []byte) (int, error)

func (*InferenceResult_RegressionResult) MarshalToSizedBuffer 

func (m *InferenceResult_RegressionResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InferenceResult_RegressionResult) Size 

func (m *InferenceResult_RegressionResult) Size() (n int)

type InferenceTask 

type InferenceTask struct {
	// Model Specification. If version is not specified, will use the latest
	// (numerical) version.
	// All ModelSpecs in a MultiInferenceRequest must access the same model name.
	ModelSpec *ModelSpec `protobuf:"bytes,1,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	// Signature's method_name. Should be one of the method names defined in
	// third_party/tensorflow/python/saved_model/signature_constants.py.
	// e.g. "tensorflow/serving/classify".
	MethodName string `protobuf:"bytes,2,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
}

Inference request such as classification, regression, etc...

func (*InferenceTask) Descriptor 

func (*InferenceTask) Descriptor() ([]byte, []int)

func (*InferenceTask) GetMethodName 

func (m *InferenceTask) GetMethodName() string

func (*InferenceTask) GetModelSpec 

func (m *InferenceTask) GetModelSpec() *ModelSpec

func (*InferenceTask) Marshal 

func (m *InferenceTask) Marshal() (dAtA []byte, err error)

func (*InferenceTask) MarshalTo 

func (m *InferenceTask) MarshalTo(dAtA []byte) (int, error)

func (*InferenceTask) MarshalToSizedBuffer 

func (m *InferenceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InferenceTask) ProtoMessage 

func (*InferenceTask) ProtoMessage()

func (*InferenceTask) Reset 

func (m *InferenceTask) Reset()

func (*InferenceTask) Size 

func (m *InferenceTask) Size() (n int)

func (*InferenceTask) String 

func (m *InferenceTask) String() string

func (*InferenceTask) Unmarshal 

func (m *InferenceTask) Unmarshal(dAtA []byte) error

func (*InferenceTask) XXX_DiscardUnknown 

func (m *InferenceTask) XXX_DiscardUnknown()

func (*InferenceTask) XXX_Marshal 

func (m *InferenceTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InferenceTask) XXX_Merge 

func (m *InferenceTask) XXX_Merge(src proto.Message)

func (*InferenceTask) XXX_Size 

func (m *InferenceTask) XXX_Size() int

func (*InferenceTask) XXX_Unmarshal 

func (m *InferenceTask) XXX_Unmarshal(b []byte) error

type Input 

type Input struct {
	// Types that are valid to be assigned to Kind:
	//	*Input_ExampleList
	//	*Input_ExampleListWithContext
	Kind isInput_Kind `protobuf_oneof:"kind"`
}

func (*Input) Descriptor 

func (*Input) Descriptor() ([]byte, []int)

func (*Input) GetExampleList 

func (m *Input) GetExampleList() *ExampleList

func (*Input) GetExampleListWithContext 

func (m *Input) GetExampleListWithContext() *ExampleListWithContext

func (*Input) GetKind 

func (m *Input) GetKind() isInput_Kind

func (*Input) Marshal 

func (m *Input) Marshal() (dAtA []byte, err error)

func (*Input) MarshalTo 

func (m *Input) MarshalTo(dAtA []byte) (int, error)

func (*Input) MarshalToSizedBuffer 

func (m *Input) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) Reset 

func (m *Input) Reset()

func (*Input) Size 

func (m *Input) Size() (n int)

func (*Input) String 

func (m *Input) String() string

func (*Input) Unmarshal 

func (m *Input) Unmarshal(dAtA []byte) error

func (*Input) XXX_DiscardUnknown 

func (m *Input) XXX_DiscardUnknown()

func (*Input) XXX_Marshal 

func (m *Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Input) XXX_Merge 

func (m *Input) XXX_Merge(src proto.Message)

func (*Input) XXX_OneofWrappers 

func (*Input) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Input) XXX_Size 

func (m *Input) XXX_Size() int

func (*Input) XXX_Unmarshal 

func (m *Input) XXX_Unmarshal(b []byte) error

type Input_ExampleList 

type Input_ExampleList struct {
	ExampleList *ExampleList `protobuf:"bytes,1,opt,name=example_list,json=exampleList,proto3,oneof" json:"example_list,omitempty"`
}

func (*Input_ExampleList) MarshalTo 

func (m *Input_ExampleList) MarshalTo(dAtA []byte) (int, error)

func (*Input_ExampleList) MarshalToSizedBuffer 

func (m *Input_ExampleList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Input_ExampleList) Size 

func (m *Input_ExampleList) Size() (n int)

type Input_ExampleListWithContext 

type Input_ExampleListWithContext struct {
	ExampleListWithContext *ExampleListWithContext `` /* 137-byte string literal not displayed */
}

func (*Input_ExampleListWithContext) MarshalTo 

func (m *Input_ExampleListWithContext) MarshalTo(dAtA []byte) (int, error)

func (*Input_ExampleListWithContext) MarshalToSizedBuffer 

func (m *Input_ExampleListWithContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Input_ExampleListWithContext) Size 

func (m *Input_ExampleListWithContext) Size() (n int)

type LogCollectorConfig 

type LogCollectorConfig struct {
	// Identifies the type of the LogCollector we will use to collect these logs.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// The prefix to use for the filenames of the logs.
	FilenamePrefix string `protobuf:"bytes,2,opt,name=filename_prefix,json=filenamePrefix,proto3" json:"filename_prefix,omitempty"`
}

func (*LogCollectorConfig) Descriptor 

func (*LogCollectorConfig) Descriptor() ([]byte, []int)

func (*LogCollectorConfig) GetFilenamePrefix 

func (m *LogCollectorConfig) GetFilenamePrefix() string

func (*LogCollectorConfig) GetType 

func (m *LogCollectorConfig) GetType() string

func (*LogCollectorConfig) Marshal 

func (m *LogCollectorConfig) Marshal() (dAtA []byte, err error)

func (*LogCollectorConfig) MarshalTo 

func (m *LogCollectorConfig) MarshalTo(dAtA []byte) (int, error)

func (*LogCollectorConfig) MarshalToSizedBuffer 

func (m *LogCollectorConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogCollectorConfig) ProtoMessage 

func (*LogCollectorConfig) ProtoMessage()

func (*LogCollectorConfig) Reset 

func (m *LogCollectorConfig) Reset()

func (*LogCollectorConfig) Size 

func (m *LogCollectorConfig) Size() (n int)

func (*LogCollectorConfig) String 

func (m *LogCollectorConfig) String() string

func (*LogCollectorConfig) Unmarshal 

func (m *LogCollectorConfig) Unmarshal(dAtA []byte) error

func (*LogCollectorConfig) XXX_DiscardUnknown 

func (m *LogCollectorConfig) XXX_DiscardUnknown()

func (*LogCollectorConfig) XXX_Marshal 

func (m *LogCollectorConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogCollectorConfig) XXX_Merge 

func (m *LogCollectorConfig) XXX_Merge(src proto.Message)

func (*LogCollectorConfig) XXX_Size 

func (m *LogCollectorConfig) XXX_Size() int

func (*LogCollectorConfig) XXX_Unmarshal 

func (m *LogCollectorConfig) XXX_Unmarshal(b []byte) error

type LogMetadata 

type LogMetadata struct {
	ModelSpec      *ModelSpec      `protobuf:"bytes,1,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	SamplingConfig *SamplingConfig `protobuf:"bytes,2,opt,name=sampling_config,json=samplingConfig,proto3" json:"sampling_config,omitempty"`
	// List of tags used to load the relevant MetaGraphDef from SavedModel.
	SavedModelTags []string `protobuf:"bytes,3,rep,name=saved_model_tags,json=savedModelTags,proto3" json:"saved_model_tags,omitempty"`
}

Metadata logged along with the request logs.

func (*LogMetadata) Descriptor 

func (*LogMetadata) Descriptor() ([]byte, []int)

func (*LogMetadata) GetModelSpec 

func (m *LogMetadata) GetModelSpec() *ModelSpec

func (*LogMetadata) GetSamplingConfig 

func (m *LogMetadata) GetSamplingConfig() *SamplingConfig

func (*LogMetadata) GetSavedModelTags 

func (m *LogMetadata) GetSavedModelTags() []string

func (*LogMetadata) Marshal 

func (m *LogMetadata) Marshal() (dAtA []byte, err error)

func (*LogMetadata) MarshalTo 

func (m *LogMetadata) MarshalTo(dAtA []byte) (int, error)

func (*LogMetadata) MarshalToSizedBuffer 

func (m *LogMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogMetadata) ProtoMessage 

func (*LogMetadata) ProtoMessage()

func (*LogMetadata) Reset 

func (m *LogMetadata) Reset()

func (*LogMetadata) Size 

func (m *LogMetadata) Size() (n int)

func (*LogMetadata) String 

func (m *LogMetadata) String() string

func (*LogMetadata) Unmarshal 

func (m *LogMetadata) Unmarshal(dAtA []byte) error

func (*LogMetadata) XXX_DiscardUnknown 

func (m *LogMetadata) XXX_DiscardUnknown()

func (*LogMetadata) XXX_Marshal 

func (m *LogMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogMetadata) XXX_Merge 

func (m *LogMetadata) XXX_Merge(src proto.Message)

func (*LogMetadata) XXX_Size 

func (m *LogMetadata) XXX_Size() int

func (*LogMetadata) XXX_Unmarshal 

func (m *LogMetadata) XXX_Unmarshal(b []byte) error

type LoggingConfig 

type LoggingConfig struct {
	LogCollectorConfig *LogCollectorConfig `protobuf:"bytes,1,opt,name=log_collector_config,json=logCollectorConfig,proto3" json:"log_collector_config,omitempty"`
	SamplingConfig     *SamplingConfig     `protobuf:"bytes,2,opt,name=sampling_config,json=samplingConfig,proto3" json:"sampling_config,omitempty"`
}

Configuration for logging query/responses.

func (*LoggingConfig) Descriptor 

func (*LoggingConfig) Descriptor() ([]byte, []int)

func (*LoggingConfig) GetLogCollectorConfig 

func (m *LoggingConfig) GetLogCollectorConfig() *LogCollectorConfig

func (*LoggingConfig) GetSamplingConfig 

func (m *LoggingConfig) GetSamplingConfig() *SamplingConfig

func (*LoggingConfig) Marshal 

func (m *LoggingConfig) Marshal() (dAtA []byte, err error)

func (*LoggingConfig) MarshalTo 

func (m *LoggingConfig) MarshalTo(dAtA []byte) (int, error)

func (*LoggingConfig) MarshalToSizedBuffer 

func (m *LoggingConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoggingConfig) ProtoMessage 

func (*LoggingConfig) ProtoMessage()

func (*LoggingConfig) Reset 

func (m *LoggingConfig) Reset()

func (*LoggingConfig) Size 

func (m *LoggingConfig) Size() (n int)

func (*LoggingConfig) String 

func (m *LoggingConfig) String() string

func (*LoggingConfig) Unmarshal 

func (m *LoggingConfig) Unmarshal(dAtA []byte) error

func (*LoggingConfig) XXX_DiscardUnknown 

func (m *LoggingConfig) XXX_DiscardUnknown()

func (*LoggingConfig) XXX_Marshal 

func (m *LoggingConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoggingConfig) XXX_Merge 

func (m *LoggingConfig) XXX_Merge(src proto.Message)

func (*LoggingConfig) XXX_Size 

func (m *LoggingConfig) XXX_Size() int

func (*LoggingConfig) XXX_Unmarshal 

func (m *LoggingConfig) XXX_Unmarshal(b []byte) error

type MessageWithAny 

type MessageWithAny struct {
	AnyField *types.Any `protobuf:"bytes,1,opt,name=any_field,json=anyField,proto3" json:"any_field,omitempty"`
}

func (*MessageWithAny) Descriptor 

func (*MessageWithAny) Descriptor() ([]byte, []int)

func (*MessageWithAny) GetAnyField 

func (m *MessageWithAny) GetAnyField() *types.Any

func (*MessageWithAny) Marshal 

func (m *MessageWithAny) Marshal() (dAtA []byte, err error)

func (*MessageWithAny) MarshalTo 

func (m *MessageWithAny) MarshalTo(dAtA []byte) (int, error)

func (*MessageWithAny) MarshalToSizedBuffer 

func (m *MessageWithAny) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MessageWithAny) ProtoMessage 

func (*MessageWithAny) ProtoMessage()

func (*MessageWithAny) Reset 

func (m *MessageWithAny) Reset()

func (*MessageWithAny) Size 

func (m *MessageWithAny) Size() (n int)

func (*MessageWithAny) String 

func (m *MessageWithAny) String() string

func (*MessageWithAny) Unmarshal 

func (m *MessageWithAny) Unmarshal(dAtA []byte) error

func (*MessageWithAny) XXX_DiscardUnknown 

func (m *MessageWithAny) XXX_DiscardUnknown()

func (*MessageWithAny) XXX_Marshal 

func (m *MessageWithAny) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageWithAny) XXX_Merge 

func (m *MessageWithAny) XXX_Merge(src proto.Message)

func (*MessageWithAny) XXX_Size 

func (m *MessageWithAny) XXX_Size() int

func (*MessageWithAny) XXX_Unmarshal 

func (m *MessageWithAny) XXX_Unmarshal(b []byte) error

type ModelConfig 

type ModelConfig struct {
	// Name of the model.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Base path to the model, excluding the version directory.
	// E.g> for a model at /foo/bar/my_model/123, where 123 is the version, the
	// base path is /foo/bar/my_model.
	//
	// (This can be changed once a model is in serving, *if* the underlying data
	// remains the same. Otherwise there are no guarantees about whether the old
	// or new data will be used for model versions currently loaded.)
	BasePath string `protobuf:"bytes,2,opt,name=base_path,json=basePath,proto3" json:"base_path,omitempty"`
	// Type of model.
	// TODO(b/31336131): DEPRECATED. Please use 'model_platform' instead.
	ModelType ModelType `protobuf:"varint,3,opt,name=model_type,json=modelType,proto3,enum=tensorflow.serving.ModelType" json:"model_type,omitempty"` // Deprecated: Do not use.
	// Type of model (e.g. "tensorflow").
	//
	// (This cannot be changed once a model is in serving.)
	ModelPlatform string `protobuf:"bytes,4,opt,name=model_platform,json=modelPlatform,proto3" json:"model_platform,omitempty"`
	// Version policy for the model indicating which version(s) of the model to
	// load and make available for serving simultaneously.
	// The default option is to serve only the latest version of the model.
	//
	// (This can be changed once a model is in serving.)
	ModelVersionPolicy *FileSystemStoragePathSourceConfig_ServableVersionPolicy `protobuf:"bytes,7,opt,name=model_version_policy,json=modelVersionPolicy,proto3" json:"model_version_policy,omitempty"`
	// String labels to associate with versions of the model, allowing inference
	// queries to refer to versions by label instead of number. Multiple labels
	// can map to the same version, but not vice-versa.
	//
	// An envisioned use-case for these labels is canarying tentative versions.
	// For example, one can assign labels "stable" and "canary" to two specific
	// versions. Perhaps initially "stable" is assigned to version 0 and "canary"
	// to version 1. Once version 1 passes canary, one can shift the "stable"
	// label to refer to version 1 (at that point both labels map to the same
	// version -- version 1 -- which is fine). Later once version 2 is ready to
	// canary one can move the "canary" label to version 2. And so on.
	VersionLabels map[string]int64 `` /* 189-byte string literal not displayed */
	// Configures logging requests and responses, to the model.
	//
	// (This can be changed once a model is in serving.)
	LoggingConfig *LoggingConfig `protobuf:"bytes,6,opt,name=logging_config,json=loggingConfig,proto3" json:"logging_config,omitempty"`
}

Common configuration for loading a model being served.

func (*ModelConfig) Descriptor 

func (*ModelConfig) Descriptor() ([]byte, []int)

func (*ModelConfig) GetBasePath 

func (m *ModelConfig) GetBasePath() string

func (*ModelConfig) GetLoggingConfig 

func (m *ModelConfig) GetLoggingConfig() *LoggingConfig

func (*ModelConfig) GetModelPlatform 

func (m *ModelConfig) GetModelPlatform() string

func (*ModelConfig) GetModelType deprecated 

func (m *ModelConfig) GetModelType() ModelType

Deprecated: Do not use.

func (*ModelConfig) GetModelVersionPolicy 

func (m *ModelConfig) GetModelVersionPolicy() *FileSystemStoragePathSourceConfig_ServableVersionPolicy

func (*ModelConfig) GetName 

func (m *ModelConfig) GetName() string

func (*ModelConfig) GetVersionLabels 

func (m *ModelConfig) GetVersionLabels() map[string]int64

func (*ModelConfig) Marshal 

func (m *ModelConfig) Marshal() (dAtA []byte, err error)

func (*ModelConfig) MarshalTo 

func (m *ModelConfig) MarshalTo(dAtA []byte) (int, error)

func (*ModelConfig) MarshalToSizedBuffer 

func (m *ModelConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModelConfig) ProtoMessage 

func (*ModelConfig) ProtoMessage()

func (*ModelConfig) Reset 

func (m *ModelConfig) Reset()

func (*ModelConfig) Size 

func (m *ModelConfig) Size() (n int)

func (*ModelConfig) String 

func (m *ModelConfig) String() string

func (*ModelConfig) Unmarshal 

func (m *ModelConfig) Unmarshal(dAtA []byte) error

func (*ModelConfig) XXX_DiscardUnknown 

func (m *ModelConfig) XXX_DiscardUnknown()

func (*ModelConfig) XXX_Marshal 

func (m *ModelConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelConfig) XXX_Merge 

func (m *ModelConfig) XXX_Merge(src proto.Message)

func (*ModelConfig) XXX_Size 

func (m *ModelConfig) XXX_Size() int

func (*ModelConfig) XXX_Unmarshal 

func (m *ModelConfig) XXX_Unmarshal(b []byte) error

type ModelConfigList 

type ModelConfigList struct {
	Config []*ModelConfig `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty"`
}

Static list of models to be loaded for serving.

func (*ModelConfigList) Descriptor 

func (*ModelConfigList) Descriptor() ([]byte, []int)

func (*ModelConfigList) GetConfig 

func (m *ModelConfigList) GetConfig() []*ModelConfig

func (*ModelConfigList) Marshal 

func (m *ModelConfigList) Marshal() (dAtA []byte, err error)

func (*ModelConfigList) MarshalTo 

func (m *ModelConfigList) MarshalTo(dAtA []byte) (int, error)

func (*ModelConfigList) MarshalToSizedBuffer 

func (m *ModelConfigList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModelConfigList) ProtoMessage 

func (*ModelConfigList) ProtoMessage()

func (*ModelConfigList) Reset 

func (m *ModelConfigList) Reset()

func (*ModelConfigList) Size 

func (m *ModelConfigList) Size() (n int)

func (*ModelConfigList) String 

func (m *ModelConfigList) String() string

func (*ModelConfigList) Unmarshal 

func (m *ModelConfigList) Unmarshal(dAtA []byte) error

func (*ModelConfigList) XXX_DiscardUnknown 

func (m *ModelConfigList) XXX_DiscardUnknown()

func (*ModelConfigList) XXX_Marshal 

func (m *ModelConfigList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelConfigList) XXX_Merge 

func (m *ModelConfigList) XXX_Merge(src proto.Message)

func (*ModelConfigList) XXX_Size 

func (m *ModelConfigList) XXX_Size() int

func (*ModelConfigList) XXX_Unmarshal 

func (m *ModelConfigList) XXX_Unmarshal(b []byte) error

type ModelServerConfig 

type ModelServerConfig struct {
	// ModelServer takes either a static file-based model config list or an Any
	// proto representing custom model config that is fetched dynamically at
	// runtime (through network RPC, custom service, etc.).
	//
	// Types that are valid to be assigned to Config:
	//	*ModelServerConfig_ModelConfigList
	//	*ModelServerConfig_CustomModelConfig
	Config isModelServerConfig_Config `protobuf_oneof:"config"`
}

ModelServer config.

func (*ModelServerConfig) Descriptor 

func (*ModelServerConfig) Descriptor() ([]byte, []int)

func (*ModelServerConfig) GetConfig 

func (m *ModelServerConfig) GetConfig() isModelServerConfig_Config

func (*ModelServerConfig) GetCustomModelConfig 

func (m *ModelServerConfig) GetCustomModelConfig() *types.Any

func (*ModelServerConfig) GetModelConfigList 

func (m *ModelServerConfig) GetModelConfigList() *ModelConfigList

func (*ModelServerConfig) Marshal 

func (m *ModelServerConfig) Marshal() (dAtA []byte, err error)

func (*ModelServerConfig) MarshalTo 

func (m *ModelServerConfig) MarshalTo(dAtA []byte) (int, error)

func (*ModelServerConfig) MarshalToSizedBuffer 

func (m *ModelServerConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModelServerConfig) ProtoMessage 

func (*ModelServerConfig) ProtoMessage()

func (*ModelServerConfig) Reset 

func (m *ModelServerConfig) Reset()

func (*ModelServerConfig) Size 

func (m *ModelServerConfig) Size() (n int)

func (*ModelServerConfig) String 

func (m *ModelServerConfig) String() string

func (*ModelServerConfig) Unmarshal 

func (m *ModelServerConfig) Unmarshal(dAtA []byte) error

func (*ModelServerConfig) XXX_DiscardUnknown 

func (m *ModelServerConfig) XXX_DiscardUnknown()

func (*ModelServerConfig) XXX_Marshal 

func (m *ModelServerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelServerConfig) XXX_Merge 

func (m *ModelServerConfig) XXX_Merge(src proto.Message)

func (*ModelServerConfig) XXX_OneofWrappers 

func (*ModelServerConfig) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ModelServerConfig) XXX_Size 

func (m *ModelServerConfig) XXX_Size() int

func (*ModelServerConfig) XXX_Unmarshal 

func (m *ModelServerConfig) XXX_Unmarshal(b []byte) error

type ModelServerConfig_CustomModelConfig 

type ModelServerConfig_CustomModelConfig struct {
	CustomModelConfig *types.Any `protobuf:"bytes,2,opt,name=custom_model_config,json=customModelConfig,proto3,oneof" json:"custom_model_config,omitempty"`
}

func (*ModelServerConfig_CustomModelConfig) MarshalTo 

func (m *ModelServerConfig_CustomModelConfig) MarshalTo(dAtA []byte) (int, error)

func (*ModelServerConfig_CustomModelConfig) MarshalToSizedBuffer 

func (m *ModelServerConfig_CustomModelConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModelServerConfig_CustomModelConfig) Size 

func (m *ModelServerConfig_CustomModelConfig) Size() (n int)

type ModelServerConfig_ModelConfigList 

type ModelServerConfig_ModelConfigList struct {
	ModelConfigList *ModelConfigList `protobuf:"bytes,1,opt,name=model_config_list,json=modelConfigList,proto3,oneof" json:"model_config_list,omitempty"`
}

func (*ModelServerConfig_ModelConfigList) MarshalTo 

func (m *ModelServerConfig_ModelConfigList) MarshalTo(dAtA []byte) (int, error)

func (*ModelServerConfig_ModelConfigList) MarshalToSizedBuffer 

func (m *ModelServerConfig_ModelConfigList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModelServerConfig_ModelConfigList) Size 

func (m *ModelServerConfig_ModelConfigList) Size() (n int)

type ModelServiceClient 

type ModelServiceClient interface {
	// Gets status of model. If the ModelSpec in the request does not specify
	// version, information about all versions of the model will be returned. If
	// the ModelSpec in the request does specify a version, the status of only
	// that version will be returned.
	GetModelStatus(ctx context.Context, in *GetModelStatusRequest, opts ...grpc.CallOption) (*GetModelStatusResponse, error)
	// Reloads the set of served models. The new config supersedes the old one,
	// so if a model is omitted from the new config it will be unloaded and no
	// longer served.
	HandleReloadConfigRequest(ctx context.Context, in *ReloadConfigRequest, opts ...grpc.CallOption) (*ReloadConfigResponse, error)
}

ModelServiceClient is the client API for ModelService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewModelServiceClient 

func NewModelServiceClient(cc *grpc.ClientConn) ModelServiceClient

type ModelServiceServer 

type ModelServiceServer interface {
	// Gets status of model. If the ModelSpec in the request does not specify
	// version, information about all versions of the model will be returned. If
	// the ModelSpec in the request does specify a version, the status of only
	// that version will be returned.
	GetModelStatus(context.Context, *GetModelStatusRequest) (*GetModelStatusResponse, error)
	// Reloads the set of served models. The new config supersedes the old one,
	// so if a model is omitted from the new config it will be unloaded and no
	// longer served.
	HandleReloadConfigRequest(context.Context, *ReloadConfigRequest) (*ReloadConfigResponse, error)
}

ModelServiceServer is the server API for ModelService service.

type ModelSpec 

type ModelSpec struct {
	// Required servable name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional choice of which version of the model to use.
	//
	// Recommended to be left unset in the common case. Should be specified only
	// when there is a strong version consistency requirement.
	//
	// When left unspecified, the system will serve the best available version.
	// This is typically the latest version, though during version transitions,
	// notably when serving on a fleet of instances, may be either the previous or
	// new version.
	//
	// Types that are valid to be assigned to VersionChoice:
	//	*ModelSpec_Version
	//	*ModelSpec_VersionLabel
	VersionChoice isModelSpec_VersionChoice `protobuf_oneof:"version_choice"`
	// A named signature to evaluate. If unspecified, the default signature will
	// be used.
	SignatureName string `protobuf:"bytes,3,opt,name=signature_name,json=signatureName,proto3" json:"signature_name,omitempty"`
}

Metadata for an inference request such as the model name and version.

func (*ModelSpec) Descriptor 

func (*ModelSpec) Descriptor() ([]byte, []int)

func (*ModelSpec) GetName 

func (m *ModelSpec) GetName() string

func (*ModelSpec) GetSignatureName 

func (m *ModelSpec) GetSignatureName() string

func (*ModelSpec) GetVersion 

func (m *ModelSpec) GetVersion() *types.Int64Value

func (*ModelSpec) GetVersionChoice 

func (m *ModelSpec) GetVersionChoice() isModelSpec_VersionChoice

func (*ModelSpec) GetVersionLabel 

func (m *ModelSpec) GetVersionLabel() string

func (*ModelSpec) Marshal 

func (m *ModelSpec) Marshal() (dAtA []byte, err error)

func (*ModelSpec) MarshalTo 

func (m *ModelSpec) MarshalTo(dAtA []byte) (int, error)

func (*ModelSpec) MarshalToSizedBuffer 

func (m *ModelSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModelSpec) ProtoMessage 

func (*ModelSpec) ProtoMessage()

func (*ModelSpec) Reset 

func (m *ModelSpec) Reset()

func (*ModelSpec) Size 

func (m *ModelSpec) Size() (n int)

func (*ModelSpec) String 

func (m *ModelSpec) String() string

func (*ModelSpec) Unmarshal 

func (m *ModelSpec) Unmarshal(dAtA []byte) error

func (*ModelSpec) XXX_DiscardUnknown 

func (m *ModelSpec) XXX_DiscardUnknown()

func (*ModelSpec) XXX_Marshal 

func (m *ModelSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelSpec) XXX_Merge 

func (m *ModelSpec) XXX_Merge(src proto.Message)

func (*ModelSpec) XXX_OneofWrappers 

func (*ModelSpec) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ModelSpec) XXX_Size 

func (m *ModelSpec) XXX_Size() int

func (*ModelSpec) XXX_Unmarshal 

func (m *ModelSpec) XXX_Unmarshal(b []byte) error

type ModelSpec_Version 

type ModelSpec_Version struct {
	Version *types.Int64Value `protobuf:"bytes,2,opt,name=version,proto3,oneof" json:"version,omitempty"`
}

func (*ModelSpec_Version) MarshalTo 

func (m *ModelSpec_Version) MarshalTo(dAtA []byte) (int, error)

func (*ModelSpec_Version) MarshalToSizedBuffer 

func (m *ModelSpec_Version) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModelSpec_Version) Size 

func (m *ModelSpec_Version) Size() (n int)

type ModelSpec_VersionLabel 

type ModelSpec_VersionLabel struct {
	VersionLabel string `protobuf:"bytes,4,opt,name=version_label,json=versionLabel,proto3,oneof" json:"version_label,omitempty"`
}

func (*ModelSpec_VersionLabel) MarshalTo 

func (m *ModelSpec_VersionLabel) MarshalTo(dAtA []byte) (int, error)

func (*ModelSpec_VersionLabel) MarshalToSizedBuffer 

func (m *ModelSpec_VersionLabel) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModelSpec_VersionLabel) Size 

func (m *ModelSpec_VersionLabel) Size() (n int)

type ModelType 

type ModelType int32

The type of model. TODO(b/31336131): DEPRECATED. 

const (
	ModelType_MODEL_TYPE_UNSPECIFIED ModelType = 0 // Deprecated: Do not use.
	ModelType_TENSORFLOW             ModelType = 1 // Deprecated: Do not use.
	ModelType_OTHER                  ModelType = 2 // Deprecated: Do not use.
)

func (ModelType) EnumDescriptor 

func (ModelType) EnumDescriptor() ([]byte, []int)

func (ModelType) String 

func (x ModelType) String() string

type ModelVersionStatus 

type ModelVersionStatus struct {
	// Model version.
	Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// Model state.
	State ModelVersionStatus_State `protobuf:"varint,2,opt,name=state,proto3,enum=tensorflow.serving.ModelVersionStatus_State" json:"state,omitempty"`
	// Model status.
	Status *StatusProto `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
}

Version number, state, and status for a single version of a model.

func (*ModelVersionStatus) Descriptor 

func (*ModelVersionStatus) Descriptor() ([]byte, []int)

func (*ModelVersionStatus) GetState 

func (m *ModelVersionStatus) GetState() ModelVersionStatus_State

func (*ModelVersionStatus) GetStatus 

func (m *ModelVersionStatus) GetStatus() *StatusProto

func (*ModelVersionStatus) GetVersion 

func (m *ModelVersionStatus) GetVersion() int64

func (*ModelVersionStatus) Marshal 

func (m *ModelVersionStatus) Marshal() (dAtA []byte, err error)

func (*ModelVersionStatus) MarshalTo 

func (m *ModelVersionStatus) MarshalTo(dAtA []byte) (int, error)

func (*ModelVersionStatus) MarshalToSizedBuffer 

func (m *ModelVersionStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModelVersionStatus) ProtoMessage 

func (*ModelVersionStatus) ProtoMessage()

func (*ModelVersionStatus) Reset 

func (m *ModelVersionStatus) Reset()

func (*ModelVersionStatus) Size 

func (m *ModelVersionStatus) Size() (n int)

func (*ModelVersionStatus) String 

func (m *ModelVersionStatus) String() string

func (*ModelVersionStatus) Unmarshal 

func (m *ModelVersionStatus) Unmarshal(dAtA []byte) error

func (*ModelVersionStatus) XXX_DiscardUnknown 

func (m *ModelVersionStatus) XXX_DiscardUnknown()

func (*ModelVersionStatus) XXX_Marshal 

func (m *ModelVersionStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelVersionStatus) XXX_Merge 

func (m *ModelVersionStatus) XXX_Merge(src proto.Message)

func (*ModelVersionStatus) XXX_Size 

func (m *ModelVersionStatus) XXX_Size() int

func (*ModelVersionStatus) XXX_Unmarshal 

func (m *ModelVersionStatus) XXX_Unmarshal(b []byte) error

type ModelVersionStatus_State 

type ModelVersionStatus_State int32

States that map to ManagerState enum in tensorflow_serving/servable_state.h 

const (
	// Default value.
	ModelVersionStatus_UNKNOWN ModelVersionStatus_State = 0
	// The manager is tracking this servable, but has not initiated any action
	// pertaining to it.
	ModelVersionStatus_START ModelVersionStatus_State = 10
	// The manager has decided to load this servable. In particular, checks
	// around resource availability and other aspects have passed, and the
	// manager is about to invoke the loader's Load() method.
	ModelVersionStatus_LOADING ModelVersionStatus_State = 20
	// The manager has successfully loaded this servable and made it available
	// for serving (i.e. GetServableHandle(id) will succeed). To avoid races,
	// this state is not reported until *after* the servable is made
	// available.
	ModelVersionStatus_AVAILABLE ModelVersionStatus_State = 30
	// The manager has decided to make this servable unavailable, and unload
	// it. To avoid races, this state is reported *before* the servable is
	// made unavailable.
	ModelVersionStatus_UNLOADING ModelVersionStatus_State = 40
	// This servable has reached the end of its journey in the manager. Either
	// it loaded and ultimately unloaded successfully, or it hit an error at
	// some point in its lifecycle.
	ModelVersionStatus_END ModelVersionStatus_State = 50
)

func (ModelVersionStatus_State) EnumDescriptor 

func (ModelVersionStatus_State) EnumDescriptor() ([]byte, []int)

func (ModelVersionStatus_State) String 

func (x ModelVersionStatus_State) String() string

type MonitoringConfig 

type MonitoringConfig struct {
	PrometheusConfig *PrometheusConfig `protobuf:"bytes,1,opt,name=prometheus_config,json=prometheusConfig,proto3" json:"prometheus_config,omitempty"`
}

Configuration for monitoring.

func (*MonitoringConfig) Descriptor 

func (*MonitoringConfig) Descriptor() ([]byte, []int)

func (*MonitoringConfig) GetPrometheusConfig 

func (m *MonitoringConfig) GetPrometheusConfig() *PrometheusConfig

func (*MonitoringConfig) Marshal 

func (m *MonitoringConfig) Marshal() (dAtA []byte, err error)

func (*MonitoringConfig) MarshalTo 

func (m *MonitoringConfig) MarshalTo(dAtA []byte) (int, error)

func (*MonitoringConfig) MarshalToSizedBuffer 

func (m *MonitoringConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MonitoringConfig) ProtoMessage 

func (*MonitoringConfig) ProtoMessage()

func (*MonitoringConfig) Reset 

func (m *MonitoringConfig) Reset()

func (*MonitoringConfig) Size 

func (m *MonitoringConfig) Size() (n int)

func (*MonitoringConfig) String 

func (m *MonitoringConfig) String() string

func (*MonitoringConfig) Unmarshal 

func (m *MonitoringConfig) Unmarshal(dAtA []byte) error

func (*MonitoringConfig) XXX_DiscardUnknown 

func (m *MonitoringConfig) XXX_DiscardUnknown()

func (*MonitoringConfig) XXX_Marshal 

func (m *MonitoringConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MonitoringConfig) XXX_Merge 

func (m *MonitoringConfig) XXX_Merge(src proto.Message)

func (*MonitoringConfig) XXX_Size 

func (m *MonitoringConfig) XXX_Size() int

func (*MonitoringConfig) XXX_Unmarshal 

func (m *MonitoringConfig) XXX_Unmarshal(b []byte) error

type MultiInferenceLog 

type MultiInferenceLog struct {
	Request  *MultiInferenceRequest  `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Response *MultiInferenceResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
}

func (*MultiInferenceLog) Descriptor 

func (*MultiInferenceLog) Descriptor() ([]byte, []int)

func (*MultiInferenceLog) GetRequest 

func (m *MultiInferenceLog) GetRequest() *MultiInferenceRequest

func (*MultiInferenceLog) GetResponse 

func (m *MultiInferenceLog) GetResponse() *MultiInferenceResponse

func (*MultiInferenceLog) Marshal 

func (m *MultiInferenceLog) Marshal() (dAtA []byte, err error)

func (*MultiInferenceLog) MarshalTo 

func (m *MultiInferenceLog) MarshalTo(dAtA []byte) (int, error)

func (*MultiInferenceLog) MarshalToSizedBuffer 

func (m *MultiInferenceLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MultiInferenceLog) ProtoMessage 

func (*MultiInferenceLog) ProtoMessage()

func (*MultiInferenceLog) Reset 

func (m *MultiInferenceLog) Reset()

func (*MultiInferenceLog) Size 

func (m *MultiInferenceLog) Size() (n int)

func (*MultiInferenceLog) String 

func (m *MultiInferenceLog) String() string

func (*MultiInferenceLog) Unmarshal 

func (m *MultiInferenceLog) Unmarshal(dAtA []byte) error

func (*MultiInferenceLog) XXX_DiscardUnknown 

func (m *MultiInferenceLog) XXX_DiscardUnknown()

func (*MultiInferenceLog) XXX_Marshal 

func (m *MultiInferenceLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiInferenceLog) XXX_Merge 

func (m *MultiInferenceLog) XXX_Merge(src proto.Message)

func (*MultiInferenceLog) XXX_Size 

func (m *MultiInferenceLog) XXX_Size() int

func (*MultiInferenceLog) XXX_Unmarshal 

func (m *MultiInferenceLog) XXX_Unmarshal(b []byte) error

type MultiInferenceRequest 

type MultiInferenceRequest struct {
	// Inference tasks.
	Tasks []*InferenceTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// Input data.
	Input *Input `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
}

Inference request containing one or more requests.

func (*MultiInferenceRequest) Descriptor 

func (*MultiInferenceRequest) Descriptor() ([]byte, []int)

func (*MultiInferenceRequest) GetInput 

func (m *MultiInferenceRequest) GetInput() *Input

func (*MultiInferenceRequest) GetTasks 

func (m *MultiInferenceRequest) GetTasks() []*InferenceTask

func (*MultiInferenceRequest) Marshal 

func (m *MultiInferenceRequest) Marshal() (dAtA []byte, err error)

func (*MultiInferenceRequest) MarshalTo 

func (m *MultiInferenceRequest) MarshalTo(dAtA []byte) (int, error)

func (*MultiInferenceRequest) MarshalToSizedBuffer 

func (m *MultiInferenceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MultiInferenceRequest) ProtoMessage 

func (*MultiInferenceRequest) ProtoMessage()

func (*MultiInferenceRequest) Reset 

func (m *MultiInferenceRequest) Reset()

func (*MultiInferenceRequest) Size 

func (m *MultiInferenceRequest) Size() (n int)

func (*MultiInferenceRequest) String 

func (m *MultiInferenceRequest) String() string

func (*MultiInferenceRequest) Unmarshal 

func (m *MultiInferenceRequest) Unmarshal(dAtA []byte) error

func (*MultiInferenceRequest) XXX_DiscardUnknown 

func (m *MultiInferenceRequest) XXX_DiscardUnknown()

func (*MultiInferenceRequest) XXX_Marshal 

func (m *MultiInferenceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiInferenceRequest) XXX_Merge 

func (m *MultiInferenceRequest) XXX_Merge(src proto.Message)

func (*MultiInferenceRequest) XXX_Size 

func (m *MultiInferenceRequest) XXX_Size() int

func (*MultiInferenceRequest) XXX_Unmarshal 

func (m *MultiInferenceRequest) XXX_Unmarshal(b []byte) error

type MultiInferenceResponse 

type MultiInferenceResponse struct {
	// List of results; one for each InferenceTask in the request, returned in the
	// same order as the request.
	Results []*InferenceResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
}

Inference request containing one or more responses.

func (*MultiInferenceResponse) Descriptor 

func (*MultiInferenceResponse) Descriptor() ([]byte, []int)

func (*MultiInferenceResponse) GetResults 

func (m *MultiInferenceResponse) GetResults() []*InferenceResult

func (*MultiInferenceResponse) Marshal 

func (m *MultiInferenceResponse) Marshal() (dAtA []byte, err error)

func (*MultiInferenceResponse) MarshalTo 

func (m *MultiInferenceResponse) MarshalTo(dAtA []byte) (int, error)

func (*MultiInferenceResponse) MarshalToSizedBuffer 

func (m *MultiInferenceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MultiInferenceResponse) ProtoMessage 

func (*MultiInferenceResponse) ProtoMessage()

func (*MultiInferenceResponse) Reset 

func (m *MultiInferenceResponse) Reset()

func (*MultiInferenceResponse) Size 

func (m *MultiInferenceResponse) Size() (n int)

func (*MultiInferenceResponse) String 

func (m *MultiInferenceResponse) String() string

func (*MultiInferenceResponse) Unmarshal 

func (m *MultiInferenceResponse) Unmarshal(dAtA []byte) error

func (*MultiInferenceResponse) XXX_DiscardUnknown 

func (m *MultiInferenceResponse) XXX_DiscardUnknown()

func (*MultiInferenceResponse) XXX_Marshal 

func (m *MultiInferenceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiInferenceResponse) XXX_Merge 

func (m *MultiInferenceResponse) XXX_Merge(src proto.Message)

func (*MultiInferenceResponse) XXX_Size 

func (m *MultiInferenceResponse) XXX_Size() int

func (*MultiInferenceResponse) XXX_Unmarshal 

func (m *MultiInferenceResponse) XXX_Unmarshal(b []byte) error

type PlatformConfig 

type PlatformConfig struct {
	// The config proto for a SourceAdapter in the StoragePathSourceAdapter
	// registry.
	SourceAdapterConfig *types.Any `protobuf:"bytes,1,opt,name=source_adapter_config,json=sourceAdapterConfig,proto3" json:"source_adapter_config,omitempty"`
}

Configuration for a servable platform e.g. tensorflow or other ML systems.

func (*PlatformConfig) Descriptor 

func (*PlatformConfig) Descriptor() ([]byte, []int)

func (*PlatformConfig) GetSourceAdapterConfig 

func (m *PlatformConfig) GetSourceAdapterConfig() *types.Any

func (*PlatformConfig) Marshal 

func (m *PlatformConfig) Marshal() (dAtA []byte, err error)

func (*PlatformConfig) MarshalTo 

func (m *PlatformConfig) MarshalTo(dAtA []byte) (int, error)

func (*PlatformConfig) MarshalToSizedBuffer 

func (m *PlatformConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PlatformConfig) ProtoMessage 

func (*PlatformConfig) ProtoMessage()

func (*PlatformConfig) Reset 

func (m *PlatformConfig) Reset()

func (*PlatformConfig) Size 

func (m *PlatformConfig) Size() (n int)

func (*PlatformConfig) String 

func (m *PlatformConfig) String() string

func (*PlatformConfig) Unmarshal 

func (m *PlatformConfig) Unmarshal(dAtA []byte) error

func (*PlatformConfig) XXX_DiscardUnknown 

func (m *PlatformConfig) XXX_DiscardUnknown()

func (*PlatformConfig) XXX_Marshal 

func (m *PlatformConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlatformConfig) XXX_Merge 

func (m *PlatformConfig) XXX_Merge(src proto.Message)

func (*PlatformConfig) XXX_Size 

func (m *PlatformConfig) XXX_Size() int

func (*PlatformConfig) XXX_Unmarshal 

func (m *PlatformConfig) XXX_Unmarshal(b []byte) error

type PlatformConfigMap 

type PlatformConfigMap struct {
	// A map from a platform name to a platform config. The platform name is used
	// in ModelConfig.model_platform.
	PlatformConfigs map[string]*PlatformConfig `` /* 194-byte string literal not displayed */
}

func (*PlatformConfigMap) Descriptor 

func (*PlatformConfigMap) Descriptor() ([]byte, []int)

func (*PlatformConfigMap) GetPlatformConfigs 

func (m *PlatformConfigMap) GetPlatformConfigs() map[string]*PlatformConfig

func (*PlatformConfigMap) Marshal 

func (m *PlatformConfigMap) Marshal() (dAtA []byte, err error)

func (*PlatformConfigMap) MarshalTo 

func (m *PlatformConfigMap) MarshalTo(dAtA []byte) (int, error)

func (*PlatformConfigMap) MarshalToSizedBuffer 

func (m *PlatformConfigMap) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PlatformConfigMap) ProtoMessage 

func (*PlatformConfigMap) ProtoMessage()

func (*PlatformConfigMap) Reset 

func (m *PlatformConfigMap) Reset()

func (*PlatformConfigMap) Size 

func (m *PlatformConfigMap) Size() (n int)

func (*PlatformConfigMap) String 

func (m *PlatformConfigMap) String() string

func (*PlatformConfigMap) Unmarshal 

func (m *PlatformConfigMap) Unmarshal(dAtA []byte) error

func (*PlatformConfigMap) XXX_DiscardUnknown 

func (m *PlatformConfigMap) XXX_DiscardUnknown()

func (*PlatformConfigMap) XXX_Marshal 

func (m *PlatformConfigMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlatformConfigMap) XXX_Merge 

func (m *PlatformConfigMap) XXX_Merge(src proto.Message)

func (*PlatformConfigMap) XXX_Size 

func (m *PlatformConfigMap) XXX_Size() int

func (*PlatformConfigMap) XXX_Unmarshal 

func (m *PlatformConfigMap) XXX_Unmarshal(b []byte) error

type PredictLog 

type PredictLog struct {
	Request  *PredictRequest  `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Response *PredictResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
}

func (*PredictLog) Descriptor 

func (*PredictLog) Descriptor() ([]byte, []int)

func (*PredictLog) GetRequest 

func (m *PredictLog) GetRequest() *PredictRequest

func (*PredictLog) GetResponse 

func (m *PredictLog) GetResponse() *PredictResponse

func (*PredictLog) Marshal 

func (m *PredictLog) Marshal() (dAtA []byte, err error)

func (*PredictLog) MarshalTo 

func (m *PredictLog) MarshalTo(dAtA []byte) (int, error)

func (*PredictLog) MarshalToSizedBuffer 

func (m *PredictLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PredictLog) ProtoMessage 

func (*PredictLog) ProtoMessage()

func (*PredictLog) Reset 

func (m *PredictLog) Reset()

func (*PredictLog) Size 

func (m *PredictLog) Size() (n int)

func (*PredictLog) String 

func (m *PredictLog) String() string

func (*PredictLog) Unmarshal 

func (m *PredictLog) Unmarshal(dAtA []byte) error

func (*PredictLog) XXX_DiscardUnknown 

func (m *PredictLog) XXX_DiscardUnknown()

func (*PredictLog) XXX_Marshal 

func (m *PredictLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PredictLog) XXX_Merge 

func (m *PredictLog) XXX_Merge(src proto.Message)

func (*PredictLog) XXX_Size 

func (m *PredictLog) XXX_Size() int

func (*PredictLog) XXX_Unmarshal 

func (m *PredictLog) XXX_Unmarshal(b []byte) error

type PredictRequest 

type PredictRequest struct {
	// Model Specification. If version is not specified, will use the latest
	// (numerical) version.
	ModelSpec *ModelSpec `protobuf:"bytes,1,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	// Input tensors.
	// Names of input tensor are alias names. The mapping from aliases to real
	// input tensor names is stored in the SavedModel export as a prediction
	// SignatureDef under the 'inputs' field.
	Inputs map[string]*framework.TensorProto `` /* 153-byte string literal not displayed */
	// Output filter.
	// Names specified are alias names. The mapping from aliases to real output
	// tensor names is stored in the SavedModel export as a prediction
	// SignatureDef under the 'outputs' field.
	// Only tensors specified here will be run/fetched and returned, with the
	// exception that when none is specified, all tensors specified in the
	// named signature will be run/fetched and returned.
	OutputFilter []string `protobuf:"bytes,3,rep,name=output_filter,json=outputFilter,proto3" json:"output_filter,omitempty"`
}

PredictRequest specifies which TensorFlow model to run, as well as how inputs are mapped to tensors and how outputs are filtered before returning to user.

func (*PredictRequest) Descriptor 

func (*PredictRequest) Descriptor() ([]byte, []int)

func (*PredictRequest) GetInputs 

func (m *PredictRequest) GetInputs() map[string]*framework.TensorProto

func (*PredictRequest) GetModelSpec 

func (m *PredictRequest) GetModelSpec() *ModelSpec

func (*PredictRequest) GetOutputFilter 

func (m *PredictRequest) GetOutputFilter() []string

func (*PredictRequest) Marshal 

func (m *PredictRequest) Marshal() (dAtA []byte, err error)

func (*PredictRequest) MarshalTo 

func (m *PredictRequest) MarshalTo(dAtA []byte) (int, error)

func (*PredictRequest) MarshalToSizedBuffer 

func (m *PredictRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PredictRequest) ProtoMessage 

func (*PredictRequest) ProtoMessage()

func (*PredictRequest) Reset 

func (m *PredictRequest) Reset()

func (*PredictRequest) Size 

func (m *PredictRequest) Size() (n int)

func (*PredictRequest) String 

func (m *PredictRequest) String() string

func (*PredictRequest) Unmarshal 

func (m *PredictRequest) Unmarshal(dAtA []byte) error

func (*PredictRequest) XXX_DiscardUnknown 

func (m *PredictRequest) XXX_DiscardUnknown()

func (*PredictRequest) XXX_Marshal 

func (m *PredictRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PredictRequest) XXX_Merge 

func (m *PredictRequest) XXX_Merge(src proto.Message)

func (*PredictRequest) XXX_Size 

func (m *PredictRequest) XXX_Size() int

func (*PredictRequest) XXX_Unmarshal 

func (m *PredictRequest) XXX_Unmarshal(b []byte) error

type PredictResponse 

type PredictResponse struct {
	// Effective Model Specification used to process PredictRequest.
	ModelSpec *ModelSpec `protobuf:"bytes,2,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	// Output tensors.
	Outputs map[string]*framework.TensorProto `` /* 155-byte string literal not displayed */
}

Response for PredictRequest on successful run.

func (*PredictResponse) Descriptor 

func (*PredictResponse) Descriptor() ([]byte, []int)

func (*PredictResponse) GetModelSpec 

func (m *PredictResponse) GetModelSpec() *ModelSpec

func (*PredictResponse) GetOutputs 

func (m *PredictResponse) GetOutputs() map[string]*framework.TensorProto

func (*PredictResponse) Marshal 

func (m *PredictResponse) Marshal() (dAtA []byte, err error)

func (*PredictResponse) MarshalTo 

func (m *PredictResponse) MarshalTo(dAtA []byte) (int, error)

func (*PredictResponse) MarshalToSizedBuffer 

func (m *PredictResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PredictResponse) ProtoMessage 

func (*PredictResponse) ProtoMessage()

func (*PredictResponse) Reset 

func (m *PredictResponse) Reset()

func (*PredictResponse) Size 

func (m *PredictResponse) Size() (n int)

func (*PredictResponse) String 

func (m *PredictResponse) String() string

func (*PredictResponse) Unmarshal 

func (m *PredictResponse) Unmarshal(dAtA []byte) error

func (*PredictResponse) XXX_DiscardUnknown 

func (m *PredictResponse) XXX_DiscardUnknown()

func (*PredictResponse) XXX_Marshal 

func (m *PredictResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PredictResponse) XXX_Merge 

func (m *PredictResponse) XXX_Merge(src proto.Message)

func (*PredictResponse) XXX_Size 

func (m *PredictResponse) XXX_Size() int

func (*PredictResponse) XXX_Unmarshal 

func (m *PredictResponse) XXX_Unmarshal(b []byte) error

type PredictionLog 

type PredictionLog struct {
	LogMetadata *LogMetadata `protobuf:"bytes,1,opt,name=log_metadata,json=logMetadata,proto3" json:"log_metadata,omitempty"`
	// Types that are valid to be assigned to LogType:
	//	*PredictionLog_ClassifyLog
	//	*PredictionLog_RegressLog
	//	*PredictionLog_PredictLog
	//	*PredictionLog_MultiInferenceLog
	//	*PredictionLog_SessionRunLog
	LogType isPredictionLog_LogType `protobuf_oneof:"log_type"`
}

Logged model inference request.

func (*PredictionLog) Descriptor 

func (*PredictionLog) Descriptor() ([]byte, []int)

func (*PredictionLog) GetClassifyLog 

func (m *PredictionLog) GetClassifyLog() *ClassifyLog

func (*PredictionLog) GetLogMetadata 

func (m *PredictionLog) GetLogMetadata() *LogMetadata

func (*PredictionLog) GetLogType 

func (m *PredictionLog) GetLogType() isPredictionLog_LogType

func (*PredictionLog) GetMultiInferenceLog 

func (m *PredictionLog) GetMultiInferenceLog() *MultiInferenceLog

func (*PredictionLog) GetPredictLog 

func (m *PredictionLog) GetPredictLog() *PredictLog

func (*PredictionLog) GetRegressLog 

func (m *PredictionLog) GetRegressLog() *RegressLog

func (*PredictionLog) GetSessionRunLog 

func (m *PredictionLog) GetSessionRunLog() *SessionRunLog

func (*PredictionLog) Marshal 

func (m *PredictionLog) Marshal() (dAtA []byte, err error)

func (*PredictionLog) MarshalTo 

func (m *PredictionLog) MarshalTo(dAtA []byte) (int, error)

func (*PredictionLog) MarshalToSizedBuffer 

func (m *PredictionLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PredictionLog) ProtoMessage 

func (*PredictionLog) ProtoMessage()

func (*PredictionLog) Reset 

func (m *PredictionLog) Reset()

func (*PredictionLog) Size 

func (m *PredictionLog) Size() (n int)

func (*PredictionLog) String 

func (m *PredictionLog) String() string

func (*PredictionLog) Unmarshal 

func (m *PredictionLog) Unmarshal(dAtA []byte) error

func (*PredictionLog) XXX_DiscardUnknown 

func (m *PredictionLog) XXX_DiscardUnknown()

func (*PredictionLog) XXX_Marshal 

func (m *PredictionLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PredictionLog) XXX_Merge 

func (m *PredictionLog) XXX_Merge(src proto.Message)

func (*PredictionLog) XXX_OneofWrappers 

func (*PredictionLog) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PredictionLog) XXX_Size 

func (m *PredictionLog) XXX_Size() int

func (*PredictionLog) XXX_Unmarshal 

func (m *PredictionLog) XXX_Unmarshal(b []byte) error

type PredictionLog_ClassifyLog 

type PredictionLog_ClassifyLog struct {
	ClassifyLog *ClassifyLog `protobuf:"bytes,2,opt,name=classify_log,json=classifyLog,proto3,oneof" json:"classify_log,omitempty"`
}

func (*PredictionLog_ClassifyLog) MarshalTo 

func (m *PredictionLog_ClassifyLog) MarshalTo(dAtA []byte) (int, error)

func (*PredictionLog_ClassifyLog) MarshalToSizedBuffer 

func (m *PredictionLog_ClassifyLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PredictionLog_ClassifyLog) Size 

func (m *PredictionLog_ClassifyLog) Size() (n int)

type PredictionLog_MultiInferenceLog 

type PredictionLog_MultiInferenceLog struct {
	MultiInferenceLog *MultiInferenceLog `protobuf:"bytes,4,opt,name=multi_inference_log,json=multiInferenceLog,proto3,oneof" json:"multi_inference_log,omitempty"`
}

func (*PredictionLog_MultiInferenceLog) MarshalTo 

func (m *PredictionLog_MultiInferenceLog) MarshalTo(dAtA []byte) (int, error)

func (*PredictionLog_MultiInferenceLog) MarshalToSizedBuffer 

func (m *PredictionLog_MultiInferenceLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PredictionLog_MultiInferenceLog) Size 

func (m *PredictionLog_MultiInferenceLog) Size() (n int)

type PredictionLog_PredictLog 

type PredictionLog_PredictLog struct {
	PredictLog *PredictLog `protobuf:"bytes,6,opt,name=predict_log,json=predictLog,proto3,oneof" json:"predict_log,omitempty"`
}

func (*PredictionLog_PredictLog) MarshalTo 

func (m *PredictionLog_PredictLog) MarshalTo(dAtA []byte) (int, error)

func (*PredictionLog_PredictLog) MarshalToSizedBuffer 

func (m *PredictionLog_PredictLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PredictionLog_PredictLog) Size 

func (m *PredictionLog_PredictLog) Size() (n int)

type PredictionLog_RegressLog 

type PredictionLog_RegressLog struct {
	RegressLog *RegressLog `protobuf:"bytes,3,opt,name=regress_log,json=regressLog,proto3,oneof" json:"regress_log,omitempty"`
}

func (*PredictionLog_RegressLog) MarshalTo 

func (m *PredictionLog_RegressLog) MarshalTo(dAtA []byte) (int, error)

func (*PredictionLog_RegressLog) MarshalToSizedBuffer 

func (m *PredictionLog_RegressLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PredictionLog_RegressLog) Size 

func (m *PredictionLog_RegressLog) Size() (n int)

type PredictionLog_SessionRunLog 

type PredictionLog_SessionRunLog struct {
	SessionRunLog *SessionRunLog `protobuf:"bytes,5,opt,name=session_run_log,json=sessionRunLog,proto3,oneof" json:"session_run_log,omitempty"`
}

func (*PredictionLog_SessionRunLog) MarshalTo 

func (m *PredictionLog_SessionRunLog) MarshalTo(dAtA []byte) (int, error)

func (*PredictionLog_SessionRunLog) MarshalToSizedBuffer 

func (m *PredictionLog_SessionRunLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PredictionLog_SessionRunLog) Size 

func (m *PredictionLog_SessionRunLog) Size() (n int)

type PredictionServiceClient 

type PredictionServiceClient interface {
	// Classify.
	Classify(ctx context.Context, in *ClassificationRequest, opts ...grpc.CallOption) (*ClassificationResponse, error)
	// Regress.
	Regress(ctx context.Context, in *RegressionRequest, opts ...grpc.CallOption) (*RegressionResponse, error)
	// Predict -- provides access to loaded TensorFlow model.
	Predict(ctx context.Context, in *PredictRequest, opts ...grpc.CallOption) (*PredictResponse, error)
	// MultiInference API for multi-headed models.
	MultiInference(ctx context.Context, in *MultiInferenceRequest, opts ...grpc.CallOption) (*MultiInferenceResponse, error)
	// GetModelMetadata - provides access to metadata for loaded models.
	GetModelMetadata(ctx context.Context, in *GetModelMetadataRequest, opts ...grpc.CallOption) (*GetModelMetadataResponse, error)
}

PredictionServiceClient is the client API for PredictionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPredictionServiceClient 

func NewPredictionServiceClient(cc *grpc.ClientConn) PredictionServiceClient

type PredictionServiceServer 

type PredictionServiceServer interface {
	// Classify.
	Classify(context.Context, *ClassificationRequest) (*ClassificationResponse, error)
	// Regress.
	Regress(context.Context, *RegressionRequest) (*RegressionResponse, error)
	// Predict -- provides access to loaded TensorFlow model.
	Predict(context.Context, *PredictRequest) (*PredictResponse, error)
	// MultiInference API for multi-headed models.
	MultiInference(context.Context, *MultiInferenceRequest) (*MultiInferenceResponse, error)
	// GetModelMetadata - provides access to metadata for loaded models.
	GetModelMetadata(context.Context, *GetModelMetadataRequest) (*GetModelMetadataResponse, error)
}

PredictionServiceServer is the server API for PredictionService service.

type PrometheusConfig 

type PrometheusConfig struct {
	// Whether to expose Prometheus metrics.
	Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	// The endpoint to expose Prometheus metrics.
	// If not specified, PrometheusExporter::kPrometheusPath value is used.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
}

Configuration for Prometheus monitoring.

func (*PrometheusConfig) Descriptor 

func (*PrometheusConfig) Descriptor() ([]byte, []int)

func (*PrometheusConfig) GetEnable 

func (m *PrometheusConfig) GetEnable() bool

func (*PrometheusConfig) GetPath 

func (m *PrometheusConfig) GetPath() string

func (*PrometheusConfig) Marshal 

func (m *PrometheusConfig) Marshal() (dAtA []byte, err error)

func (*PrometheusConfig) MarshalTo 

func (m *PrometheusConfig) MarshalTo(dAtA []byte) (int, error)

func (*PrometheusConfig) MarshalToSizedBuffer 

func (m *PrometheusConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PrometheusConfig) ProtoMessage 

func (*PrometheusConfig) ProtoMessage()

func (*PrometheusConfig) Reset 

func (m *PrometheusConfig) Reset()

func (*PrometheusConfig) Size 

func (m *PrometheusConfig) Size() (n int)

func (*PrometheusConfig) String 

func (m *PrometheusConfig) String() string

func (*PrometheusConfig) Unmarshal 

func (m *PrometheusConfig) Unmarshal(dAtA []byte) error

func (*PrometheusConfig) XXX_DiscardUnknown 

func (m *PrometheusConfig) XXX_DiscardUnknown()

func (*PrometheusConfig) XXX_Marshal 

func (m *PrometheusConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrometheusConfig) XXX_Merge 

func (m *PrometheusConfig) XXX_Merge(src proto.Message)

func (*PrometheusConfig) XXX_Size 

func (m *PrometheusConfig) XXX_Size() int

func (*PrometheusConfig) XXX_Unmarshal 

func (m *PrometheusConfig) XXX_Unmarshal(b []byte) error

type RegressLog 

type RegressLog struct {
	Request  *RegressionRequest  `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Response *RegressionResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
}

func (*RegressLog) Descriptor 

func (*RegressLog) Descriptor() ([]byte, []int)

func (*RegressLog) GetRequest 

func (m *RegressLog) GetRequest() *RegressionRequest

func (*RegressLog) GetResponse 

func (m *RegressLog) GetResponse() *RegressionResponse

func (*RegressLog) Marshal 

func (m *RegressLog) Marshal() (dAtA []byte, err error)

func (*RegressLog) MarshalTo 

func (m *RegressLog) MarshalTo(dAtA []byte) (int, error)

func (*RegressLog) MarshalToSizedBuffer 

func (m *RegressLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegressLog) ProtoMessage 

func (*RegressLog) ProtoMessage()

func (*RegressLog) Reset 

func (m *RegressLog) Reset()

func (*RegressLog) Size 

func (m *RegressLog) Size() (n int)

func (*RegressLog) String 

func (m *RegressLog) String() string

func (*RegressLog) Unmarshal 

func (m *RegressLog) Unmarshal(dAtA []byte) error

func (*RegressLog) XXX_DiscardUnknown 

func (m *RegressLog) XXX_DiscardUnknown()

func (*RegressLog) XXX_Marshal 

func (m *RegressLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegressLog) XXX_Merge 

func (m *RegressLog) XXX_Merge(src proto.Message)

func (*RegressLog) XXX_Size 

func (m *RegressLog) XXX_Size() int

func (*RegressLog) XXX_Unmarshal 

func (m *RegressLog) XXX_Unmarshal(b []byte) error

type Regression 

type Regression struct {
	Value float32 `protobuf:"fixed32,1,opt,name=value,proto3" json:"value,omitempty"`
}

Regression result for a single item (tensorflow.Example).

func (*Regression) Descriptor 

func (*Regression) Descriptor() ([]byte, []int)

func (*Regression) GetValue 

func (m *Regression) GetValue() float32

func (*Regression) Marshal 

func (m *Regression) Marshal() (dAtA []byte, err error)

func (*Regression) MarshalTo 

func (m *Regression) MarshalTo(dAtA []byte) (int, error)

func (*Regression) MarshalToSizedBuffer 

func (m *Regression) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Regression) ProtoMessage 

func (*Regression) ProtoMessage()

func (*Regression) Reset 

func (m *Regression) Reset()

func (*Regression) Size 

func (m *Regression) Size() (n int)

func (*Regression) String 

func (m *Regression) String() string

func (*Regression) Unmarshal 

func (m *Regression) Unmarshal(dAtA []byte) error

func (*Regression) XXX_DiscardUnknown 

func (m *Regression) XXX_DiscardUnknown()

func (*Regression) XXX_Marshal 

func (m *Regression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Regression) XXX_Merge 

func (m *Regression) XXX_Merge(src proto.Message)

func (*Regression) XXX_Size 

func (m *Regression) XXX_Size() int

func (*Regression) XXX_Unmarshal 

func (m *Regression) XXX_Unmarshal(b []byte) error

type RegressionRequest 

type RegressionRequest struct {
	// Model Specification. If version is not specified, will use the latest
	// (numerical) version.
	ModelSpec *ModelSpec `protobuf:"bytes,1,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	// Input data.
	Input *Input `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
}

func (*RegressionRequest) Descriptor 

func (*RegressionRequest) Descriptor() ([]byte, []int)

func (*RegressionRequest) GetInput 

func (m *RegressionRequest) GetInput() *Input

func (*RegressionRequest) GetModelSpec 

func (m *RegressionRequest) GetModelSpec() *ModelSpec

func (*RegressionRequest) Marshal 

func (m *RegressionRequest) Marshal() (dAtA []byte, err error)

func (*RegressionRequest) MarshalTo 

func (m *RegressionRequest) MarshalTo(dAtA []byte) (int, error)

func (*RegressionRequest) MarshalToSizedBuffer 

func (m *RegressionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegressionRequest) ProtoMessage 

func (*RegressionRequest) ProtoMessage()

func (*RegressionRequest) Reset 

func (m *RegressionRequest) Reset()

func (*RegressionRequest) Size 

func (m *RegressionRequest) Size() (n int)

func (*RegressionRequest) String 

func (m *RegressionRequest) String() string

func (*RegressionRequest) Unmarshal 

func (m *RegressionRequest) Unmarshal(dAtA []byte) error

func (*RegressionRequest) XXX_DiscardUnknown 

func (m *RegressionRequest) XXX_DiscardUnknown()

func (*RegressionRequest) XXX_Marshal 

func (m *RegressionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegressionRequest) XXX_Merge 

func (m *RegressionRequest) XXX_Merge(src proto.Message)

func (*RegressionRequest) XXX_Size 

func (m *RegressionRequest) XXX_Size() int

func (*RegressionRequest) XXX_Unmarshal 

func (m *RegressionRequest) XXX_Unmarshal(b []byte) error

type RegressionResponse 

type RegressionResponse struct {
	// Effective Model Specification used for regression.
	ModelSpec *ModelSpec        `protobuf:"bytes,2,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	Result    *RegressionResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*RegressionResponse) Descriptor 

func (*RegressionResponse) Descriptor() ([]byte, []int)

func (*RegressionResponse) GetModelSpec 

func (m *RegressionResponse) GetModelSpec() *ModelSpec

func (*RegressionResponse) GetResult 

func (m *RegressionResponse) GetResult() *RegressionResult

func (*RegressionResponse) Marshal 

func (m *RegressionResponse) Marshal() (dAtA []byte, err error)

func (*RegressionResponse) MarshalTo 

func (m *RegressionResponse) MarshalTo(dAtA []byte) (int, error)

func (*RegressionResponse) MarshalToSizedBuffer 

func (m *RegressionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegressionResponse) ProtoMessage 

func (*RegressionResponse) ProtoMessage()

func (*RegressionResponse) Reset 

func (m *RegressionResponse) Reset()

func (*RegressionResponse) Size 

func (m *RegressionResponse) Size() (n int)

func (*RegressionResponse) String 

func (m *RegressionResponse) String() string

func (*RegressionResponse) Unmarshal 

func (m *RegressionResponse) Unmarshal(dAtA []byte) error

func (*RegressionResponse) XXX_DiscardUnknown 

func (m *RegressionResponse) XXX_DiscardUnknown()

func (*RegressionResponse) XXX_Marshal 

func (m *RegressionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegressionResponse) XXX_Merge 

func (m *RegressionResponse) XXX_Merge(src proto.Message)

func (*RegressionResponse) XXX_Size 

func (m *RegressionResponse) XXX_Size() int

func (*RegressionResponse) XXX_Unmarshal 

func (m *RegressionResponse) XXX_Unmarshal(b []byte) error

type RegressionResult 

type RegressionResult struct {
	Regressions []*Regression `protobuf:"bytes,1,rep,name=regressions,proto3" json:"regressions,omitempty"`
}

Contains one result per input example, in the same order as the input in RegressionRequest.

func (*RegressionResult) Descriptor 

func (*RegressionResult) Descriptor() ([]byte, []int)

func (*RegressionResult) GetRegressions 

func (m *RegressionResult) GetRegressions() []*Regression

func (*RegressionResult) Marshal 

func (m *RegressionResult) Marshal() (dAtA []byte, err error)

func (*RegressionResult) MarshalTo 

func (m *RegressionResult) MarshalTo(dAtA []byte) (int, error)

func (*RegressionResult) MarshalToSizedBuffer 

func (m *RegressionResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegressionResult) ProtoMessage 

func (*RegressionResult) ProtoMessage()

func (*RegressionResult) Reset 

func (m *RegressionResult) Reset()

func (*RegressionResult) Size 

func (m *RegressionResult) Size() (n int)

func (*RegressionResult) String 

func (m *RegressionResult) String() string

func (*RegressionResult) Unmarshal 

func (m *RegressionResult) Unmarshal(dAtA []byte) error

func (*RegressionResult) XXX_DiscardUnknown 

func (m *RegressionResult) XXX_DiscardUnknown()

func (*RegressionResult) XXX_Marshal 

func (m *RegressionResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegressionResult) XXX_Merge 

func (m *RegressionResult) XXX_Merge(src proto.Message)

func (*RegressionResult) XXX_Size 

func (m *RegressionResult) XXX_Size() int

func (*RegressionResult) XXX_Unmarshal 

func (m *RegressionResult) XXX_Unmarshal(b []byte) error

type ReloadConfigRequest 

type ReloadConfigRequest struct {
	Config *ModelServerConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
}

func (*ReloadConfigRequest) Descriptor 

func (*ReloadConfigRequest) Descriptor() ([]byte, []int)

func (*ReloadConfigRequest) GetConfig 

func (m *ReloadConfigRequest) GetConfig() *ModelServerConfig

func (*ReloadConfigRequest) Marshal 

func (m *ReloadConfigRequest) Marshal() (dAtA []byte, err error)

func (*ReloadConfigRequest) MarshalTo 

func (m *ReloadConfigRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReloadConfigRequest) MarshalToSizedBuffer 

func (m *ReloadConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReloadConfigRequest) ProtoMessage 

func (*ReloadConfigRequest) ProtoMessage()

func (*ReloadConfigRequest) Reset 

func (m *ReloadConfigRequest) Reset()

func (*ReloadConfigRequest) Size 

func (m *ReloadConfigRequest) Size() (n int)

func (*ReloadConfigRequest) String 

func (m *ReloadConfigRequest) String() string

func (*ReloadConfigRequest) Unmarshal 

func (m *ReloadConfigRequest) Unmarshal(dAtA []byte) error

func (*ReloadConfigRequest) XXX_DiscardUnknown 

func (m *ReloadConfigRequest) XXX_DiscardUnknown()

func (*ReloadConfigRequest) XXX_Marshal 

func (m *ReloadConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReloadConfigRequest) XXX_Merge 

func (m *ReloadConfigRequest) XXX_Merge(src proto.Message)

func (*ReloadConfigRequest) XXX_Size 

func (m *ReloadConfigRequest) XXX_Size() int

func (*ReloadConfigRequest) XXX_Unmarshal 

func (m *ReloadConfigRequest) XXX_Unmarshal(b []byte) error

type ReloadConfigResponse 

type ReloadConfigResponse struct {
	Status *StatusProto `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}

func (*ReloadConfigResponse) Descriptor 

func (*ReloadConfigResponse) Descriptor() ([]byte, []int)

func (*ReloadConfigResponse) GetStatus 

func (m *ReloadConfigResponse) GetStatus() *StatusProto

func (*ReloadConfigResponse) Marshal 

func (m *ReloadConfigResponse) Marshal() (dAtA []byte, err error)

func (*ReloadConfigResponse) MarshalTo 

func (m *ReloadConfigResponse) MarshalTo(dAtA []byte) (int, error)

func (*ReloadConfigResponse) MarshalToSizedBuffer 

func (m *ReloadConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReloadConfigResponse) ProtoMessage 

func (*ReloadConfigResponse) ProtoMessage()

func (*ReloadConfigResponse) Reset 

func (m *ReloadConfigResponse) Reset()

func (*ReloadConfigResponse) Size 

func (m *ReloadConfigResponse) Size() (n int)

func (*ReloadConfigResponse) String 

func (m *ReloadConfigResponse) String() string

func (*ReloadConfigResponse) Unmarshal 

func (m *ReloadConfigResponse) Unmarshal(dAtA []byte) error

func (*ReloadConfigResponse) XXX_DiscardUnknown 

func (m *ReloadConfigResponse) XXX_DiscardUnknown()

func (*ReloadConfigResponse) XXX_Marshal 

func (m *ReloadConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReloadConfigResponse) XXX_Merge 

func (m *ReloadConfigResponse) XXX_Merge(src proto.Message)

func (*ReloadConfigResponse) XXX_Size 

func (m *ReloadConfigResponse) XXX_Size() int

func (*ReloadConfigResponse) XXX_Unmarshal 

func (m *ReloadConfigResponse) XXX_Unmarshal(b []byte) error

type SSLConfig 

type SSLConfig struct {
	// private server key for SSL
	ServerKey string `protobuf:"bytes,1,opt,name=server_key,json=serverKey,proto3" json:"server_key,omitempty"`
	// public server certificate
	ServerCert string `protobuf:"bytes,2,opt,name=server_cert,json=serverCert,proto3" json:"server_cert,omitempty"`
	//  custom certificate authority
	CustomCa string `protobuf:"bytes,3,opt,name=custom_ca,json=customCa,proto3" json:"custom_ca,omitempty"`
	// valid client certificate required ?
	ClientVerify bool `protobuf:"varint,4,opt,name=client_verify,json=clientVerify,proto3" json:"client_verify,omitempty"`
}

Configuration for a secure gRPC channel

func (*SSLConfig) Descriptor 

func (*SSLConfig) Descriptor() ([]byte, []int)

func (*SSLConfig) GetClientVerify 

func (m *SSLConfig) GetClientVerify() bool

func (*SSLConfig) GetCustomCa 

func (m *SSLConfig) GetCustomCa() string

func (*SSLConfig) GetServerCert 

func (m *SSLConfig) GetServerCert() string

func (*SSLConfig) GetServerKey 

func (m *SSLConfig) GetServerKey() string

func (*SSLConfig) Marshal 

func (m *SSLConfig) Marshal() (dAtA []byte, err error)

func (*SSLConfig) MarshalTo 

func (m *SSLConfig) MarshalTo(dAtA []byte) (int, error)

func (*SSLConfig) MarshalToSizedBuffer 

func (m *SSLConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SSLConfig) ProtoMessage 

func (*SSLConfig) ProtoMessage()

func (*SSLConfig) Reset 

func (m *SSLConfig) Reset()

func (*SSLConfig) Size 

func (m *SSLConfig) Size() (n int)

func (*SSLConfig) String 

func (m *SSLConfig) String() string

func (*SSLConfig) Unmarshal 

func (m *SSLConfig) Unmarshal(dAtA []byte) error

func (*SSLConfig) XXX_DiscardUnknown 

func (m *SSLConfig) XXX_DiscardUnknown()

func (*SSLConfig) XXX_Marshal 

func (m *SSLConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SSLConfig) XXX_Merge 

func (m *SSLConfig) XXX_Merge(src proto.Message)

func (*SSLConfig) XXX_Size 

func (m *SSLConfig) XXX_Size() int

func (*SSLConfig) XXX_Unmarshal 

func (m *SSLConfig) XXX_Unmarshal(b []byte) error

type SamplingConfig 

type SamplingConfig struct {
	// Requests will be logged uniformly at random with this probability. Valid
	// range: [0, 1.0].
	SamplingRate float64 `protobuf:"fixed64,1,opt,name=sampling_rate,json=samplingRate,proto3" json:"sampling_rate,omitempty"`
}

func (*SamplingConfig) Descriptor 

func (*SamplingConfig) Descriptor() ([]byte, []int)

func (*SamplingConfig) GetSamplingRate 

func (m *SamplingConfig) GetSamplingRate() float64

func (*SamplingConfig) Marshal 

func (m *SamplingConfig) Marshal() (dAtA []byte, err error)

func (*SamplingConfig) MarshalTo 

func (m *SamplingConfig) MarshalTo(dAtA []byte) (int, error)

func (*SamplingConfig) MarshalToSizedBuffer 

func (m *SamplingConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SamplingConfig) ProtoMessage 

func (*SamplingConfig) ProtoMessage()

func (*SamplingConfig) Reset 

func (m *SamplingConfig) Reset()

func (*SamplingConfig) Size 

func (m *SamplingConfig) Size() (n int)

func (*SamplingConfig) String 

func (m *SamplingConfig) String() string

func (*SamplingConfig) Unmarshal 

func (m *SamplingConfig) Unmarshal(dAtA []byte) error

func (*SamplingConfig) XXX_DiscardUnknown 

func (m *SamplingConfig) XXX_DiscardUnknown()

func (*SamplingConfig) XXX_Marshal 

func (m *SamplingConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SamplingConfig) XXX_Merge 

func (m *SamplingConfig) XXX_Merge(src proto.Message)

func (*SamplingConfig) XXX_Size 

func (m *SamplingConfig) XXX_Size() int

func (*SamplingConfig) XXX_Unmarshal 

func (m *SamplingConfig) XXX_Unmarshal(b []byte) error

type SessionRunLog 

type SessionRunLog struct {
	Request  *SessionRunRequest  `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Response *SessionRunResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
}

func (*SessionRunLog) Descriptor 

func (*SessionRunLog) Descriptor() ([]byte, []int)

func (*SessionRunLog) GetRequest 

func (m *SessionRunLog) GetRequest() *SessionRunRequest

func (*SessionRunLog) GetResponse 

func (m *SessionRunLog) GetResponse() *SessionRunResponse

func (*SessionRunLog) Marshal 

func (m *SessionRunLog) Marshal() (dAtA []byte, err error)

func (*SessionRunLog) MarshalTo 

func (m *SessionRunLog) MarshalTo(dAtA []byte) (int, error)

func (*SessionRunLog) MarshalToSizedBuffer 

func (m *SessionRunLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionRunLog) ProtoMessage 

func (*SessionRunLog) ProtoMessage()

func (*SessionRunLog) Reset 

func (m *SessionRunLog) Reset()

func (*SessionRunLog) Size 

func (m *SessionRunLog) Size() (n int)

func (*SessionRunLog) String 

func (m *SessionRunLog) String() string

func (*SessionRunLog) Unmarshal 

func (m *SessionRunLog) Unmarshal(dAtA []byte) error

func (*SessionRunLog) XXX_DiscardUnknown 

func (m *SessionRunLog) XXX_DiscardUnknown()

func (*SessionRunLog) XXX_Marshal 

func (m *SessionRunLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionRunLog) XXX_Merge 

func (m *SessionRunLog) XXX_Merge(src proto.Message)

func (*SessionRunLog) XXX_Size 

func (m *SessionRunLog) XXX_Size() int

func (*SessionRunLog) XXX_Unmarshal 

func (m *SessionRunLog) XXX_Unmarshal(b []byte) error

type SessionRunRequest 

type SessionRunRequest struct {
	// Model Specification. If version is not specified, will use the latest
	// (numerical) version.
	ModelSpec *ModelSpec `protobuf:"bytes,1,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	// Tensors to be fed in the step. Each feed is a named tensor.
	Feed []*protobuf.NamedTensorProto `protobuf:"bytes,2,rep,name=feed,proto3" json:"feed,omitempty"`
	// Fetches. A list of tensor names. The caller expects a tensor to
	// be returned for each fetch[i] (see RunResponse.tensor). The
	// order of specified fetches does not change the execution order.
	Fetch []string `protobuf:"bytes,3,rep,name=fetch,proto3" json:"fetch,omitempty"`
	// Target Nodes. A list of node names. The named nodes will be run
	// to but their outputs will not be fetched.
	Target []string `protobuf:"bytes,4,rep,name=target,proto3" json:"target,omitempty"`
	// Options for the run call. **Currently ignored.**
	Options *protobuf.RunOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
}

func (*SessionRunRequest) Descriptor 

func (*SessionRunRequest) Descriptor() ([]byte, []int)

func (*SessionRunRequest) GetFeed 

func (m *SessionRunRequest) GetFeed() []*protobuf.NamedTensorProto

func (*SessionRunRequest) GetFetch 

func (m *SessionRunRequest) GetFetch() []string

func (*SessionRunRequest) GetModelSpec 

func (m *SessionRunRequest) GetModelSpec() *ModelSpec

func (*SessionRunRequest) GetOptions 

func (m *SessionRunRequest) GetOptions() *protobuf.RunOptions

func (*SessionRunRequest) GetTarget 

func (m *SessionRunRequest) GetTarget() []string

func (*SessionRunRequest) Marshal 

func (m *SessionRunRequest) Marshal() (dAtA []byte, err error)

func (*SessionRunRequest) MarshalTo 

func (m *SessionRunRequest) MarshalTo(dAtA []byte) (int, error)

func (*SessionRunRequest) MarshalToSizedBuffer 

func (m *SessionRunRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionRunRequest) ProtoMessage 

func (*SessionRunRequest) ProtoMessage()

func (*SessionRunRequest) Reset 

func (m *SessionRunRequest) Reset()

func (*SessionRunRequest) Size 

func (m *SessionRunRequest) Size() (n int)

func (*SessionRunRequest) String 

func (m *SessionRunRequest) String() string

func (*SessionRunRequest) Unmarshal 

func (m *SessionRunRequest) Unmarshal(dAtA []byte) error

func (*SessionRunRequest) XXX_DiscardUnknown 

func (m *SessionRunRequest) XXX_DiscardUnknown()

func (*SessionRunRequest) XXX_Marshal 

func (m *SessionRunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionRunRequest) XXX_Merge 

func (m *SessionRunRequest) XXX_Merge(src proto.Message)

func (*SessionRunRequest) XXX_Size 

func (m *SessionRunRequest) XXX_Size() int

func (*SessionRunRequest) XXX_Unmarshal 

func (m *SessionRunRequest) XXX_Unmarshal(b []byte) error

type SessionRunResponse 

type SessionRunResponse struct {
	// Effective Model Specification used for session run.
	ModelSpec *ModelSpec `protobuf:"bytes,3,opt,name=model_spec,json=modelSpec,proto3" json:"model_spec,omitempty"`
	// NOTE: The order of the returned tensors may or may not match
	// the fetch order specified in RunRequest.
	Tensor []*protobuf.NamedTensorProto `protobuf:"bytes,1,rep,name=tensor,proto3" json:"tensor,omitempty"`
	// Returned metadata if requested in the options.
	Metadata *protobuf.RunMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
}

func (*SessionRunResponse) Descriptor 

func (*SessionRunResponse) Descriptor() ([]byte, []int)

func (*SessionRunResponse) GetMetadata 

func (m *SessionRunResponse) GetMetadata() *protobuf.RunMetadata

func (*SessionRunResponse) GetModelSpec 

func (m *SessionRunResponse) GetModelSpec() *ModelSpec

func (*SessionRunResponse) GetTensor 

func (m *SessionRunResponse) GetTensor() []*protobuf.NamedTensorProto

func (*SessionRunResponse) Marshal 

func (m *SessionRunResponse) Marshal() (dAtA []byte, err error)

func (*SessionRunResponse) MarshalTo 

func (m *SessionRunResponse) MarshalTo(dAtA []byte) (int, error)

func (*SessionRunResponse) MarshalToSizedBuffer 

func (m *SessionRunResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionRunResponse) ProtoMessage 

func (*SessionRunResponse) ProtoMessage()

func (*SessionRunResponse) Reset 

func (m *SessionRunResponse) Reset()

func (*SessionRunResponse) Size 

func (m *SessionRunResponse) Size() (n int)

func (*SessionRunResponse) String 

func (m *SessionRunResponse) String() string

func (*SessionRunResponse) Unmarshal 

func (m *SessionRunResponse) Unmarshal(dAtA []byte) error

func (*SessionRunResponse) XXX_DiscardUnknown 

func (m *SessionRunResponse) XXX_DiscardUnknown()

func (*SessionRunResponse) XXX_Marshal 

func (m *SessionRunResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionRunResponse) XXX_Merge 

func (m *SessionRunResponse) XXX_Merge(src proto.Message)

func (*SessionRunResponse) XXX_Size 

func (m *SessionRunResponse) XXX_Size() int

func (*SessionRunResponse) XXX_Unmarshal 

func (m *SessionRunResponse) XXX_Unmarshal(b []byte) error

type SessionServiceClient 

type SessionServiceClient interface {
	// Runs inference of a given model.
	SessionRun(ctx context.Context, in *SessionRunRequest, opts ...grpc.CallOption) (*SessionRunResponse, error)
}

SessionServiceClient is the client API for SessionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSessionServiceClient 

func NewSessionServiceClient(cc *grpc.ClientConn) SessionServiceClient

type SessionServiceServer 

type SessionServiceServer interface {
	// Runs inference of a given model.
	SessionRun(context.Context, *SessionRunRequest) (*SessionRunResponse, error)
}

SessionServiceServer is the server API for SessionService service.

type SignatureDefMap 

type SignatureDefMap struct {
	SignatureDef map[string]*protobuf.SignatureDef `` /* 185-byte string literal not displayed */
}

Message returned for "signature_def" field.

func (*SignatureDefMap) Descriptor 

func (*SignatureDefMap) Descriptor() ([]byte, []int)

func (*SignatureDefMap) GetSignatureDef 

func (m *SignatureDefMap) GetSignatureDef() map[string]*protobuf.SignatureDef

func (*SignatureDefMap) Marshal 

func (m *SignatureDefMap) Marshal() (dAtA []byte, err error)

func (*SignatureDefMap) MarshalTo 

func (m *SignatureDefMap) MarshalTo(dAtA []byte) (int, error)

func (*SignatureDefMap) MarshalToSizedBuffer 

func (m *SignatureDefMap) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SignatureDefMap) ProtoMessage 

func (*SignatureDefMap) ProtoMessage()

func (*SignatureDefMap) Reset 

func (m *SignatureDefMap) Reset()

func (*SignatureDefMap) Size 

func (m *SignatureDefMap) Size() (n int)

func (*SignatureDefMap) String 

func (m *SignatureDefMap) String() string

func (*SignatureDefMap) Unmarshal 

func (m *SignatureDefMap) Unmarshal(dAtA []byte) error

func (*SignatureDefMap) XXX_DiscardUnknown 

func (m *SignatureDefMap) XXX_DiscardUnknown()

func (*SignatureDefMap) XXX_Marshal 

func (m *SignatureDefMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignatureDefMap) XXX_Merge 

func (m *SignatureDefMap) XXX_Merge(src proto.Message)

func (*SignatureDefMap) XXX_Size 

func (m *SignatureDefMap) XXX_Size() int

func (*SignatureDefMap) XXX_Unmarshal 

func (m *SignatureDefMap) XXX_Unmarshal(b []byte) error

type StaticStoragePathSourceConfig 

type StaticStoragePathSourceConfig struct {
	// The single servable name, version number and path to supply statically.
	ServableName string `protobuf:"bytes,1,opt,name=servable_name,json=servableName,proto3" json:"servable_name,omitempty"`
	VersionNum   int64  `protobuf:"varint,2,opt,name=version_num,json=versionNum,proto3" json:"version_num,omitempty"`
	VersionPath  string `protobuf:"bytes,3,opt,name=version_path,json=versionPath,proto3" json:"version_path,omitempty"`
}

Config proto for StaticStoragePathSource.

func (*StaticStoragePathSourceConfig) Descriptor 

func (*StaticStoragePathSourceConfig) Descriptor() ([]byte, []int)

func (*StaticStoragePathSourceConfig) GetServableName 

func (m *StaticStoragePathSourceConfig) GetServableName() string

func (*StaticStoragePathSourceConfig) GetVersionNum 

func (m *StaticStoragePathSourceConfig) GetVersionNum() int64

func (*StaticStoragePathSourceConfig) GetVersionPath 

func (m *StaticStoragePathSourceConfig) GetVersionPath() string

func (*StaticStoragePathSourceConfig) Marshal 

func (m *StaticStoragePathSourceConfig) Marshal() (dAtA []byte, err error)

func (*StaticStoragePathSourceConfig) MarshalTo 

func (m *StaticStoragePathSourceConfig) MarshalTo(dAtA []byte) (int, error)

func (*StaticStoragePathSourceConfig) MarshalToSizedBuffer 

func (m *StaticStoragePathSourceConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StaticStoragePathSourceConfig) ProtoMessage 

func (*StaticStoragePathSourceConfig) ProtoMessage()

func (*StaticStoragePathSourceConfig) Reset 

func (m *StaticStoragePathSourceConfig) Reset()

func (*StaticStoragePathSourceConfig) Size 

func (m *StaticStoragePathSourceConfig) Size() (n int)

func (*StaticStoragePathSourceConfig) String 

func (m *StaticStoragePathSourceConfig) String() string

func (*StaticStoragePathSourceConfig) Unmarshal 

func (m *StaticStoragePathSourceConfig) Unmarshal(dAtA []byte) error

func (*StaticStoragePathSourceConfig) XXX_DiscardUnknown 

func (m *StaticStoragePathSourceConfig) XXX_DiscardUnknown()

func (*StaticStoragePathSourceConfig) XXX_Marshal 

func (m *StaticStoragePathSourceConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StaticStoragePathSourceConfig) XXX_Merge 

func (m *StaticStoragePathSourceConfig) XXX_Merge(src proto.Message)

func (*StaticStoragePathSourceConfig) XXX_Size 

func (m *StaticStoragePathSourceConfig) XXX_Size() int

func (*StaticStoragePathSourceConfig) XXX_Unmarshal 

func (m *StaticStoragePathSourceConfig) XXX_Unmarshal(b []byte) error

type StatusProto 

type StatusProto struct {
	// Error code.
	ErrorCode protobuf.Code `protobuf:"varint,1,opt,name=error_code,proto3,enum=tensorflow.error.Code" json:"error_code,omitempty"`
	// Error message. Will only be set if an error was encountered.
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,proto3" json:"error_message,omitempty"`
}

Status that corresponds to Status in third_party/tensorflow/core/lib/core/status.h.

func (*StatusProto) Descriptor 

func (*StatusProto) Descriptor() ([]byte, []int)

func (*StatusProto) GetErrorCode 

func (m *StatusProto) GetErrorCode() protobuf.Code

func (*StatusProto) GetErrorMessage 

func (m *StatusProto) GetErrorMessage() string

func (*StatusProto) Marshal 

func (m *StatusProto) Marshal() (dAtA []byte, err error)

func (*StatusProto) MarshalTo 

func (m *StatusProto) MarshalTo(dAtA []byte) (int, error)

func (*StatusProto) MarshalToSizedBuffer 

func (m *StatusProto) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatusProto) ProtoMessage 

func (*StatusProto) ProtoMessage()

func (*StatusProto) Reset 

func (m *StatusProto) Reset()

func (*StatusProto) Size 

func (m *StatusProto) Size() (n int)

func (*StatusProto) String 

func (m *StatusProto) String() string

func (*StatusProto) Unmarshal 

func (m *StatusProto) Unmarshal(dAtA []byte) error

func (*StatusProto) XXX_DiscardUnknown 

func (m *StatusProto) XXX_DiscardUnknown()

func (*StatusProto) XXX_Marshal 

func (m *StatusProto) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatusProto) XXX_Merge 

func (m *StatusProto) XXX_Merge(src proto.Message)

func (*StatusProto) XXX_Size 

func (m *StatusProto) XXX_Size() int

func (*StatusProto) XXX_Unmarshal 

func (m *StatusProto) XXX_Unmarshal(b []byte) error

type UnimplementedModelServiceServer 

type UnimplementedModelServiceServer struct {
}

UnimplementedModelServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedModelServiceServer) GetModelStatus 

func (*UnimplementedModelServiceServer) GetModelStatus(ctx context.Context, req *GetModelStatusRequest) (*GetModelStatusResponse, error)

func (*UnimplementedModelServiceServer) HandleReloadConfigRequest 

func (*UnimplementedModelServiceServer) HandleReloadConfigRequest(ctx context.Context, req *ReloadConfigRequest) (*ReloadConfigResponse, error)

type UnimplementedPredictionServiceServer 

type UnimplementedPredictionServiceServer struct {
}

UnimplementedPredictionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPredictionServiceServer) Classify 

func (*UnimplementedPredictionServiceServer) Classify(ctx context.Context, req *ClassificationRequest) (*ClassificationResponse, error)

func (*UnimplementedPredictionServiceServer) GetModelMetadata 

func (*UnimplementedPredictionServiceServer) GetModelMetadata(ctx context.Context, req *GetModelMetadataRequest) (*GetModelMetadataResponse, error)

func (*UnimplementedPredictionServiceServer) MultiInference 

func (*UnimplementedPredictionServiceServer) MultiInference(ctx context.Context, req *MultiInferenceRequest) (*MultiInferenceResponse, error)

func (*UnimplementedPredictionServiceServer) Predict 

func (*UnimplementedPredictionServiceServer) Predict(ctx context.Context, req *PredictRequest) (*PredictResponse, error)

func (*UnimplementedPredictionServiceServer) Regress 

func (*UnimplementedPredictionServiceServer) Regress(ctx context.Context, req *RegressionRequest) (*RegressionResponse, error)

type UnimplementedSessionServiceServer 

type UnimplementedSessionServiceServer struct {
}

UnimplementedSessionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSessionServiceServer) SessionRun 

func (*UnimplementedSessionServiceServer) SessionRun(ctx context.Context, req *SessionRunRequest) (*SessionRunResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.