aggregatorpb

package
v0.0.0-...-d9bce91 Latest Latest
Warning

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

 Go to latest Published: Jul 11, 2018 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package aggregatorpb is a generated protocol buffer package.

It is generated from these files: 

protobuf/aggregatorpb/aggregator.proto

It has these top-level messages: 

HyperParams
SchedulingInfo
Work
ModelID
GetWorkRequest
FindWorkRequest
FindWorkResponse
ModelWeightChunk
GetWorkResponse
ReportWorkRequest
ReportWorkResponse
ProdModelRequest
ProdModelResponse
ModelTypeAllocation
NotifyRequest
NotifyResponse
CancelModelTrainingRequest
CancelModelTrainingResponse
ModelURLRequest
ModelURLResponse
Error
ReportErrorRequest
ReportErrorResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAggregator = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAggregator   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ErrorType_name = map[int32]string{
	0: "ERROR_UNKNOWN",
	1: "ERROR_TRAINING",
	2: "ERROR_INFERENCE",
}
View Source 
var ErrorType_value = map[string]int32{
	"ERROR_UNKNOWN":   0,
	"ERROR_TRAINING":  1,
	"ERROR_INFERENCE": 2,
}
View Source 
var Repeat_name = map[int32]string{
	0: "NEVER",
	1: "HOURLY",
	2: "DAILY",
	3: "WEEKLY",
	4: "MONTHLY",
}
View Source 
var Repeat_value = map[string]int32{
	"NEVER":   0,
	"HOURLY":  1,
	"DAILY":   2,
	"WEEKLY":  3,
	"MONTHLY": 4,
}
View Source 
var TrainingStatus_name = map[int32]string{
	0: "SCHEDULED",
	1: "TRAINING",
	2: "SUCCEEDED",
	3: "FAILED",
	4: "CANCELED",
}
View Source 
var TrainingStatus_value = map[string]int32{
	"SCHEDULED": 0,
	"TRAINING":  1,
	"SUCCEEDED": 2,
	"FAILED":    3,
	"CANCELED":  4,
}

Functions

func RegisterAggregatorServer 

func RegisterAggregatorServer(s *grpc.Server, srv AggregatorServer)

func RegisterEdgeServer 

func RegisterEdgeServer(s *grpc.Server, srv EdgeServer)

Types

type AggregatorClient 

type AggregatorClient interface {
	// GetWork sends work to clients to process.
	GetWork(ctx context.Context, in *GetWorkRequest, opts ...grpc.CallOption) (Aggregator_GetWorkClient, error)
	// ReportWork is used to report the trained model/work to the server.
	ReportWork(ctx context.Context, opts ...grpc.CallOption) (Aggregator_ReportWorkClient, error)
	// Internal RPCs.
	Notify(ctx context.Context, in *NotifyRequest, opts ...grpc.CallOption) (*NotifyResponse, error)
	CancelModelTraining(ctx context.Context, in *CancelModelTrainingRequest, opts ...grpc.CallOption) (*CancelModelTrainingResponse, error)
}

func NewAggregatorClient 

func NewAggregatorClient(cc *grpc.ClientConn) AggregatorClient

type AggregatorServer 

type AggregatorServer interface {
	// GetWork sends work to clients to process.
	GetWork(*GetWorkRequest, Aggregator_GetWorkServer) error
	// ReportWork is used to report the trained model/work to the server.
	ReportWork(Aggregator_ReportWorkServer) error
	// Internal RPCs.
	Notify(context.Context, *NotifyRequest) (*NotifyResponse, error)
	CancelModelTraining(context.Context, *CancelModelTrainingRequest) (*CancelModelTrainingResponse, error)
}

type Aggregator_GetWorkClient 

type Aggregator_GetWorkClient interface {
	Recv() (*GetWorkResponse, error)
	grpc.ClientStream
}

type Aggregator_GetWorkServer 

type Aggregator_GetWorkServer interface {
	Send(*GetWorkResponse) error
	grpc.ServerStream
}

type Aggregator_ReportWorkClient 

type Aggregator_ReportWorkClient interface {
	Send(*ReportWorkRequest) error
	CloseAndRecv() (*ReportWorkResponse, error)
	grpc.ClientStream
}

type Aggregator_ReportWorkServer 

type Aggregator_ReportWorkServer interface {
	SendAndClose(*ReportWorkResponse) error
	Recv() (*ReportWorkRequest, error)
	grpc.ServerStream
}

type CancelModelTrainingRequest 

type CancelModelTrainingRequest struct {
	Id ModelID `protobuf:"bytes,1,opt,name=id" json:"id"`
}

