api

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Feb 17, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Metric_MetricType_name = map[int32]string{
	0: "COUNTER",
	1: "GAUGE",
	2: "TIMER",
}
View Source 
var Metric_MetricType_value = map[string]int32{
	"COUNTER": 0,
	"GAUGE":   1,
	"TIMER":   2,
}
View Source 
var Status_StatusFlag_name = map[int32]string{
	0: "SUCCESS",
	1: "FAILURE",
}
View Source 
var Status_StatusFlag_value = map[string]int32{
	"SUCCESS": 0,
	"FAILURE": 1,
}

Functions

func RegisterCombinerServer 

func RegisterCombinerServer(s *grpc.Server, srv CombinerServer)

func RegisterGenericServer 

func RegisterGenericServer(s *grpc.Server, srv GenericServer)

func RegisterModelServer 

func RegisterModelServer(s *grpc.Server, srv ModelServer)

func RegisterOutputTransformerServer 

func RegisterOutputTransformerServer(s *grpc.Server, srv OutputTransformerServer)

func RegisterRouterServer 

func RegisterRouterServer(s *grpc.Server, srv RouterServer)

func RegisterSeldonServer 

func RegisterSeldonServer(s *grpc.Server, srv SeldonServer)

func RegisterTransformerServer 

func RegisterTransformerServer(s *grpc.Server, srv TransformerServer)

Types

type CombinerClient 

type CombinerClient interface {
	Aggregate(ctx context.Context, in *SeldonMessageList, opts ...grpc.CallOption) (*SeldonMessage, error)
}

CombinerClient is the client API for Combiner service.

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

func NewCombinerClient 

func NewCombinerClient(cc *grpc.ClientConn) CombinerClient

type CombinerServer 

type CombinerServer interface {
	Aggregate(context.Context, *SeldonMessageList) (*SeldonMessage, error)
}

CombinerServer is the server API for Combiner service.

type DefaultData 

type DefaultData struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// Types that are valid to be assigned to DataOneof:
	//	*DefaultData_Tensor
	//	*DefaultData_Ndarray
	//	*DefaultData_Tftensor
	DataOneof            isDefaultData_DataOneof `protobuf_oneof:"data_oneof"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*DefaultData) Descriptor 

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

func (*DefaultData) GetDataOneof 

func (m *DefaultData) GetDataOneof() isDefaultData_DataOneof

func (*DefaultData) GetNames 

func (m *DefaultData) GetNames() []string

func (*DefaultData) GetNdarray 

func (m *DefaultData) GetNdarray() *_struct.ListValue

func (*DefaultData) GetTensor 

func (m *DefaultData) GetTensor() *Tensor

func (*DefaultData) GetTftensor 

func (m *DefaultData) GetTftensor() *framework.TensorProto

func (*DefaultData) ProtoMessage 

func (*DefaultData) ProtoMessage()

func (*DefaultData) Reset 

func (m *DefaultData) Reset()

func (*DefaultData) String 

func (m *DefaultData) String() string

func (*DefaultData) XXX_DiscardUnknown 

func (m *DefaultData) XXX_DiscardUnknown()

func (*DefaultData) XXX_Marshal 

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

func (*DefaultData) XXX_Merge 

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

func (*DefaultData) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DefaultData) XXX_Size 

func (m *DefaultData) XXX_Size() int

func (*DefaultData) XXX_Unmarshal 

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

type DefaultData_Ndarray 

type DefaultData_Ndarray struct {
	Ndarray *_struct.ListValue `protobuf:"bytes,3,opt,name=ndarray,proto3,oneof"`
}

type DefaultData_Tensor 

type DefaultData_Tensor struct {
	Tensor *Tensor `protobuf:"bytes,2,opt,name=tensor,proto3,oneof"`
}

type DefaultData_Tftensor 

type DefaultData_Tftensor struct {
	Tftensor *framework.TensorProto `protobuf:"bytes,4,opt,name=tftensor,proto3,oneof"`
}

type Feedback 

type Feedback struct {
	Request              *SeldonMessage `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Response             *SeldonMessage `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	Reward               float32        `protobuf:"fixed32,3,opt,name=reward,proto3" json:"reward,omitempty"`
	Truth                *SeldonMessage `protobuf:"bytes,4,opt,name=truth,proto3" json:"truth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Feedback) Descriptor 

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

