grpc_training_data_v1

package
v0.0.0-...-e1a27db Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2019 License: Apache-2.0 Imports: 5 Imported by: 4

Documentation

Overview

Package grpc_training_data_v1 is a generated protocol buffer package.

It is generated from these files: 

training_data.proto

It has these top-level messages: 

MetaInfo
LogLine
LogLineBatch
Any
EMetrics
EMetricsBatch
Query
DeleteQuery
AddResponse
DeleteResponse
HelloResponse
Empty

Index

Constants

This section is empty.

Variables

View Source 
var Any_DataType_name = map[int32]string{
	0: "STRING",
	1: "JSONSTRING",
	2: "INT",
	3: "FLOAT",
}
View Source 
var Any_DataType_value = map[string]int32{
	"STRING":     0,
	"JSONSTRING": 1,
	"INT":        2,
	"FLOAT":      3,
}
View Source 
var Query_SearchType_name = map[int32]string{
	0: "TERM",
	1: "NESTED",
	2: "MATCH",
	3: "ALL",
}
View Source 
var Query_SearchType_value = map[string]int32{
	"TERM":   0,
	"NESTED": 1,
	"MATCH":  2,
	"ALL":    3,
}

Functions

func RegisterTrainingDataServer 

func RegisterTrainingDataServer(s *grpc.Server, srv TrainingDataServer)

Types

type AddResponse 

type AddResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
}

***

func (*AddResponse) Descriptor 

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

func (*AddResponse) GetSuccess 

func (m *AddResponse) GetSuccess() bool

func (*AddResponse) ProtoMessage 

func (*AddResponse) ProtoMessage()

func (*AddResponse) Reset 

func (m *AddResponse) Reset()

func (*AddResponse) String 

func (m *AddResponse) String() string

type Any 

type Any struct {
	Type  Any_DataType `protobuf:"varint,1,opt,name=type,enum=grpc.training.data.v1.Any_DataType" json:"type,omitempty"`
	Value string       `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
}

func (*Any) Descriptor 

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

func (*Any) GetType 

func (m *Any) GetType() Any_DataType

func (*Any) GetValue 

func (m *Any) GetValue() string

func (*Any) ProtoMessage 

func (*Any) ProtoMessage()

func (*Any) Reset 

func (m *Any) Reset()

func (*Any) String 

func (m *Any) String() string

type Any_DataType 

type Any_DataType int32
const (
	Any_STRING     Any_DataType = 0
	Any_JSONSTRING Any_DataType = 1
	Any_INT        Any_DataType = 2
	Any_FLOAT      Any_DataType = 3
)

func (Any_DataType) EnumDescriptor 

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

func (Any_DataType) String 

func (x Any_DataType) String() string

type DeleteQuery 

type DeleteQuery struct {
	// The following two options are exclusive
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty"`
}

func (*DeleteQuery) Descriptor 

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

func (*DeleteQuery) GetTrainingId 

func (m *DeleteQuery) GetTrainingId() string

func (*DeleteQuery) GetUserId 

func (m *DeleteQuery) GetUserId() string

func (*DeleteQuery) ProtoMessage 

func (*DeleteQuery) ProtoMessage()

func (*DeleteQuery) Reset 

func (m *DeleteQuery) Reset()

func (*DeleteQuery) String 

func (m *DeleteQuery) String() string

type DeleteResponse 

type DeleteResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) GetSuccess 

func (m *DeleteResponse) GetSuccess() bool

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

type EMetrics 

type EMetrics struct {
	Meta *MetaInfo `protobuf:"bytes,1,opt,name=meta" json:"meta,omitempty"`
	// Repeated, order-dependent list of temporal keys
	// Example: {"iteration": 209}
	Etimes map[string]*Any `` /* 132-byte string literal not displayed */
	// Group label, such as test, train, or validate
	Grouplabel string `protobuf:"bytes,3,opt,name=grouplabel" json:"grouplabel,omitempty"`
	// / {"cross_entropy": 0.4430539906024933,	"accuracy": 0.8999999761581421}
	Values map[string]*Any `` /* 132-byte string literal not displayed */
}

func (*EMetrics) Descriptor 

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

func (*EMetrics) GetEtimes 

func (m *EMetrics) GetEtimes() map[string]*Any

func (*EMetrics) GetGrouplabel 

func (m *EMetrics) GetGrouplabel() string

func (*EMetrics) GetMeta 

func (m *EMetrics) GetMeta() *MetaInfo

func (*EMetrics) GetValues 

func (m *EMetrics) GetValues() map[string]*Any

func (*EMetrics) ProtoMessage 

func (*EMetrics) ProtoMessage()

func (*EMetrics) Reset 

func (m *EMetrics) Reset()

func (*EMetrics) String 