func (*CancelModelTrainingRequest) Descriptor 

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

func (*CancelModelTrainingRequest) Equal 

func (this *CancelModelTrainingRequest) Equal(that interface{}) bool

func (*CancelModelTrainingRequest) GetId 

func (m *CancelModelTrainingRequest) GetId() ModelID

func (*CancelModelTrainingRequest) GoString 

func (this *CancelModelTrainingRequest) GoString() string

func (*CancelModelTrainingRequest) Marshal 

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

func (*CancelModelTrainingRequest) MarshalTo 

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

func (*CancelModelTrainingRequest) ProtoMessage 

func (*CancelModelTrainingRequest) ProtoMessage()

func (*CancelModelTrainingRequest) Reset 

func (m *CancelModelTrainingRequest) Reset()

func (*CancelModelTrainingRequest) Size 

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

func (*CancelModelTrainingRequest) String 

func (this *CancelModelTrainingRequest) String() string

func (*CancelModelTrainingRequest) Unmarshal 

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

type CancelModelTrainingResponse 

type CancelModelTrainingResponse struct {
}

func (*CancelModelTrainingResponse) Descriptor 

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

func (*CancelModelTrainingResponse) Equal 

func (this *CancelModelTrainingResponse) Equal(that interface{}) bool

func (*CancelModelTrainingResponse) GoString 

func (this *CancelModelTrainingResponse) GoString() string

func (*CancelModelTrainingResponse) Marshal 

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

func (*CancelModelTrainingResponse) MarshalTo 

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

func (*CancelModelTrainingResponse) ProtoMessage 

func (*CancelModelTrainingResponse) ProtoMessage()

func (*CancelModelTrainingResponse) Reset 

func (m *CancelModelTrainingResponse) Reset()

func (*CancelModelTrainingResponse) Size 

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

func (*CancelModelTrainingResponse) String 

func (this *CancelModelTrainingResponse) String() string

func (*CancelModelTrainingResponse) Unmarshal 

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

type EdgeClient 

type EdgeClient interface {
	// ProdModel returns the current production model.
	ProdModel(ctx context.Context, in *ProdModelRequest, opts ...grpc.CallOption) (*ProdModelResponse, error)
	// FindWork returns an address of the aggregator that the client should
	// request work from.
	FindWork(ctx context.Context, in *FindWorkRequest, opts ...grpc.CallOption) (*FindWorkResponse, error)
	// ModelURL returns a URL that can be used to download the model. For billing
	// purposes, hitting this endpoint will count as one download of the model.
	ModelURL(ctx context.Context, in *ModelURLRequest, opts ...grpc.CallOption) (*ModelURLResponse, error)
	// ReportError reports an error to the server so the developers can later view
	// them.
	ReportError(ctx context.Context, in *ReportErrorRequest, opts ...grpc.CallOption) (*ReportErrorResponse, error)
}

func NewEdgeClient 

func NewEdgeClient(cc *grpc.ClientConn) EdgeClient

type EdgeServer 

type EdgeServer interface {
	// ProdModel returns the current production model.
	ProdModel(context.Context, *ProdModelRequest) (*ProdModelResponse, error)
	// FindWork returns an address of the aggregator that the client should
	// request work from.
	FindWork(context.Context, *FindWorkRequest) (*FindWorkResponse, error)
	// ModelURL returns a URL that can be used to download the model. For billing
	// purposes, hitting this endpoint will count as one download of the model.
	ModelURL(context.Context, *ModelURLRequest) (*ModelURLResponse, error)
	// ReportError reports an error to the server so the developers can later view
	// them.
	ReportError(context.Context, *ReportErrorRequest) (*ReportErrorResponse, error)
}

type Error 