func (*Feedback) GetRequest 

func (m *Feedback) GetRequest() *SeldonMessage

func (*Feedback) GetResponse 

func (m *Feedback) GetResponse() *SeldonMessage

func (*Feedback) GetReward 

func (m *Feedback) GetReward() float32

func (*Feedback) GetTruth 

func (m *Feedback) GetTruth() *SeldonMessage

func (*Feedback) ProtoMessage 

func (*Feedback) ProtoMessage()

func (*Feedback) Reset 

func (m *Feedback) Reset()

func (*Feedback) String 

func (m *Feedback) String() string

func (*Feedback) XXX_DiscardUnknown 

func (m *Feedback) XXX_DiscardUnknown()

func (*Feedback) XXX_Marshal 

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

func (*Feedback) XXX_Merge 

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

func (*Feedback) XXX_Size 

func (m *Feedback) XXX_Size() int

func (*Feedback) XXX_Unmarshal 

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

type GenericClient 

type GenericClient interface {
	TransformInput(ctx context.Context, in *SeldonMessage, opts ...grpc.CallOption) (*SeldonMessage, error)
	TransformOutput(ctx context.Context, in *SeldonMessage, opts ...grpc.CallOption) (*SeldonMessage, error)
	Route(ctx context.Context, in *SeldonMessage, opts ...grpc.CallOption) (*SeldonMessage, error)
	Aggregate(ctx context.Context, in *SeldonMessageList, opts ...grpc.CallOption) (*SeldonMessage, error)
	SendFeedback(ctx context.Context, in *Feedback, opts ...grpc.CallOption) (*SeldonMessage, error)
}

GenericClient is the client API for Generic service.

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

func NewGenericClient 

func NewGenericClient(cc *grpc.ClientConn) GenericClient

type GenericServer 

type GenericServer interface {
	TransformInput(context.Context, *SeldonMessage) (*SeldonMessage, error)
	TransformOutput(context.Context, *SeldonMessage) (*SeldonMessage, error)
	Route(context.Context, *SeldonMessage) (*SeldonMessage, error)
	Aggregate(context.Context, *SeldonMessageList) (*SeldonMessage, error)
	SendFeedback(context.Context, *Feedback) (*SeldonMessage, error)
}

GenericServer is the server API for Generic service.

type Meta 