func (m *EMetrics) String() string

type EMetricsBatch 

type EMetricsBatch struct {
	Force    bool        `protobuf:"varint,1,opt,name=force" json:"force,omitempty"`
	Emetrics []*EMetrics `protobuf:"bytes,2,rep,name=emetrics" json:"emetrics,omitempty"`
}

func (*EMetricsBatch) Descriptor 

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

func (*EMetricsBatch) GetEmetrics 

func (m *EMetricsBatch) GetEmetrics() []*EMetrics

func (*EMetricsBatch) GetForce 

func (m *EMetricsBatch) GetForce() bool

func (*EMetricsBatch) ProtoMessage 

func (*EMetricsBatch) ProtoMessage()

func (*EMetricsBatch) Reset 

func (m *EMetricsBatch) Reset()

func (*EMetricsBatch) String 

func (m *EMetricsBatch) String() string

type Empty 

type Empty struct {
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

type HelloResponse 

type HelloResponse struct {
	Msg string `protobuf:"bytes,1,opt,name=msg" json:"msg,omitempty"`
}

func (*HelloResponse) Descriptor 

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

func (*HelloResponse) GetMsg 

func (m *HelloResponse) GetMsg() string

func (*HelloResponse) ProtoMessage 

func (*HelloResponse) ProtoMessage()

func (*HelloResponse) Reset 

func (m *HelloResponse) Reset()

func (*HelloResponse) String 

func (m *HelloResponse) String() string

type LogLine 

type LogLine struct {
	Meta *MetaInfo `protobuf:"bytes,1,opt,name=meta" json:"meta,omitempty"`
	Line string    `protobuf:"bytes,2,opt,name=line" json:"line,omitempty"`
}

func (*LogLine) Descriptor 

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

func (*LogLine) GetLine 

func (m *LogLine) GetLine() string

func (*LogLine) GetMeta 

func (m *LogLine) GetMeta() *MetaInfo

func (*LogLine) ProtoMessage 

func (*LogLine) ProtoMessage()

func (*LogLine) Reset 

func (m *LogLine) Reset()

func (*LogLine) String 

func (m *LogLine) String() string

type LogLineBatch 

type LogLineBatch struct {
	Force   bool       `protobuf:"varint,1,opt,name=force" json:"force,omitempty"`
	LogLine []*LogLine `protobuf:"bytes,2,rep,name=logLine" json:"logLine,omitempty"`
}

func (*LogLineBatch) Descriptor 

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

func (*LogLineBatch) GetForce 

func (m *LogLineBatch) GetForce() bool

func (*LogLineBatch) GetLogLine 

func (m *LogLineBatch) GetLogLine() []*LogLine

func (*LogLineBatch) ProtoMessage 

func (*LogLineBatch) ProtoMessage()

func (*LogLineBatch) Reset 

func (m *LogLineBatch) Reset()

func (*LogLineBatch) String 

func (m *LogLineBatch) String() string

type MetaInfo 

type MetaInfo struct {
	// Unique id identifying the training job
	TrainingId string `protobuf:"bytes,1,opt,name=training_id,json=trainingId" json:"training_id,omitempty"`
	// Unique id identifying the user
	UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId" json:"user_id,omitempty"`
	// Time that the metric occured: representing the number of millisecond since midnight January 1, 1970.
	Time int64 `protobuf:"varint,3,opt,name=time" json:"time,omitempty"`
	// Sequential index
	Rindex int64 `protobuf:"varint,4,opt,name=rindex" json:"rindex,omitempty"`
	// Optional subid
	Subid string `protobuf:"bytes,5,opt,name=subid" json:"subid,omitempty"`
}

func (*MetaInfo) Descriptor 

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

func (*MetaInfo) GetRindex 

func (m *MetaInfo) GetRindex() int64

func (*MetaInfo) GetSubid 

func (m *MetaInfo) GetSubid() string

func (*MetaInfo) GetTime 

func (m *MetaInfo) GetTime() int64

func (*MetaInfo) GetTrainingId 

func (m *MetaInfo) GetTrainingId() string

func (*MetaInfo) GetUserId 

func (m *MetaInfo) GetUserId() string

func (*MetaInfo) ProtoMessage 

func (*MetaInfo) ProtoMessage()

func (*MetaInfo) Reset 

func (m *MetaInfo) Reset()

func (*MetaInfo) String 

func (m *MetaInfo) String() string

type Query 

type Query struct {
	SearchType Query_SearchType `protobuf:"varint,1,opt,name=searchType,enum=grpc.training.data.v1.Query_SearchType" json:"searchType,omitempty"`
	// The following three options are exclusive
	Meta  *MetaInfo `protobuf:"bytes,3,opt,name=meta" json:"meta,omitempty"`
	Since string    `protobuf:"bytes,4,opt,name=since" json:"since,omitempty"`
	// Only get this many records
	Pagesize int32 `protobuf:"varint,5,opt,name=pagesize" json:"pagesize,omitempty"`
	// The starting position.  If positive or zero, count from beginning, if negative, count from end.
	Pos int64 `protobuf:"varint,6,opt,name=pos" json:"pos,omitempty"`
}

Playing with semi-generalized query request.

func (*Query) Descriptor 

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

func (*Query) GetMeta 

func (m *Query) GetMeta() *MetaInfo

func (*Query) GetPagesize 

func (m *Query) GetPagesize() int32

func (*Query) GetPos 

func (m *Query) GetPos() int64

func (*Query) GetSearchType 

func (m *Query) GetSearchType() Query_SearchType

func (*Query) GetSince 

func (m *Query) GetSince() string

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

type Query_SearchType 

type Query_SearchType int32
const (
	Query_TERM   Query_SearchType = 0
	Query_NESTED Query_SearchType = 1
	Query_MATCH  Query_SearchType = 2
	Query_ALL    Query_SearchType = 3
)

func (Query_SearchType) EnumDescriptor 

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

func (Query_SearchType) String 

func (x Query_SearchType) String() string

type TrainingDataClient 

type TrainingDataClient interface {
	// Get loglines, based on query
	GetLogs(ctx context.Context, in *Query, opts ...grpc.CallOption) (TrainingData_GetLogsClient, error)
	// Get evaluation metrics records, based on query
	GetEMetrics(ctx context.Context, in *Query, opts ...grpc.CallOption) (TrainingData_GetEMetricsClient, error)
	// Add evaluation metrics record
	AddEMetrics(ctx context.Context, in *EMetrics, opts ...grpc.CallOption) (*AddResponse, error)
	// Add log line record
	AddLogLine(ctx context.Context, in *LogLine, opts ...grpc.CallOption) (*AddResponse, error)
	// Add evaluation metrics record
	AddEMetricsBatch(ctx context.Context, in *EMetricsBatch, opts ...grpc.CallOption) (*AddResponse, error)
	// Add log line record
	AddLogLineBatch(ctx context.Context, in *LogLineBatch, opts ...grpc.CallOption) (*AddResponse, error)
	// Delete all evaluation metrics belonging to a training job or user id
	DeleteEMetrics(ctx context.Context, in *Query, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Delete all log lines belonging to a training job or user id
	DeleteLogLines(ctx context.Context, in *Query, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Delete all log lines belonging to a training job or user id
	DeleteJob(ctx context.Context, in *Query, opts ...grpc.CallOption) (*DeleteResponse, error)
	// ===== In case you want it to say "Hello" =========
	Hello(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HelloResponse, error)
}

func NewTrainingDataClient 

func NewTrainingDataClient(cc *grpc.ClientConn) TrainingDataClient

type TrainingDataServer 

type TrainingDataServer interface {
	// Get loglines, based on query
	GetLogs(*Query, TrainingData_GetLogsServer) error
	// Get evaluation metrics records, based on query
	GetEMetrics(*Query, TrainingData_GetEMetricsServer) error
	// Add evaluation metrics record
	AddEMetrics(context.Context, *EMetrics) (*AddResponse, error)
	// Add log line record
	AddLogLine(context.Context, *LogLine) (*AddResponse, error)
	// Add evaluation metrics record
	AddEMetricsBatch(context.Context, *EMetricsBatch) (*AddResponse, error)
	// Add log line record
	AddLogLineBatch(context.Context, *LogLineBatch) (*AddResponse, error)
	// Delete all evaluation metrics belonging to a training job or user id
	DeleteEMetrics(context.Context, *Query) (*DeleteResponse, error)
	// Delete all log lines belonging to a training job or user id
	DeleteLogLines(context.Context, *Query) (*DeleteResponse, error)
	// Delete all log lines belonging to a training job or user id
	DeleteJob(context.Context, *Query) (*DeleteResponse, error)
	// ===== In case you want it to say "Hello" =========
	Hello(context.Context, *Empty) (*HelloResponse, error)
}

type TrainingData_GetEMetricsClient 

type TrainingData_GetEMetricsClient interface {
	Recv() (*EMetrics, error)
	grpc.ClientStream
}

type TrainingData_GetEMetricsServer 

type TrainingData_GetEMetricsServer interface {
	Send(*EMetrics) error
	grpc.ServerStream
}

type TrainingData_GetLogsClient 

type TrainingData_GetLogsClient interface {
	Recv() (*LogLine, error)
	grpc.ClientStream
}

type TrainingData_GetLogsServer 

type TrainingData_GetLogsServer interface {
	Send(*LogLine) error
	grpc.ServerStream
}

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.