type Error struct {
	Id         ModelID   `protobuf:"bytes,1,opt,name=id" json:"id"`
	Type       ErrorType `protobuf:"varint,2,opt,name=type,proto3,enum=aggregatorpb.ErrorType" json:"type,omitempty"`
	Error      string    `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Stacktrace string    `protobuf:"bytes,4,opt,name=stacktrace,proto3" json:"stacktrace,omitempty"`
}

func (*Error) Descriptor 

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

func (*Error) Equal 

func (this *Error) Equal(that interface{}) bool

func (*Error) GetError 

func (m *Error) GetError() string

func (*Error) GetId 

func (m *Error) GetId() ModelID

func (*Error) GetStacktrace 

func (m *Error) GetStacktrace() string

func (*Error) GetType 

func (m *Error) GetType() ErrorType

func (*Error) GoString 

func (this *Error) GoString() string

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (this *Error) String() string

func (*Error) Unmarshal 

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

type ErrorType 

type ErrorType int32
const (
	ERROR_UNKNOWN   ErrorType = 0
	ERROR_TRAINING  ErrorType = 1
	ERROR_INFERENCE ErrorType = 2
)

func (ErrorType) EnumDescriptor 

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

func (ErrorType) String 

func (x ErrorType) String() string

type FindWorkRequest 

type FindWorkRequest struct {
	Id ModelID `protobuf:"bytes,1,opt,name=id" json:"id"`
}

func (*FindWorkRequest) Descriptor 

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

func (*FindWorkRequest) Equal 

func (this *FindWorkRequest) Equal(that interface{}) bool

func (*FindWorkRequest) GetId 

func (m *FindWorkRequest) GetId() ModelID

func (*FindWorkRequest) GoString 

func (this *FindWorkRequest) GoString() string

func (*FindWorkRequest) Marshal 

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

func (*FindWorkRequest) MarshalTo 

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

func (*FindWorkRequest) ProtoMessage 

func (*FindWorkRequest) ProtoMessage()

func (*FindWorkRequest) Reset 

func (m *FindWorkRequest) Reset()

func (*FindWorkRequest) Size 

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

func (*FindWorkRequest) String 

func (this *FindWorkRequest) String() string

func (*FindWorkRequest) Unmarshal 

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

type FindWorkResponse 

type FindWorkResponse struct {
	AggregatorAddr string `protobuf:"bytes,1,opt,name=aggregator_addr,json=aggregatorAddr,proto3" json:"aggregator_addr,omitempty"`
}

func (*FindWorkResponse) Descriptor 

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

func (*FindWorkResponse) Equal 

func (this *FindWorkResponse) Equal(that interface{}) bool

func (*FindWorkResponse) GetAggregatorAddr 

func (m *FindWorkResponse) GetAggregatorAddr() string

func (*FindWorkResponse) GoString 

func (this *FindWorkResponse) GoString() string

func (*FindWorkResponse) Marshal 

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

func (*FindWorkResponse) MarshalTo 

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

func (*FindWorkResponse) ProtoMessage 

func (*FindWorkResponse) ProtoMessage()

func (*FindWorkResponse) Reset 

func (m *FindWorkResponse) Reset()

func (*FindWorkResponse) Size 

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

func (*FindWorkResponse) String 

func (this *FindWorkResponse) String() string

func (*FindWorkResponse) Unmarshal 

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

type GetWorkRequest 

type GetWorkRequest struct {
	Id ModelID `protobuf:"bytes,1,opt,name=id" json:"id"`
}

func (*GetWorkRequest) Descriptor 

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

func (*GetWorkRequest) Equal 

func (this *GetWorkRequest) Equal(that interface{}) bool

func (*GetWorkRequest) GetId 

func (m *GetWorkRequest) GetId() ModelID

func (*GetWorkRequest) GoString 

func (this *GetWorkRequest) GoString() string

func (*GetWorkRequest) Marshal 

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

func (*GetWorkRequest) MarshalTo 

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

func (*GetWorkRequest) ProtoMessage 

func (*GetWorkRequest) ProtoMessage()

func (*GetWorkRequest) Reset 

func (m *GetWorkRequest) Reset()

func (*GetWorkRequest) Size 

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

func (*GetWorkRequest) String 

func (this *GetWorkRequest) String() string

func (*GetWorkRequest) Unmarshal 

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

type GetWorkResponse 

type GetWorkResponse struct {
	// Types that are valid to be assigned to Type:
	//	*GetWorkResponse_Work
	//	*GetWorkResponse_Weights
	Type isGetWorkResponse_Type `protobuf_oneof:"type"`
}

func (*GetWorkResponse) Descriptor 

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

func (*GetWorkResponse) Equal 

func (this *GetWorkResponse) Equal(that interface{}) bool

func (*GetWorkResponse) GetType 

func (m *GetWorkResponse) GetType() isGetWorkResponse_Type

func (*GetWorkResponse) GetWeights 

func (m *GetWorkResponse) GetWeights() *ModelWeightChunk

func (*GetWorkResponse) GetWork 

func (m *GetWorkResponse) GetWork() *Work

func (*GetWorkResponse) GoString 

func (this *GetWorkResponse) GoString() string

func (*GetWorkResponse) Marshal 

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

func (*GetWorkResponse) MarshalTo 

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

func (*GetWorkResponse) ProtoMessage 

func (*GetWorkResponse) ProtoMessage()

func (*GetWorkResponse) Reset 

func (m *GetWorkResponse) Reset()

func (*GetWorkResponse) Size 

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

func (*GetWorkResponse) String 

func (this *GetWorkResponse) String() string

func (*GetWorkResponse) Unmarshal 

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

func (*GetWorkResponse) XXX_OneofFuncs 

func (*GetWorkResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type GetWorkResponse_Weights 

type GetWorkResponse_Weights struct {
	Weights *ModelWeightChunk `protobuf:"bytes,2,opt,name=weights,oneof"`
}

func (*GetWorkResponse_Weights) Equal 

func (this *GetWorkResponse_Weights) Equal(that interface{}) bool

func (*GetWorkResponse_Weights) GoString 

func (this *GetWorkResponse_Weights) GoString() string

func (*GetWorkResponse_Weights) MarshalTo 

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

func (*GetWorkResponse_Weights) Size 

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

func (*GetWorkResponse_Weights) String 

func (this *GetWorkResponse_Weights) String() string

type GetWorkResponse_Work 

type GetWorkResponse_Work struct {
	Work *Work `protobuf:"bytes,1,opt,name=work,oneof"`
}

func (*GetWorkResponse_Work) Equal 

func (this *GetWorkResponse_Work) Equal(that interface{}) bool

func (*GetWorkResponse_Work) GoString 

func (this *GetWorkResponse_Work) GoString() string

func (*GetWorkResponse_Work) MarshalTo 

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

func (*GetWorkResponse_Work) Size 

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

func (*GetWorkResponse_Work) String 

func (this *GetWorkResponse_Work) String() string

type HyperParams 

type HyperParams struct {
	// double proportion_clients = 1;
	BatchSize        int64   `protobuf:"varint,2,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	NumRounds        int64   `protobuf:"varint,3,opt,name=num_rounds,json=numRounds,proto3" json:"num_rounds,omitempty"`
	LearningRate     float64 `protobuf:"fixed64,4,opt,name=learning_rate,json=learningRate,proto3" json:"learning_rate,omitempty"`
	NumLocalRounds   int64   `protobuf:"varint,5,opt,name=num_local_rounds,json=numLocalRounds,proto3" json:"num_local_rounds,omitempty"`
	QuantizedUpdates bool    `protobuf:"varint,6,opt,name=quantized_updates,json=quantizedUpdates,proto3" json:"quantized_updates,omitempty"`
	NumClients       int64   `protobuf:"varint,7,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`
}

