status

Documentation

Index

• Variables
• func RegisterStatusServiceServer(s grpc.ServiceRegistrar, srv StatusServiceServer)
• type Status
  • func (Status) Descriptor() protoreflect.EnumDescriptor
  • func (x Status) Enum() *Status
  • func (Status) EnumDescriptor() ([]byte, []int)
  • func (x Status) Number() protoreflect.EnumNumber
  • func (x Status) String() string
  • func (Status) Type() protoreflect.EnumType
• type StatusRequest
  • func (*StatusRequest) Descriptor() ([]byte, []int)
  • func (x *StatusRequest) GetCmd() string
  • func (x *StatusRequest) GetPodIndex() string
  • func (x *StatusRequest) GetTaskProgress() *TaskProgress
  • func (x *StatusRequest) GetTimestamp() *timestamppb.Timestamp
  • func (*StatusRequest) ProtoMessage()
  • func (x *StatusRequest) ProtoReflect() protoreflect.Message
  • func (x *StatusRequest) Reset()
  • func (x *StatusRequest) String() string
• type StatusResponse
  • func (*StatusResponse) Descriptor() ([]byte, []int)
  • func (*StatusResponse) ProtoMessage()
  • func (x *StatusResponse) ProtoReflect() protoreflect.Message
  • func (x *StatusResponse) Reset()
  • func (x *StatusResponse) String() string
• type StatusServiceClient
  • func NewStatusServiceClient(cc grpc.ClientConnInterface) StatusServiceClient
• type StatusServiceServer
• type TaskProgress
  • func (*TaskProgress) Descriptor() ([]byte, []int)
  • func (x *TaskProgress) GetProgress() int64
  • func (x *TaskProgress) GetStatus() Status
  • func (*TaskProgress) ProtoMessage()
  • func (x *TaskProgress) ProtoReflect() protoreflect.Message
  • func (x *TaskProgress) Reset()
  • func (x *TaskProgress) String() string
• type UnimplementedStatusServiceServer
  • func (UnimplementedStatusServiceServer) SendWorkerStatus(context.Context, *StatusRequest) (*StatusResponse, error)
• type UnsafeStatusServiceServer

Variables

var (
	Status_name = map[int32]string{
		0: "STARTED",
		1: "RUNNING",
		2: "FINISHED",
		3: "FAILED",
		4: "CANCELLED",
		5: "UNKNOWN",
	}
	Status_value = map[string]int32{
		"STARTED":   0,
		"RUNNING":   1,
		"FINISHED":  2,
		"FAILED":    3,
		"CANCELLED": 4,
		"UNKNOWN":   5,
	}
)

Enum value maps for Status.

var File_proto_manager_status_service_proto protoreflect.FileDescriptor

var StatusService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "status.StatusService",
	HandlerType: (*StatusServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendWorkerStatus",
			Handler:    _StatusService_SendWorkerStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/manager/status/service.proto",
}

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

Functions

func RegisterStatusServiceServer

func RegisterStatusServiceServer(s grpc.ServiceRegistrar, srv StatusServiceServer)

Types

type Status

type Status int32

const (
	Status_STARTED   Status = 0
	Status_RUNNING   Status = 1
	Status_FINISHED  Status = 2
	Status_FAILED    Status = 3
	Status_CANCELLED Status = 4
	Status_UNKNOWN   Status = 5
)

func (Status) Descriptor

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum

func (x Status) Enum() *Status

func (Status) EnumDescriptor

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number

func (x Status) Number() protoreflect.EnumNumber

func (Status) String

func (x Status) String() string

func (Status) Type

func (Status) Type() protoreflect.EnumType

type StatusRequest

type StatusRequest struct {
	PodIndex     string                 `protobuf:"bytes,1,opt,name=pod_index,json=podIndex,proto3" json:"pod_index,omitempty"`
	Cmd          string                 `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	Timestamp    *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	TaskProgress *TaskProgress          `protobuf:"bytes,4,opt,name=task_progress,json=taskProgress,proto3" json:"task_progress,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetCmd

func (x *StatusRequest) GetCmd() string

func (*StatusRequest) GetPodIndex

func (x *StatusRequest) GetPodIndex() string

func (*StatusRequest) GetTaskProgress

func (x *StatusRequest) GetTaskProgress() *TaskProgress

func (*StatusRequest) GetTimestamp

func (x *StatusRequest) GetTimestamp() *timestamppb.Timestamp

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 {
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

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 StatusServiceClient

type StatusServiceClient interface {
	SendWorkerStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

StatusServiceClient is the client API for StatusService 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 NewStatusServiceClient

func NewStatusServiceClient(cc grpc.ClientConnInterface) StatusServiceClient

type StatusServiceServer

type StatusServiceServer interface {
	SendWorkerStatus(context.Context, *StatusRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

StatusServiceServer is the server API for StatusService service. All implementations must embed UnimplementedStatusServiceServer for forward compatibility

type TaskProgress

type TaskProgress struct {
	Status   Status `protobuf:"varint,1,opt,name=status,proto3,enum=status.Status" json:"status,omitempty"`
	Progress int64  `protobuf:"varint,2,opt,name=progress,proto3" json:"progress,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskProgress) Descriptor

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

Deprecated: Use TaskProgress.ProtoReflect.Descriptor instead.

func (*TaskProgress) GetProgress

func (x *TaskProgress) GetProgress() int64

func (*TaskProgress) GetStatus

func (x *TaskProgress) GetStatus() Status

func (*TaskProgress) ProtoMessage

func (*TaskProgress) ProtoMessage()

func (*TaskProgress) ProtoReflect

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

func (*TaskProgress) Reset

func (x *TaskProgress) Reset()

func (*TaskProgress) String

func (x *TaskProgress) String() string

type UnimplementedStatusServiceServer

type UnimplementedStatusServiceServer struct {
}

UnimplementedStatusServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStatusServiceServer) SendWorkerStatus

func (UnimplementedStatusServiceServer) SendWorkerStatus(context.Context, *StatusRequest) (*StatusResponse, error)

type UnsafeStatusServiceServer

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

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