type Meta struct {
	Puid                 string                    `protobuf:"bytes,1,opt,name=puid,proto3" json:"puid,omitempty"`
	Tags                 map[string]*_struct.Value `` /* 149-byte string literal not displayed */
	Routing              map[string]int32          `` /* 156-byte string literal not displayed */
	RequestPath          map[string]string         `` /* 163-byte string literal not displayed */
	Metrics              []*Metric                 `protobuf:"bytes,5,rep,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*Meta) Descriptor 

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

func (*Meta) GetMetrics 

func (m *Meta) GetMetrics() []*Metric

func (*Meta) GetPuid 

func (m *Meta) GetPuid() string

func (*Meta) GetRequestPath 

func (m *Meta) GetRequestPath() map[string]string

func (*Meta) GetRouting 

func (m *Meta) GetRouting() map[string]int32

func (*Meta) GetTags 

func (m *Meta) GetTags() map[string]*_struct.Value

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) Reset 

func (m *Meta) Reset()

func (*Meta) String 

func (m *Meta) String() string

func (*Meta) XXX_DiscardUnknown 

func (m *Meta) XXX_DiscardUnknown()

func (*Meta) XXX_Marshal 

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

func (*Meta) XXX_Merge 

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

func (*Meta) XXX_Size 

func (m *Meta) XXX_Size() int

func (*Meta) XXX_Unmarshal 

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

type Metric 

type Metric struct {
	Key                  string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Type                 Metric_MetricType `protobuf:"varint,2,opt,name=type,proto3,enum=seldon.protos.Metric_MetricType" json:"type,omitempty"`
	Value                float32           `protobuf:"fixed32,3,opt,name=value,proto3" json:"value,omitempty"`
	Tags                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Metric) Descriptor 

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

func (*Metric) GetKey 

func (m *Metric) GetKey() string

func (*Metric) GetTags 

func (m *Metric) GetTags() map[string]string

func (*Metric) GetType 

func (m *Metric) GetType() Metric_MetricType

func (*Metric) GetValue 

func (m *Metric) GetValue() float32

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) Reset 

func (m *Metric) Reset()

func (*Metric) String 

func (m *Metric) String() string

func (*Metric) XXX_DiscardUnknown 

func (m *Metric) XXX_DiscardUnknown()

func (*Metric) XXX_Marshal 

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

func (*Metric) XXX_Merge 

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

func (*Metric) XXX_Size 

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal 

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

type Metric_MetricType 

type Metric_MetricType int32
const (
	Metric_COUNTER Metric_MetricType = 0
	Metric_GAUGE   Metric_MetricType = 1
	Metric_TIMER   Metric_MetricType = 2
)

func (Metric_MetricType) EnumDescriptor 

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

func (Metric_MetricType) String 

func (x Metric_MetricType) String() string

type ModelClient 

type ModelClient interface {
	Predict(ctx context.Context, in *SeldonMessage, opts ...grpc.CallOption) (*SeldonMessage, error)
	SendFeedback(ctx context.Context, in *Feedback, opts ...grpc.CallOption) (*SeldonMessage, error)
}

ModelClient is the client API for Model service.

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

func NewModelClient 

func NewModelClient(cc *grpc.ClientConn) ModelClient

type ModelServer 

type ModelServer interface {
	Predict(context.Context, *SeldonMessage) (*SeldonMessage, error)
	SendFeedback(context.Context, *Feedback) (*SeldonMessage, error)
}

ModelServer is the server API for Model service.

type OutputTransformerClient 

type OutputTransformerClient interface {
	TransformOutput(ctx context.Context, in *SeldonMessage, opts ...grpc.CallOption) (*SeldonMessage, error)
}

OutputTransformerClient is the client API for OutputTransformer service.

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

func NewOutputTransformerClient 

func NewOutputTransformerClient(cc *grpc.ClientConn) OutputTransformerClient

type OutputTransformerServer 

type OutputTransformerServer interface {
	TransformOutput(context.Context, *SeldonMessage) (*SeldonMessage, error)
}

OutputTransformerServer is the server API for OutputTransformer service.

type RequestResponse 

type RequestResponse struct {
	Request              *SeldonMessage `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Response             *SeldonMessage `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RequestResponse) Descriptor 

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

func (*RequestResponse) GetRequest 

func (m *RequestResponse) GetRequest() *SeldonMessage

func (*RequestResponse) GetResponse 

func (m *RequestResponse) GetResponse() *SeldonMessage

func (*RequestResponse) ProtoMessage 

func (*RequestResponse) ProtoMessage()

func (*RequestResponse) Reset 

func (m *RequestResponse) Reset()

func (*RequestResponse) String 

func (m *RequestResponse) String() string

func (*RequestResponse) XXX_DiscardUnknown 

func (m *RequestResponse) XXX_DiscardUnknown()

func (*RequestResponse) XXX_Marshal 

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

func (*RequestResponse) XXX_Merge 

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

func (*RequestResponse) XXX_Size 

func (m *RequestResponse) XXX_Size() int

func (*RequestResponse) XXX_Unmarshal 

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

type RouterClient 

type RouterClient interface {
	Route(ctx context.Context, in *SeldonMessage, opts ...grpc.CallOption) (*SeldonMessage, error)
	SendFeedback(ctx context.Context, in *Feedback, opts ...grpc.CallOption) (*SeldonMessage, error)
}

RouterClient is the client API for Router service.

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

func NewRouterClient 

func NewRouterClient(cc *grpc.ClientConn) RouterClient

type RouterServer 

type RouterServer interface {
	Route(context.Context, *SeldonMessage) (*SeldonMessage, error)
	SendFeedback(context.Context, *Feedback) (*SeldonMessage, error)
}

RouterServer is the server API for Router service.

type SeldonClient 

type SeldonClient interface {
	Predict(ctx context.Context, in *SeldonMessage, opts ...grpc.CallOption) (*SeldonMessage, error)
	SendFeedback(ctx context.Context, in *Feedback, opts ...grpc.CallOption) (*SeldonMessage, error)
}

SeldonClient is the client API for Seldon service.

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

func NewSeldonClient 

func NewSeldonClient(cc *grpc.ClientConn) SeldonClient

type SeldonMessage 

type SeldonMessage struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Meta   *Meta   `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// Types that are valid to be assigned to DataOneof:
	//	*SeldonMessage_Data
	//	*SeldonMessage_BinData
	//	*SeldonMessage_StrData
	//	*SeldonMessage_JsonData
	DataOneof            isSeldonMessage_DataOneof `protobuf_oneof:"data_oneof"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*SeldonMessage) Descriptor 

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

func (*SeldonMessage) GetBinData 

func (m *SeldonMessage) GetBinData() []byte

func (*SeldonMessage) GetData 

func (m *SeldonMessage) GetData() *DefaultData

func (*SeldonMessage) GetDataOneof 

func (m *SeldonMessage) GetDataOneof() isSeldonMessage_DataOneof

func (*SeldonMessage) GetJsonData added in v1.0.1 

func (m *SeldonMessage) GetJsonData() *_struct.Value

func (*SeldonMessage) GetMeta 

func (m *SeldonMessage) GetMeta() *Meta

func (*SeldonMessage) GetStatus 

func (m *SeldonMessage) GetStatus() *Status

func (*SeldonMessage) GetStrData 

func (m *SeldonMessage) GetStrData() string

func (*SeldonMessage) ProtoMessage 

func (*SeldonMessage) ProtoMessage()

func (*SeldonMessage) Reset 

func (m *SeldonMessage) Reset()

func (*SeldonMessage) String 

func (m *SeldonMessage) String() string

func (*SeldonMessage) XXX_DiscardUnknown 

func (m *SeldonMessage) XXX_DiscardUnknown()

func (*SeldonMessage) XXX_Marshal 

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

func (*SeldonMessage) XXX_Merge 

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

func (*SeldonMessage) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*SeldonMessage) XXX_Size 

func (m *SeldonMessage) XXX_Size() int

func (*SeldonMessage) XXX_Unmarshal 

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

type SeldonMessageList 

type SeldonMessageList struct {
	SeldonMessages       []*SeldonMessage `protobuf:"bytes,1,rep,name=seldonMessages,proto3" json:"seldonMessages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SeldonMessageList) Descriptor 

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

func (*SeldonMessageList) GetSeldonMessages 

func (m *SeldonMessageList) GetSeldonMessages() []*SeldonMessage

func (*SeldonMessageList) ProtoMessage 

func (*SeldonMessageList) ProtoMessage()

func (*SeldonMessageList) Reset 

func (m *SeldonMessageList) Reset()

func (*SeldonMessageList) String 

func (m *SeldonMessageList) String() string

func (*SeldonMessageList) XXX_DiscardUnknown 

func (m *SeldonMessageList) XXX_DiscardUnknown()

func (*SeldonMessageList) XXX_Marshal 

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

func (*SeldonMessageList) XXX_Merge 

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

func (*SeldonMessageList) XXX_Size 

func (m *SeldonMessageList) XXX_Size() int

func (*SeldonMessageList) XXX_Unmarshal 

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

type SeldonMessage_BinData 

type SeldonMessage_BinData struct {
	BinData []byte `protobuf:"bytes,4,opt,name=binData,proto3,oneof"`
}

type SeldonMessage_Data 

type SeldonMessage_Data struct {
	Data *DefaultData `protobuf:"bytes,3,opt,name=data,proto3,oneof"`
}

type SeldonMessage_JsonData added in v1.0.1 

type SeldonMessage_JsonData struct {
	JsonData *_struct.Value `protobuf:"bytes,6,opt,name=jsonData,proto3,oneof"`
}

type SeldonMessage_StrData 

type SeldonMessage_StrData struct {
	StrData string `protobuf:"bytes,5,opt,name=strData,proto3,oneof"`
}

type SeldonServer 

type SeldonServer interface {
	Predict(context.Context, *SeldonMessage) (*SeldonMessage, error)
	SendFeedback(context.Context, *Feedback) (*SeldonMessage, error)
}

SeldonServer is the server API for Seldon service.

type Status 

type Status struct {
	Code                 int32             `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Info                 string            `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Reason               string            `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	Status               Status_StatusFlag `protobuf:"varint,4,opt,name=status,proto3,enum=seldon.protos.Status_StatusFlag" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Status) Descriptor 

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

func (*Status) GetCode 

func (m *Status) GetCode() int32

func (*Status) GetInfo 

func (m *Status) GetInfo() string

func (*Status) GetReason 

func (m *Status) GetReason() string

func (*Status) GetStatus 

func (m *Status) GetStatus() Status_StatusFlag

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) String 

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

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