func (*HyperParams) Descriptor 

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

func (*HyperParams) Equal 

func (this *HyperParams) Equal(that interface{}) bool

func (*HyperParams) GetBatchSize 

func (m *HyperParams) GetBatchSize() int64

func (*HyperParams) GetLearningRate 

func (m *HyperParams) GetLearningRate() float64

func (*HyperParams) GetNumClients 

func (m *HyperParams) GetNumClients() int64

func (*HyperParams) GetNumLocalRounds 

func (m *HyperParams) GetNumLocalRounds() int64

func (*HyperParams) GetNumRounds 

func (m *HyperParams) GetNumRounds() int64

func (*HyperParams) GetQuantizedUpdates 

func (m *HyperParams) GetQuantizedUpdates() bool

func (*HyperParams) GoString 

func (this *HyperParams) GoString() string

func (*HyperParams) Marshal 

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

func (*HyperParams) MarshalTo 

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

func (*HyperParams) ProtoMessage 

func (*HyperParams) ProtoMessage()

func (*HyperParams) Reset 

func (m *HyperParams) Reset()

func (*HyperParams) Size 

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

func (*HyperParams) String 

func (this *HyperParams) String() string

func (*HyperParams) Unmarshal 

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

type ModelID 

type ModelID struct {
	Domain    string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	ModelType string `protobuf:"bytes,2,opt,name=model_type,json=modelType,proto3" json:"model_type,omitempty"`
	Id        uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
}

func (*ModelID) Descriptor 

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

func (*ModelID) Equal 

func (this *ModelID) Equal(that interface{}) bool

func (*ModelID) GetDomain 

func (m *ModelID) GetDomain() string

func (*ModelID) GetId 

func (m *ModelID) GetId() uint64

func (*ModelID) GetModelType 

func (m *ModelID) GetModelType() string

func (*ModelID) GoString 

func (this *ModelID) GoString() string

func (*ModelID) Marshal 

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

func (*ModelID) MarshalTo 

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

func (*ModelID) ProtoMessage 

func (*ModelID) ProtoMessage()

