v1alpha1

package
v0.0.0-...-7f4ff7b Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	StatusCondition_name = map[int32]string{
		0: "UNKNOWN",
		1: "FALSE",
		2: "TRUE",
	}
	StatusCondition_value = map[string]int32{
		"UNKNOWN": 0,
		"FALSE":   1,
		"TRUE":    2,
	}
)

Enum value maps for StatusCondition.

View Source 
var File_flaap_taskstore_proto protoreflect.FileDescriptor
View Source 
var TasksService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flaap.v1alpha1.TasksService",
	HandlerType: (*TasksServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _TasksService_Create_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _TasksService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _TasksService_List_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _TasksService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _TasksService_Delete_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _TasksService_Status_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "flaap/taskstore.proto",
}

TasksService_ServiceDesc is the grpc.ServiceDesc for TasksService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTasksServiceServer 

func RegisterTasksServiceServer(s grpc.ServiceRegistrar, srv TasksServiceServer)

Types

type Condition 

type Condition struct {
	Type   string          `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Status StatusCondition `protobuf:"varint,2,opt,name=status,proto3,enum=flaap.v1alpha1.StatusCondition" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Condition) Descriptor deprecated 

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

Deprecated: Use Condition.ProtoReflect.Descriptor instead.

func (*Condition) GetStatus 

func (x *Condition) GetStatus() StatusCondition

func (*Condition) GetType 

func (x *Condition) GetType() string

func (*Condition) ProtoMessage 

func (*Condition) ProtoMessage()

func (*Condition) ProtoReflect 

func (x *Condition) ProtoReflect() protoreflect.Message

func (*Condition) Reset 

func (x *Condition) Reset()

func (*Condition) String 

func (x *Condition) String() string

type CreateRequest 

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

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetTask 

func (x *CreateRequest) GetTask() *Task

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

func (x *CreateRequest) ProtoReflect() protoreflect.Message

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

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

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetTask 

func (x *CreateResponse) GetTask() *Task

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

func (x *CreateResponse) ProtoReflect() protoreflect.Message

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type DeleteRequest 

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

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetName 

func (x *DeleteRequest) GetName() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

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

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

func (x *DeleteResponse) ProtoReflect() protoreflect.Message

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type GetRequest 

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

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetName 

func (x *GetRequest) GetName() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

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

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetTask 

func (x *GetResponse) GetTask() *Task

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type ListRequest 