func (*Status) XXX_Merge 

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

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

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

type Status_StatusFlag 

type Status_StatusFlag int32
const (
	Status_SUCCESS Status_StatusFlag = 0
	Status_FAILURE Status_StatusFlag = 1
)

func (Status_StatusFlag) EnumDescriptor 

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

func (Status_StatusFlag) String 

func (x Status_StatusFlag) String() string

type Tensor 

type Tensor struct {
	Shape                []int32   `protobuf:"varint,1,rep,packed,name=shape,proto3" json:"shape,omitempty"`
	Values               []float64 `protobuf:"fixed64,2,rep,packed,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Tensor) Descriptor 

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

func (*Tensor) GetShape 

func (m *Tensor) GetShape() []int32

func (*Tensor) GetValues 

func (m *Tensor) GetValues() []float64

func (*Tensor) ProtoMessage 

func (*Tensor) ProtoMessage()

func (*Tensor) Reset 

func (m *Tensor) Reset()

func (*Tensor) String 

func (m *Tensor) String() string

func (*Tensor) XXX_DiscardUnknown 

func (m *Tensor) XXX_DiscardUnknown()

func (*Tensor) XXX_Marshal 

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

func (*Tensor) XXX_Merge 

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

func (*Tensor) XXX_Size 

func (m *Tensor) XXX_Size() int

func (*Tensor) XXX_Unmarshal 

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

type TransformerClient 

type TransformerClient interface {
	TransformInput(ctx context.Context, in *SeldonMessage, opts ...grpc.CallOption) (*SeldonMessage, error)
}

TransformerClient is the client API for Transformer service.

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

func NewTransformerClient 

func NewTransformerClient(cc *grpc.ClientConn) TransformerClient

type TransformerServer 

type TransformerServer interface {
	TransformInput(context.Context, *SeldonMessage) (*SeldonMessage, error)
}

TransformerServer is the server API for Transformer service.

type UnimplementedCombinerServer added in v1.0.1 

type UnimplementedCombinerServer struct {
}

UnimplementedCombinerServer can be embedded to have forward compatible implementations.

func (*UnimplementedCombinerServer) Aggregate added in v1.0.1 

func (*UnimplementedCombinerServer) Aggregate(ctx context.Context, req *SeldonMessageList) (*SeldonMessage, error)

type UnimplementedGenericServer added in v1.0.1 

type UnimplementedGenericServer struct {
}

UnimplementedGenericServer can be embedded to have forward compatible implementations.

func (*UnimplementedGenericServer) Aggregate added in v1.0.1 

func (*UnimplementedGenericServer) Aggregate(ctx context.Context, req *SeldonMessageList) (*SeldonMessage, error)

func (*UnimplementedGenericServer) Route added in v1.0.1 

func (*UnimplementedGenericServer) Route(ctx context.Context, req *SeldonMessage) (*SeldonMessage, error)

func (*UnimplementedGenericServer) SendFeedback added in v1.0.1 

func (*UnimplementedGenericServer) SendFeedback(ctx context.Context, req *Feedback) (*SeldonMessage, error)

func (*UnimplementedGenericServer) TransformInput added in v1.0.1 

func (*UnimplementedGenericServer) TransformInput(ctx context.Context, req *SeldonMessage) (*SeldonMessage, error)

func (*UnimplementedGenericServer) TransformOutput added in v1.0.1 

func (*UnimplementedGenericServer) TransformOutput(ctx context.Context, req *SeldonMessage) (*SeldonMessage, error)

type UnimplementedModelServer added in v1.0.1 

type UnimplementedModelServer struct {
}

UnimplementedModelServer can be embedded to have forward compatible implementations.

func (*UnimplementedModelServer) Predict added in v1.0.1 

func (*UnimplementedModelServer) Predict(ctx context.Context, req *SeldonMessage) (*SeldonMessage, error)

func (*UnimplementedModelServer) SendFeedback added in v1.0.1 

func (*UnimplementedModelServer) SendFeedback(ctx context.Context, req *Feedback) (*SeldonMessage, error)

type UnimplementedOutputTransformerServer added in v1.0.1 

type UnimplementedOutputTransformerServer struct {
}

UnimplementedOutputTransformerServer can be embedded to have forward compatible implementations.

func (*UnimplementedOutputTransformerServer) TransformOutput added in v1.0.1 

func (*UnimplementedOutputTransformerServer) TransformOutput(ctx context.Context, req *SeldonMessage) (*SeldonMessage, error)

type UnimplementedRouterServer added in v1.0.1 

type UnimplementedRouterServer struct {
}

UnimplementedRouterServer can be embedded to have forward compatible implementations.

func (*UnimplementedRouterServer) Route added in v1.0.1 

func (*UnimplementedRouterServer) Route(ctx context.Context, req *SeldonMessage) (*SeldonMessage, error)

func (*UnimplementedRouterServer) SendFeedback added in v1.0.1 

func (*UnimplementedRouterServer) SendFeedback(ctx context.Context, req *Feedback) (*SeldonMessage, error)

type UnimplementedSeldonServer added in v1.0.1 

type UnimplementedSeldonServer struct {
}

UnimplementedSeldonServer can be embedded to have forward compatible implementations.

func (*UnimplementedSeldonServer) Predict added in v1.0.1 

func (*UnimplementedSeldonServer) Predict(ctx context.Context, req *SeldonMessage) (*SeldonMessage, error)

func (*UnimplementedSeldonServer) SendFeedback added in v1.0.1 

func (*UnimplementedSeldonServer) SendFeedback(ctx context.Context, req *Feedback) (*SeldonMessage, error)

type UnimplementedTransformerServer added in v1.0.1 

type UnimplementedTransformerServer struct {
}

UnimplementedTransformerServer can be embedded to have forward compatible implementations.

func (*UnimplementedTransformerServer) TransformInput added in v1.0.1 

func (*UnimplementedTransformerServer) TransformInput(ctx context.Context, req *SeldonMessage) (*SeldonMessage, error)

Source Files

View all Source files

Directories

Path Synopsis
tensorflow
core/framework

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.