proto

type AgentClient interface {
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Scale(ctx context.Context, in *ScaleRequest, opts ...grpc.CallOption) (*ScaleResponse, error)
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeResponse, error)
}

type AgentServer interface {
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	Scale(context.Context, *ScaleRequest) (*ScaleResponse, error)
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	Invoke(context.Context, *InvokeRequest) (*InvokeResponse, error)
	// contains filtered or unexported methods
}

type Archive struct {
	Name         string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Remote       string    `protobuf:"bytes,2,opt,name=remote,proto3" json:"remote,omitempty"`
	Local        string    `protobuf:"bytes,3,opt,name=local,proto3" json:"local,omitempty"`
	Env          string    `protobuf:"bytes,4,opt,name=env,proto3" json:"env,omitempty"`
	BatchSize    int32     `protobuf:"varint,5,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	Dependencies []string  `protobuf:"bytes,6,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	Workers      []*Worker `protobuf:"bytes,7,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

type CreateRequest struct {
	Name         string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Remote       string   `protobuf:"bytes,2,opt,name=remote,proto3" json:"remote,omitempty"`
	Local        string   `protobuf:"bytes,3,opt,name=local,proto3" json:"local,omitempty"`
	Environ      string   `protobuf:"bytes,4,opt,name=environ,proto3" json:"environ,omitempty"`
	Dependencies []string `protobuf:"bytes,5,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	Replicas     int32    `protobuf:"varint,6,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

type CreateResponse struct {
	Archive *Archive `protobuf:"bytes,1,opt,name=archive,proto3" json:"archive,omitempty"`
	// contains filtered or unexported fields
}

type DeleteRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteResponse struct {
	// contains filtered or unexported fields
}

type Input struct {
	Id      string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Headers map[string]string `` /* 155-byte string literal not displayed */
	Input   map[string][]byte `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

type InvokeRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// Types that are assignable to Value:
	//	*InvokeRequest_Input
	Value isInvokeRequest_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type InvokeRequest_Input struct {
	Input *Input `protobuf:"bytes,3,opt,name=input,proto3,oneof"`
}

type InvokeResponse struct {
	Output *Output `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

type ListRequest struct {
	// contains filtered or unexported fields
}

type ListResponse struct {
	Archives []*Archive `protobuf:"bytes,1,rep,name=archives,proto3" json:"archives,omitempty"`
	// contains filtered or unexported fields
}

type LoadRequest struct {
	Where string `protobuf:"bytes,1,opt,name=where,proto3" json:"where,omitempty"`
	Gpuid int64  `protobuf:"varint,2,opt,name=gpuid,proto3" json:"gpuid,omitempty"`
	// contains filtered or unexported fields
}

type LoadResponse struct {
	Duration int64 `protobuf:"varint,1,opt,name=duration,proto3" json:"duration,omitempty"`
	Memory   int64 `protobuf:"varint,2,opt,name=memory,proto3" json:"memory,omitempty"`
	// contains filtered or unexported fields
}

type Output struct {
	Id         string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Template   string            `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
	Prediction []byte            `protobuf:"bytes,3,opt,name=prediction,proto3" json:"prediction,omitempty"`
	Headers    map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

type PredictRequest struct {
	Name  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Batch []*Input `protobuf:"bytes,2,rep,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

type PredictResponse struct {
	Batch []*Output `protobuf:"bytes,1,rep,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

type ReadRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type ReadResponse struct {
	Archive *Archive `protobuf:"bytes,1,opt,name=archive,proto3" json:"archive,omitempty"`
	// contains filtered or unexported fields
}

type ScaleRequest struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Replicas int32  `protobuf:"varint,2,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

type ScaleResponse struct {
	// contains filtered or unexported fields
}

type SyncRequest struct {
	Environ      string   `protobuf:"bytes,1,opt,name=environ,proto3" json:"environ,omitempty"`
	Dependencies []string `protobuf:"bytes,2,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

type SyncResponse struct {
	// contains filtered or unexported fields
}

type UnimplementedAgentServer struct {
}

type UnsafeAgentServer interface {
	// contains filtered or unexported methods
}

type Worker struct {
	Id     uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Uptime int64  `protobuf:"varint,2,opt,name=uptime,proto3" json:"uptime,omitempty"`
	Memory int64  `protobuf:"varint,3,opt,name=memory,proto3" json:"memory,omitempty"`
	Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	Gpu    bool   `protobuf:"varint,5,opt,name=gpu,proto3" json:"gpu,omitempty"`
	// contains filtered or unexported fields
}