queryapi

Documentation

Index

• Variables
• func RegisterQueryApiServer(s *grpc.Server, srv QueryApiServer)
• type JobStatus
  • func (JobStatus) EnumDescriptor() ([]byte, []int)
  • func (x JobStatus) String() string
• type JobStatusRequest
  • func (*JobStatusRequest) Descriptor() ([]byte, []int)
  • func (m *JobStatusRequest) GetJobId() string
  • func (m *JobStatusRequest) Marshal() (dAtA []byte, err error)
  • func (m *JobStatusRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *JobStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*JobStatusRequest) ProtoMessage()
  • func (m *JobStatusRequest) Reset()
  • func (m *JobStatusRequest) Size() (n int)
  • func (this *JobStatusRequest) String() string
  • func (m *JobStatusRequest) Unmarshal(dAtA []byte) error
  • func (m *JobStatusRequest) XXX_DiscardUnknown()
  • func (m *JobStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *JobStatusRequest) XXX_Merge(src proto.Message)
  • func (m *JobStatusRequest) XXX_Size() int
  • func (m *JobStatusRequest) XXX_Unmarshal(b []byte) error
• type JobStatusResponse
  • func (*JobStatusResponse) Descriptor() ([]byte, []int)
  • func (m *JobStatusResponse) GetJobId() string
  • func (m *JobStatusResponse) GetJobStatus() JobStatus
  • func (m *JobStatusResponse) Marshal() (dAtA []byte, err error)
  • func (m *JobStatusResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *JobStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*JobStatusResponse) ProtoMessage()
  • func (m *JobStatusResponse) Reset()
  • func (m *JobStatusResponse) Size() (n int)
  • func (this *JobStatusResponse) String() string
  • func (m *JobStatusResponse) Unmarshal(dAtA []byte) error
  • func (m *JobStatusResponse) XXX_DiscardUnknown()
  • func (m *JobStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *JobStatusResponse) XXX_Merge(src proto.Message)
  • func (m *JobStatusResponse) XXX_Size() int
  • func (m *JobStatusResponse) XXX_Unmarshal(b []byte) error
• type QueryApiClient
  • func NewQueryApiClient(cc *grpc.ClientConn) QueryApiClient
• type QueryApiServer
• type UnimplementedQueryApiServer
  • func (*UnimplementedQueryApiServer) GetJobStatus(ctx context.Context, req *JobStatusRequest) (*JobStatusResponse, error)

Variables

var (
	ErrInvalidLengthQueryapi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueryapi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueryapi = fmt.Errorf("proto: unexpected end of group")
)

var JobStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SUBMITTED",
	2: "QUEUED",
	3: "LEASED",
	4: "PENDING",
	5: "RUNNING",
	6: "SUCCEEDED",
	7: "FAILED",
	8: "PREEMPTED",
	9: "CANCELLED",
}

var JobStatus_value = map[string]int32{
	"UNKNOWN":   0,
	"SUBMITTED": 1,
	"QUEUED":    2,
	"LEASED":    3,
	"PENDING":   4,
	"RUNNING":   5,
	"SUCCEEDED": 6,
	"FAILED":    7,
	"PREEMPTED": 8,
	"CANCELLED": 9,
}

Functions

func RegisterQueryApiServer

func RegisterQueryApiServer(s *grpc.Server, srv QueryApiServer)

Types

type JobStatus

type JobStatus int32

const (
	JobStatus_UNKNOWN   JobStatus = 0
	JobStatus_SUBMITTED JobStatus = 1
	JobStatus_QUEUED    JobStatus = 2
	JobStatus_LEASED    JobStatus = 3
	JobStatus_PENDING   JobStatus = 4
	JobStatus_RUNNING   JobStatus = 5
	JobStatus_SUCCEEDED JobStatus = 6
	JobStatus_FAILED    JobStatus = 7
	JobStatus_PREEMPTED JobStatus = 8
	JobStatus_CANCELLED JobStatus = 9
)