type ListRequest struct {

	// If specified only list the tasks assigned to this worker.
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// If set only return tasks for which the status of the Done condition is True.
	// If false return tasks for which Done condition is False or Unknown
	// TODO(jeremy): The naming/design is akward. The intent is to be able to filter tasks by the done condition so that we can only request tasks
	// which aren't done
	Done bool `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetDone 

func (x *ListRequest) GetDone() bool

func (*ListRequest) GetWorkerId 

func (x *ListRequest) GetWorkerId() string

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

func (x *ListRequest) ProtoReflect() protoreflect.Message

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

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

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetItems 

func (x *ListResponse) GetItems() []*Task

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

func (x *ListResponse) ProtoReflect() protoreflect.Message

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type Metadata 

type Metadata struct {
	Name            string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels          map[string]string `` /* 153-byte string literal not displayed */
	ResourceVersion string            `protobuf:"bytes,3,opt,name=resourceVersion,proto3" json:"resourceVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetLabels 

func (x *Metadata) GetLabels() map[string]string

func (*Metadata) GetName 

func (x *Metadata) GetName() string

func (*Metadata) GetResourceVersion 

func (x *Metadata) GetResourceVersion() string

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type Selector 

type Selector struct {
	MatchLabels map[string]string `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Selector) Descriptor deprecated 

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

Deprecated: Use Selector.ProtoReflect.Descriptor instead.

func (*Selector) GetMatchLabels 

func (x *Selector) GetMatchLabels() map[string]string

func (*Selector) ProtoMessage 

func (*Selector) ProtoMessage()

func (*Selector) ProtoReflect 

func (x *Selector) ProtoReflect() protoreflect.Message

func (*Selector) Reset 

func (x *Selector) Reset()

func (*Selector) String 

func (x *Selector) String() string

type StatusCondition 

type StatusCondition int32
const (
	StatusCondition_UNKNOWN StatusCondition = 0
	StatusCondition_FALSE   StatusCondition = 1
	StatusCondition_TRUE    StatusCondition = 2
)

func (StatusCondition) Descriptor 

func (StatusCondition) Descriptor() protoreflect.EnumDescriptor

func (StatusCondition) Enum 

func (x StatusCondition) Enum() *StatusCondition

func (StatusCondition) EnumDescriptor deprecated 

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

Deprecated: Use StatusCondition.Descriptor instead.

func (StatusCondition) Number 

func (x StatusCondition) Number() protoreflect.EnumNumber

func (StatusCondition) String 

func (x StatusCondition) String() string

func (StatusCondition) Type 

func (StatusCondition) Type() protoreflect.EnumType

type StatusRequest 

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

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

func (x *StatusRequest) ProtoReflect() protoreflect.Message

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {

	// Groups assigned to workers.
	GroupAssignments map[string]string `` /* 197-byte string literal not displayed */
	// Count of the number of tasks keyed by the status.
	TaskMetrics map[string]int32 `` /* 183-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetGroupAssignments 

func (x *StatusResponse) GetGroupAssignments() map[string]string

func (*StatusResponse) GetTaskMetrics 

func (x *StatusResponse) GetTaskMetrics() map[string]int32

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

func (x *StatusResponse) ProtoReflect() protoreflect.Message

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type StoredData 

type StoredData struct {
	Tasks            []*Task           `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	GroupAssignments map[string]string `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

StoredData is used to serialize the data inside the filestore.

func (*StoredData) Descriptor deprecated 

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

Deprecated: Use StoredData.ProtoReflect.Descriptor instead.

func (*StoredData) GetGroupAssignments 

func (x *StoredData) GetGroupAssignments() map[string]string

func (*StoredData) GetTasks 

func (x *StoredData) GetTasks() []*Task

func (*StoredData) ProtoMessage 

func (*StoredData) ProtoMessage()

func (*StoredData) ProtoReflect 

func (x *StoredData) ProtoReflect() protoreflect.Message

func (*StoredData) Reset 

func (x *StoredData) Reset()

func (*StoredData) String 

func (x *StoredData) String() string

type Task 

type Task struct {
	ApiVersion string      `protobuf:"bytes,1,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	Kind       string      `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Metadata   *Metadata   `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Input      *TaskInput  `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	Output     *TaskOutput `protobuf:"bytes,5,opt,name=output,proto3" json:"output,omitempty"`
	Status     *TaskStatus `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	// Result is a serialized tensorflow_federated.v0.Value
	// Its serialized so that Tasks can be deserialized without depending on the Value proto.
	// TODO(https://github.com/jlewi/flaap/issues/22): Get rid of result field.
	Result []byte `protobuf:"bytes,7,opt,name=result,proto3" json:"result,omitempty"`
	// group_nonce is used to distinguish tasks that should be handled by different clients.
	// tasks with different group_nonce should not be handled by the same client whereas tasks
	// with the same group_nonce may(should?) be processed by the same client.
	// nonce is used to indicate that values should be chosen randomly and treated opaquely.
	GroupNonce string `protobuf:"bytes,8,opt,name=group_nonce,json=groupNonce,proto3" json:"group_nonce,omitempty"`
	// group_index is used to order tasks within a group. Tasks with higher index value need to
	// be processed after lower index tasks.
	GroupIndex int32 `protobuf:"varint,9,opt,name=group_index,json=groupIndex,proto3" json:"group_index,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetApiVersion 

func (x *Task) GetApiVersion() string

func (*Task) GetGroupIndex 

func (x *Task) GetGroupIndex() int32

func (*Task) GetGroupNonce 

func (x *Task) GetGroupNonce() string

func (*Task) GetInput 

func (x *Task) GetInput() *TaskInput

func (*Task) GetKind 

func (x *Task) GetKind() string

func (*Task) GetMetadata 

func (x *Task) GetMetadata() *Metadata

func (*Task) GetOutput 

func (x *Task) GetOutput() *TaskOutput

func (*Task) GetResult 

func (x *Task) GetResult() []byte

func (*Task) GetStatus 

func (x *Task) GetStatus() *TaskStatus

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskInput 

type TaskInput struct {

	// ExecutorRequest encodes the request proto in
	// https://github.com/tensorflow/federated/blob/a6506385def304c260a424b29e5b34c6d905760e/tensorflow_federated/proto/v0/executor.proto
	// The serialized version of the proto is stored as bytes.
	// The reason for storing the seralized proto as bytes rather than using a typed field is because using a typed field
	// would require generating the TFF protos client libraries in whichever language we use (e.g GoLang). That would be better
	// but for now we punted on trying to plugging into TFF's build process to build golang protos.
	//
	// Types that are assignable to Request:
	//	*TaskInput_CreateValue
	//	*TaskInput_CreateCall
	//	*TaskInput_CreateStruct
	//	*TaskInput_CreateSelection
	//	*TaskInput_Compute
	//	*TaskInput_Dispose
	Request isTaskInput_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*TaskInput) Descriptor deprecated 

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

Deprecated: Use TaskInput.ProtoReflect.Descriptor instead.

func (*TaskInput) GetCompute 

func (x *TaskInput) GetCompute() []byte

func (*TaskInput) GetCreateCall 

func (x *TaskInput) GetCreateCall() []byte

func (*TaskInput) GetCreateSelection 

func (x *TaskInput) GetCreateSelection() []byte

func (*TaskInput) GetCreateStruct 

func (x *TaskInput) GetCreateStruct() []byte

func (*TaskInput) GetCreateValue 

func (x *TaskInput) GetCreateValue() []byte

func (*TaskInput) GetDispose 

func (x *TaskInput) GetDispose() []byte

func (*TaskInput) GetRequest 

func (m *TaskInput) GetRequest() isTaskInput_Request

func (*TaskInput) ProtoMessage 

func (*TaskInput) ProtoMessage()

func (*TaskInput) ProtoReflect 

func (x *TaskInput) ProtoReflect() protoreflect.Message

func (*TaskInput) Reset 

func (x *TaskInput) Reset()

func (*TaskInput) String 

func (x *TaskInput) String() string

type TaskInput_Compute 

type TaskInput_Compute struct {
	Compute []byte `protobuf:"bytes,5,opt,name=compute,proto3,oneof"`
}

type TaskInput_CreateCall 

type TaskInput_CreateCall struct {
	CreateCall []byte `protobuf:"bytes,2,opt,name=create_call,json=createCall,proto3,oneof"`
}

type TaskInput_CreateSelection 

type TaskInput_CreateSelection struct {
	CreateSelection []byte `protobuf:"bytes,4,opt,name=create_selection,json=createSelection,proto3,oneof"`
}

type TaskInput_CreateStruct 

type TaskInput_CreateStruct struct {
	CreateStruct []byte `protobuf:"bytes,3,opt,name=create_struct,json=createStruct,proto3,oneof"`
}

type TaskInput_CreateValue 

type TaskInput_CreateValue struct {
	CreateValue []byte `protobuf:"bytes,1,opt,name=create_value,json=createValue,proto3,oneof"`
}

type TaskInput_Dispose 

type TaskInput_Dispose struct {
	Dispose []byte `protobuf:"bytes,6,opt,name=dispose,proto3,oneof"`
}

type TaskOutput 

type TaskOutput struct {

	// Types that are assignable to Response:
	//	*TaskOutput_Compute
	//	*TaskOutput_Dispose
	Response isTaskOutput_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*TaskOutput) Descriptor deprecated 

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

Deprecated: Use TaskOutput.ProtoReflect.Descriptor instead.

func (*TaskOutput) GetCompute 

func (x *TaskOutput) GetCompute() []byte

func (*TaskOutput) GetDispose 

func (x *TaskOutput) GetDispose() []byte

func (*TaskOutput) GetResponse 

func (m *TaskOutput) GetResponse() isTaskOutput_Response

func (*TaskOutput) ProtoMessage 

func (*TaskOutput) ProtoMessage()

func (*TaskOutput) ProtoReflect 

func (x *TaskOutput) ProtoReflect() protoreflect.Message

func (*TaskOutput) Reset 

func (x *TaskOutput) Reset()

func (*TaskOutput) String 

func (x *TaskOutput) String() string

type TaskOutput_Compute 

type TaskOutput_Compute struct {
	Compute []byte `protobuf:"bytes,1,opt,name=compute,proto3,oneof"`
}

type TaskOutput_Dispose 

type TaskOutput_Dispose struct {
	// TODO(jeremy): Should dispose have a response?
	Dispose []byte `protobuf:"bytes,2,opt,name=dispose,proto3,oneof"`
}

type TaskStatus 

type TaskStatus struct {
	Conditions []*Condition `protobuf:"bytes,1,rep,name=conditions,proto3" json:"conditions,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStatus) Descriptor deprecated 

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

Deprecated: Use TaskStatus.ProtoReflect.Descriptor instead.

func (*TaskStatus) GetConditions 

func (x *TaskStatus) GetConditions() []*Condition

func (*TaskStatus) ProtoMessage 

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) ProtoReflect 

func (x *TaskStatus) ProtoReflect() protoreflect.Message

func (*TaskStatus) Reset 

func (x *TaskStatus) Reset()

func (*TaskStatus) String 

func (x *TaskStatus) String() string

type TasksServiceClient 

type TasksServiceClient interface {
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Status is used to monitor the status of the task service.
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

TasksServiceClient is the client API for TasksService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTasksServiceClient 

func NewTasksServiceClient(cc grpc.ClientConnInterface) TasksServiceClient

type TasksServiceServer 

type TasksServiceServer interface {
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Status is used to monitor the status of the task service.
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

TasksServiceServer is the server API for TasksService service. All implementations must embed UnimplementedTasksServiceServer for forward compatibility

type UnimplementedTasksServiceServer 

type UnimplementedTasksServiceServer struct {
}

UnimplementedTasksServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTasksServiceServer) Create 

func (UnimplementedTasksServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedTasksServiceServer) Delete 

func (UnimplementedTasksServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedTasksServiceServer) Get 

func (UnimplementedTasksServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedTasksServiceServer) List 

func (UnimplementedTasksServiceServer) List(context.Context, *ListRequest) (*ListResponse, error)

func (UnimplementedTasksServiceServer) Status 

func (UnimplementedTasksServiceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

func (UnimplementedTasksServiceServer) Update 

func (UnimplementedTasksServiceServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)

type UnsafeTasksServiceServer 

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

UnsafeTasksServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TasksServiceServer will result in compilation errors.

type UpdateRequest 

type UpdateRequest struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// Id of the worker sending the request. Used to verify that only that assigned worker updates the task.
	// Update departs from K8s convention because we need to provide the ID of the worker issuing the update
	// request. In principle that should be sent via a sidechannel (e.g. as part of Authn)  so it wouldn't
	// be in the body of the request.
	WorkerId string `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetTask 

func (x *UpdateRequest) GetTask() *Task

func (*UpdateRequest) GetWorkerId 

func (x *UpdateRequest) GetWorkerId() string

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect 

func (x *UpdateRequest) ProtoReflect() protoreflect.Message

func (*UpdateRequest) Reset 

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (x *UpdateRequest) String() string

type UpdateResponse 

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

func (*UpdateResponse) Descriptor deprecated 

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

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (*UpdateResponse) GetTask 

func (x *UpdateResponse) GetTask() *Task

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoReflect 

func (x *UpdateResponse) ProtoReflect() protoreflect.Message

func (*UpdateResponse) Reset 

func (x *UpdateResponse) Reset()

func (*UpdateResponse) String 

func (x *UpdateResponse) String() string

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.