func (*ModelID) Reset 

func (m *ModelID) Reset()

func (*ModelID) Size 

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

func (*ModelID) String 

func (this *ModelID) String() string

func (*ModelID) Unmarshal 

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

type ModelTypeAllocation 

type ModelTypeAllocation struct {
	ModelType ModelID `protobuf:"bytes,1,opt,name=model_type,json=modelType" json:"model_type"`
	Addr      string  `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
}

func (*ModelTypeAllocation) Descriptor 

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

func (*ModelTypeAllocation) Equal 

func (this *ModelTypeAllocation) Equal(that interface{}) bool

func (*ModelTypeAllocation) GetAddr 

func (m *ModelTypeAllocation) GetAddr() string

func (*ModelTypeAllocation) GetModelType 

func (m *ModelTypeAllocation) GetModelType() ModelID

func (*ModelTypeAllocation) GoString 

func (this *ModelTypeAllocation) GoString() string

func (*ModelTypeAllocation) Marshal 

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

func (*ModelTypeAllocation) MarshalTo 

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

func (*ModelTypeAllocation) ProtoMessage 

func (*ModelTypeAllocation) ProtoMessage()

func (*ModelTypeAllocation) Reset 

func (m *ModelTypeAllocation) Reset()

func (*ModelTypeAllocation) Size 

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

func (*ModelTypeAllocation) String 

func (this *ModelTypeAllocation) String() string

func (*ModelTypeAllocation) Unmarshal 

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

type ModelURLRequest 

type ModelURLRequest struct {
	Id ModelID `protobuf:"bytes,1,opt,name=id" json:"id"`
}

func (*ModelURLRequest) Descriptor 

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

func (*ModelURLRequest) Equal 

func (this *ModelURLRequest) Equal(that interface{}) bool

func (*ModelURLRequest) GetId 

func (m *ModelURLRequest) GetId() ModelID

func (*ModelURLRequest) GoString 

func (this *ModelURLRequest) GoString() string

func (*ModelURLRequest) Marshal 

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

func (*ModelURLRequest) MarshalTo 

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

func (*ModelURLRequest) ProtoMessage 

func (*ModelURLRequest) ProtoMessage()

func (*ModelURLRequest) Reset 

func (m *ModelURLRequest) Reset()

func (*ModelURLRequest) Size 

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

func (*ModelURLRequest) String 

func (this *ModelURLRequest) String() string

func (*ModelURLRequest) Unmarshal 

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

type ModelURLResponse 

type ModelURLResponse struct {
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
}

func (*ModelURLResponse) Descriptor 

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

func (*ModelURLResponse) Equal 

func (this *ModelURLResponse) Equal(that interface{}) bool

func (*ModelURLResponse) GetUrl 

func (m *ModelURLResponse) GetUrl() string

func (*ModelURLResponse) GoString 

func (this *ModelURLResponse) GoString() string

func (*ModelURLResponse) Marshal 

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

func (*ModelURLResponse) MarshalTo 

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

func (*ModelURLResponse) ProtoMessage 

func (*ModelURLResponse) ProtoMessage()

func (*ModelURLResponse) Reset 

func (m *ModelURLResponse) Reset()

func (*ModelURLResponse) Size 

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

func (*ModelURLResponse) String 

func (this *ModelURLResponse) String() string

func (*ModelURLResponse) Unmarshal 

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

type ModelWeightChunk 

type ModelWeightChunk struct {
	Body []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	More bool   `protobuf:"varint,2,opt,name=more,proto3" json:"more,omitempty"`
	// id is the chunk number.
	Id uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
}

func (*ModelWeightChunk) Descriptor 

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

func (*ModelWeightChunk) Equal 

func (this *ModelWeightChunk) Equal(that interface{}) bool

func (*ModelWeightChunk) GetBody 

func (m *ModelWeightChunk) GetBody() []byte

func (*ModelWeightChunk) GetId 

func (m *ModelWeightChunk) GetId() uint64

func (*ModelWeightChunk) GetMore 

func (m *ModelWeightChunk) GetMore() bool

func (*ModelWeightChunk) GoString 

func (this *ModelWeightChunk) GoString() string

func (*ModelWeightChunk) Marshal 

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

func (*ModelWeightChunk) MarshalTo 

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

func (*ModelWeightChunk) ProtoMessage 

func (*ModelWeightChunk) ProtoMessage()

func (*ModelWeightChunk) Reset 

func (m *ModelWeightChunk) Reset()

func (*ModelWeightChunk) Size 

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

func (*ModelWeightChunk) String 

func (this *ModelWeightChunk) String() string

func (*ModelWeightChunk) Unmarshal 

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

type NotifyRequest 

type NotifyRequest struct {
	Id ModelID `protobuf:"bytes,1,opt,name=id" json:"id"`
}

func (*NotifyRequest) Descriptor 

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

func (*NotifyRequest) Equal 

func (this *NotifyRequest) Equal(that interface{}) bool

func (*NotifyRequest) GetId 

func (m *NotifyRequest) GetId() ModelID

func (*NotifyRequest) GoString 

func (this *NotifyRequest) GoString() string

func (*NotifyRequest) Marshal 

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

func (*NotifyRequest) MarshalTo 

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

func (*NotifyRequest) ProtoMessage 

func (*NotifyRequest) ProtoMessage()

func (*NotifyRequest) Reset 

func (m *NotifyRequest) Reset()

func (*NotifyRequest) Size 

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

func (*NotifyRequest) String 

func (this *NotifyRequest) String() string

func (*NotifyRequest) Unmarshal 

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

type NotifyResponse 

type NotifyResponse struct {
}

func (*NotifyResponse) Descriptor 

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

func (*NotifyResponse) Equal 

func (this *NotifyResponse) Equal(that interface{}) bool

func (*NotifyResponse) GoString 

func (this *NotifyResponse) GoString() string

func (*NotifyResponse) Marshal 

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

func (*NotifyResponse) MarshalTo 

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

func (*NotifyResponse) ProtoMessage 

func (*NotifyResponse) ProtoMessage()

func (*NotifyResponse) Reset 

func (m *NotifyResponse) Reset()

func (*NotifyResponse) Size 

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

func (*NotifyResponse) String 

func (this *NotifyResponse) String() string

func (*NotifyResponse) Unmarshal 

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

type ProdModelRequest 

type ProdModelRequest struct {
	Id ModelID `protobuf:"bytes,1,opt,name=id" json:"id"`
}

func (*ProdModelRequest) Descriptor 

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

func (*ProdModelRequest) Equal 

func (this *ProdModelRequest) Equal(that interface{}) bool

func (*ProdModelRequest) GetId 

func (m *ProdModelRequest) GetId() ModelID

func (*ProdModelRequest) GoString 

func (this *ProdModelRequest) GoString() string

func (*ProdModelRequest) Marshal 

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

func (*ProdModelRequest) MarshalTo 

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

func (*ProdModelRequest) ProtoMessage 

func (*ProdModelRequest) ProtoMessage()

func (*ProdModelRequest) Reset 

func (m *ProdModelRequest) Reset()

func (*ProdModelRequest) Size 

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

func (*ProdModelRequest) String 

func (this *ProdModelRequest) String() string

func (*ProdModelRequest) Unmarshal 

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

type ProdModelResponse 

type ProdModelResponse struct {
	Id ModelID `protobuf:"bytes,3,opt,name=id" json:"id"`
}

func (*ProdModelResponse) Descriptor 

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

func (*ProdModelResponse) Equal 

func (this *ProdModelResponse) Equal(that interface{}) bool

func (*ProdModelResponse) GetId 

func (m *ProdModelResponse) GetId() ModelID

func (*ProdModelResponse) GoString 

func (this *ProdModelResponse) GoString() string

func (*ProdModelResponse) Marshal 

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

func (*ProdModelResponse) MarshalTo 

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

func (*ProdModelResponse) ProtoMessage 

func (*ProdModelResponse) ProtoMessage()

func (*ProdModelResponse) Reset 

func (m *ProdModelResponse) Reset()

func (*ProdModelResponse) Size 

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

func (*ProdModelResponse) String 

func (this *ProdModelResponse) String() string

func (*ProdModelResponse) Unmarshal 

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

type Repeat 

type Repeat int32
const (
	NEVER   Repeat = 0
	HOURLY  Repeat = 1
	DAILY   Repeat = 2
	WEEKLY  Repeat = 3
	MONTHLY Repeat = 4
)

func (Repeat) EnumDescriptor 

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

func (Repeat) String 

func (x Repeat) String() string

type ReportErrorRequest 

type ReportErrorRequest struct {
	Errors []Error `protobuf:"bytes,1,rep,name=errors" json:"errors"`
}

func (*ReportErrorRequest) Descriptor 

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

func (*ReportErrorRequest) Equal 

func (this *ReportErrorRequest) Equal(that interface{}) bool

func (*ReportErrorRequest) GetErrors 

func (m *ReportErrorRequest) GetErrors() []Error

func (*ReportErrorRequest) GoString 

func (this *ReportErrorRequest) GoString() string

func (*ReportErrorRequest) Marshal 

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

func (*ReportErrorRequest) MarshalTo 

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

func (*ReportErrorRequest) ProtoMessage 

func (*ReportErrorRequest) ProtoMessage()

func (*ReportErrorRequest) Reset 

func (m *ReportErrorRequest) Reset()

func (*ReportErrorRequest) Size 

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

func (*ReportErrorRequest) String 

func (this *ReportErrorRequest) String() string

func (*ReportErrorRequest) Unmarshal 

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

type ReportErrorResponse 

type ReportErrorResponse struct {
}

func (*ReportErrorResponse) Descriptor 

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

func (*ReportErrorResponse) Equal 

func (this *ReportErrorResponse) Equal(that interface{}) bool

func (*ReportErrorResponse) GoString 

func (this *ReportErrorResponse) GoString() string

func (*ReportErrorResponse) Marshal 

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

func (*ReportErrorResponse) MarshalTo 

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

func (*ReportErrorResponse) ProtoMessage 

func (*ReportErrorResponse) ProtoMessage()

func (*ReportErrorResponse) Reset 

func (m *ReportErrorResponse) Reset()

func (*ReportErrorResponse) Size 

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

func (*ReportErrorResponse) String 

func (this *ReportErrorResponse) String() string

func (*ReportErrorResponse) Unmarshal 

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

type ReportWorkRequest 

type ReportWorkRequest struct {
	// Types that are valid to be assigned to Type:
	//	*ReportWorkRequest_Work
	//	*ReportWorkRequest_Weights
	Type isReportWorkRequest_Type `protobuf_oneof:"type"`
}

func (*ReportWorkRequest) Descriptor 

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

func (*ReportWorkRequest) Equal 

func (this *ReportWorkRequest) Equal(that interface{}) bool

func (*ReportWorkRequest) GetType 

func (m *ReportWorkRequest) GetType() isReportWorkRequest_Type

func (*ReportWorkRequest) GetWeights 

func (m *ReportWorkRequest) GetWeights() *ModelWeightChunk

func (*ReportWorkRequest) GetWork 

func (m *ReportWorkRequest) GetWork() *Work

func (*ReportWorkRequest) GoString 

func (this *ReportWorkRequest) GoString() string

func (*ReportWorkRequest) Marshal 

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

func (*ReportWorkRequest) MarshalTo 

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

func (*ReportWorkRequest) ProtoMessage 

func (*ReportWorkRequest) ProtoMessage()

func (*ReportWorkRequest) Reset 

func (m *ReportWorkRequest) Reset()

func (*ReportWorkRequest) Size 

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

func (*ReportWorkRequest) String 

func (this *ReportWorkRequest) String() string

func (*ReportWorkRequest) Unmarshal 

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

func (*ReportWorkRequest) XXX_OneofFuncs 

func (*ReportWorkRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ReportWorkRequest_Weights 

type ReportWorkRequest_Weights struct {
	Weights *ModelWeightChunk `protobuf:"bytes,2,opt,name=weights,oneof"`
}

func (*ReportWorkRequest_Weights) Equal 

func (this *ReportWorkRequest_Weights) Equal(that interface{}) bool

func (*ReportWorkRequest_Weights) GoString 

func (this *ReportWorkRequest_Weights) GoString() string

func (*ReportWorkRequest_Weights) MarshalTo 

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

func (*ReportWorkRequest_Weights) Size 

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

func (*ReportWorkRequest_Weights) String 

func (this *ReportWorkRequest_Weights) String() string

type ReportWorkRequest_Work 

type ReportWorkRequest_Work struct {
	Work *Work `protobuf:"bytes,1,opt,name=work,oneof"`
}

func (*ReportWorkRequest_Work) Equal 

func (this *ReportWorkRequest_Work) Equal(that interface{}) bool

func (*ReportWorkRequest_Work) GoString 

func (this *ReportWorkRequest_Work) GoString() string

func (*ReportWorkRequest_Work) MarshalTo 

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

func (*ReportWorkRequest_Work) Size 

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

func (*ReportWorkRequest_Work) String 

func (this *ReportWorkRequest_Work) String() string

type ReportWorkResponse 

type ReportWorkResponse struct {
}

func (*ReportWorkResponse) Descriptor 

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

func (*ReportWorkResponse) Equal 

func (this *ReportWorkResponse) Equal(that interface{}) bool

func (*ReportWorkResponse) GoString 

func (this *ReportWorkResponse) GoString() string

func (*ReportWorkResponse) Marshal 

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

func (*ReportWorkResponse) MarshalTo 

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

func (*ReportWorkResponse) ProtoMessage 

func (*ReportWorkResponse) ProtoMessage()

func (*ReportWorkResponse) Reset 

func (m *ReportWorkResponse) Reset()

func (*ReportWorkResponse) Size 

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

func (*ReportWorkResponse) String 

func (this *ReportWorkResponse) String() string

func (*ReportWorkResponse) Unmarshal 

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

type SchedulingInfo 

type SchedulingInfo struct {
	Scheduled *time.Time `protobuf:"bytes,1,opt,name=scheduled,stdtime" json:"scheduled,omitempty"`
	Repeat    Repeat     `protobuf:"varint,2,opt,name=repeat,proto3,enum=aggregatorpb.Repeat" json:"repeat,omitempty"`
}

func (*SchedulingInfo) Descriptor 

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

func (*SchedulingInfo) Equal 

func (this *SchedulingInfo) Equal(that interface{}) bool

func (*SchedulingInfo) GetRepeat 

func (m *SchedulingInfo) GetRepeat() Repeat

func (*SchedulingInfo) GetScheduled 

func (m *SchedulingInfo) GetScheduled() *time.Time

func (*SchedulingInfo) GoString 

func (this *SchedulingInfo) GoString() string

func (*SchedulingInfo) Marshal 

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

func (*SchedulingInfo) MarshalTo 

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

func (*SchedulingInfo) ProtoMessage 

func (*SchedulingInfo) ProtoMessage()

func (*SchedulingInfo) Reset 

func (m *SchedulingInfo) Reset()

func (*SchedulingInfo) Size 

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

func (*SchedulingInfo) String 

func (this *SchedulingInfo) String() string

func (*SchedulingInfo) Unmarshal 

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

type TrainingStatus 

type TrainingStatus int32
const (
	SCHEDULED TrainingStatus = 0
	TRAINING  TrainingStatus = 1
	SUCCEEDED TrainingStatus = 2
	FAILED    TrainingStatus = 3
	CANCELED  TrainingStatus = 4
)

func (TrainingStatus) EnumDescriptor 

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

func (TrainingStatus) String 

func (x TrainingStatus) String() string

type Work 

type Work struct {
	Id          ModelID `protobuf:"bytes,1,opt,name=id" json:"id"`
	NumExamples int64   `protobuf:"varint,2,opt,name=num_examples,json=numExamples,proto3" json:"num_examples,omitempty"`
	NumClients  int64   `protobuf:"varint,3,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`
	Epoch       int64   `protobuf:"varint,4,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// TODO(d4l3k): consider sending a link to GCS instead of the raw model.
	HyperParams HyperParams `protobuf:"bytes,7,opt,name=hyper_params,json=hyperParams" json:"hyper_params"`
	// time_taken is amount of time in seconds it took to process this work.
	TimeTaken float64 `protobuf:"fixed64,8,opt,name=time_taken,json=timeTaken,proto3" json:"time_taken,omitempty"`
	// started is when the training job was started.
	Started time.Time `protobuf:"bytes,11,opt,name=started,stdtime" json:"started"`
	// metrics are the values produced by the model defined metrics.
	Metrics []float64 `protobuf:"fixed64,9,rep,packed,name=metrics" json:"metrics,omitempty"`
}

func (*Work) Descriptor 

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

func (*Work) Equal 

func (this *Work) Equal(that interface{}) bool

func (*Work) GetEpoch 

func (m *Work) GetEpoch() int64

func (*Work) GetHyperParams 

func (m *Work) GetHyperParams() HyperParams

func (*Work) GetId 

func (m *Work) GetId() ModelID

func (*Work) GetMetrics 

func (m *Work) GetMetrics() []float64

func (*Work) GetNumClients 

func (m *Work) GetNumClients() int64

func (*Work) GetNumExamples 

func (m *Work) GetNumExamples() int64

func (*Work) GetStarted 

func (m *Work) GetStarted() time.Time

func (*Work) GetTimeTaken 

func (m *Work) GetTimeTaken() float64

func (*Work) GoString 

func (this *Work) GoString() string

func (*Work) Marshal 

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

func (*Work) MarshalTo 

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

func (*Work) ProtoMessage 

func (*Work) ProtoMessage()

func (*Work) Reset 

func (m *Work) Reset()

func (*Work) Size 

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

func (*Work) String 

func (this *Work) String() string

func (*Work) Unmarshal 

func (m *Work) Unmarshal(dAtA []byte) 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.