func (JobStatus) EnumDescriptor

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

func (JobStatus) String

func (x JobStatus) String() string

type JobStatusRequest

type JobStatusRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
}

func (*JobStatusRequest) Descriptor

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

func (*JobStatusRequest) GetJobId

func (m *JobStatusRequest) GetJobId() string

func (*JobStatusRequest) Marshal

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

func (*JobStatusRequest) MarshalTo

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

func (*JobStatusRequest) MarshalToSizedBuffer

func (m *JobStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobStatusRequest) ProtoMessage

func (*JobStatusRequest) ProtoMessage()

func (*JobStatusRequest) Reset

func (m *JobStatusRequest) Reset()

func (*JobStatusRequest) Size

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

func (*JobStatusRequest) String

func (this *JobStatusRequest) String() string

func (*JobStatusRequest) Unmarshal

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

func (*JobStatusRequest) XXX_DiscardUnknown

func (m *JobStatusRequest) XXX_DiscardUnknown()

func (*JobStatusRequest) XXX_Marshal

func (m *JobStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobStatusRequest) XXX_Merge

func (m *JobStatusRequest) XXX_Merge(src proto.Message)

func (*JobStatusRequest) XXX_Size

func (m *JobStatusRequest) XXX_Size() int

func (*JobStatusRequest) XXX_Unmarshal

func (m *JobStatusRequest) XXX_Unmarshal(b []byte) error

type JobStatusResponse

type JobStatusResponse struct {
	JobId     string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobStatus JobStatus `protobuf:"varint,2,opt,name=job_status,json=jobStatus,proto3,enum=queryapi.JobStatus" json:"jobStatus,omitempty"`
}

func (*JobStatusResponse) Descriptor

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

func (*JobStatusResponse) GetJobId

func (m *JobStatusResponse) GetJobId() string

func (*JobStatusResponse) GetJobStatus

func (m *JobStatusResponse) GetJobStatus() JobStatus

func (*JobStatusResponse) Marshal

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

func (*JobStatusResponse) MarshalTo

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

func (*JobStatusResponse) MarshalToSizedBuffer

func (m *JobStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobStatusResponse) ProtoMessage

func (*JobStatusResponse) ProtoMessage()

func (*JobStatusResponse) Reset

func (m *JobStatusResponse) Reset()

func (*JobStatusResponse) Size

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

func (*JobStatusResponse) String

func (this *JobStatusResponse) String() string

func (*JobStatusResponse) Unmarshal

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

func (*JobStatusResponse) XXX_DiscardUnknown

func (m *JobStatusResponse) XXX_DiscardUnknown()

func (*JobStatusResponse) XXX_Marshal

func (m *JobStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobStatusResponse) XXX_Merge

func (m *JobStatusResponse) XXX_Merge(src proto.Message)

func (*JobStatusResponse) XXX_Size

func (m *JobStatusResponse) XXX_Size() int

func (*JobStatusResponse) XXX_Unmarshal

func (m *JobStatusResponse) XXX_Unmarshal(b []byte) error

type QueryApiClient

type QueryApiClient interface {
	GetJobStatus(ctx context.Context, in *JobStatusRequest, opts ...grpc.CallOption) (*JobStatusResponse, error)
}

QueryApiClient is the client API for QueryApi service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryApiClient

func NewQueryApiClient(cc *grpc.ClientConn) QueryApiClient

type QueryApiServer

type QueryApiServer interface {
	GetJobStatus(context.Context, *JobStatusRequest) (*JobStatusResponse, error)
}

QueryApiServer is the server API for QueryApi service.

type UnimplementedQueryApiServer

type UnimplementedQueryApiServer struct {
}

UnimplementedQueryApiServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryApiServer) GetJobStatus

func (*UnimplementedQueryApiServer) GetJobStatus(ctx context.Context, req *JobStatusRequest) (*JobStatusResponse, error)