jobspb

Documentation

Overview

Package jobspb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

• func RegisterJobServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
• func RegisterJobServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobServiceClient) error
• func RegisterJobServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
• func RegisterJobServiceServer(s *grpc.Server, srv JobServiceServer)
• type JobServiceClient
  • func NewJobServiceClient(cc *grpc.ClientConn) JobServiceClient
• type JobServiceServer
• type JobStatusRequest
  • func (*JobStatusRequest) Descriptor() ([]byte, []int)
  • func (m *JobStatusRequest) GetJobId() string
  • func (*JobStatusRequest) ProtoMessage()
  • func (m *JobStatusRequest) Reset()
  • func (m *JobStatusRequest) String() string
  • 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) GetLastUpdated() *timestamp.Timestamp
  • func (m *JobStatusResponse) GetMessage() string
  • func (m *JobStatusResponse) GetStatus() string
  • func (*JobStatusResponse) ProtoMessage()
  • func (m *JobStatusResponse) Reset()
  • func (m *JobStatusResponse) String() string
  • 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

Functions

func RegisterJobServiceHandler

func RegisterJobServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterJobServiceHandler registers the http handlers for service JobService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterJobServiceHandlerClient

func RegisterJobServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobServiceClient) error

RegisterJobServiceHandlerClient registers the http handlers for service JobService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "JobServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "JobServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "JobServiceClient" to call the correct interceptors.

func RegisterJobServiceHandlerFromEndpoint

func RegisterJobServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterJobServiceHandlerFromEndpoint is same as RegisterJobServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterJobServiceServer

func RegisterJobServiceServer(s *grpc.Server, srv JobServiceServer)

Types

type JobServiceClient

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

JobServiceClient is the client API for JobService service.

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

func NewJobServiceClient

func NewJobServiceClient(cc *grpc.ClientConn) JobServiceClient

type JobServiceServer

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

JobServiceServer is the server API for JobService service.

type JobStatusRequest

type JobStatusRequest struct {
	JobId                string   `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobStatusRequest) Descriptor

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

func (*JobStatusRequest) GetJobId

func (m *JobStatusRequest) GetJobId() string

func (*JobStatusRequest) ProtoMessage

func (*JobStatusRequest) ProtoMessage()

func (*JobStatusRequest) Reset

func (m *JobStatusRequest) Reset()

func (*JobStatusRequest) String

func (m *JobStatusRequest) String() string

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:"job_id,omitempty"`
	Status               string               `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Message              string               `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	LastUpdated          *timestamp.Timestamp `protobuf:"bytes,4,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*JobStatusResponse) Descriptor

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

func (*JobStatusResponse) GetJobId

func (m *JobStatusResponse) GetJobId() string

func (*JobStatusResponse) GetLastUpdated

func (m *JobStatusResponse) GetLastUpdated() *timestamp.Timestamp

func (*JobStatusResponse) GetMessage

func (m *JobStatusResponse) GetMessage() string

func (*JobStatusResponse) GetStatus

func (m *JobStatusResponse) GetStatus() string

func (*JobStatusResponse) ProtoMessage

func (*JobStatusResponse) ProtoMessage()

func (*JobStatusResponse) Reset

func (m *JobStatusResponse) Reset()

func (*JobStatusResponse) String

func (m *JobStatusResponse) String() string

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