grpc

package
v3.7.2 Latest Latest
Warning

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

 Go to latest Published: May 13, 2026 License: AGPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthGrpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGrpc   = fmt.Errorf("proto: integer overflow")
)
View Source 
var JobType_name = map[int32]string{
	0: "JOB_TYPE_DELETION",
}
View Source 
var JobType_value = map[string]int32{
	"JOB_TYPE_DELETION": 0,
}

Functions

func RegisterCompactorServer 

func RegisterCompactorServer(s *grpc.Server, srv CompactorServer)

func RegisterJobQueueServer added in v3.6.0 

func RegisterJobQueueServer(s *grpc.Server, srv JobQueueServer)

Types

type CompactorClient 

type CompactorClient interface {
	GetDeleteRequests(ctx context.Context, in *GetDeleteRequestsRequest, opts ...grpc.CallOption) (*GetDeleteRequestsResponse, error)
	GetCacheGenNumbers(ctx context.Context, in *GetCacheGenNumbersRequest, opts ...grpc.CallOption) (*GetCacheGenNumbersResponse, error)
}

CompactorClient is the client API for Compactor service.

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

func NewCompactorClient 

func NewCompactorClient(cc *grpc.ClientConn) CompactorClient

type CompactorServer 

type CompactorServer interface {
	GetDeleteRequests(context.Context, *GetDeleteRequestsRequest) (*GetDeleteRequestsResponse, error)
	GetCacheGenNumbers(context.Context, *GetCacheGenNumbersRequest) (*GetCacheGenNumbersResponse, error)
}

CompactorServer is the server API for Compactor service.

type GetCacheGenNumbersRequest 

type GetCacheGenNumbersRequest struct {
}

func (*GetCacheGenNumbersRequest) Descriptor 

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

func (*GetCacheGenNumbersRequest) Equal 

func (this *GetCacheGenNumbersRequest) Equal(that interface{}) bool

func (*GetCacheGenNumbersRequest) GoString 

func (this *GetCacheGenNumbersRequest) GoString() string

func (*GetCacheGenNumbersRequest) Marshal 

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

func (*GetCacheGenNumbersRequest) MarshalTo 

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

func (*GetCacheGenNumbersRequest) MarshalToSizedBuffer 

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

func (*GetCacheGenNumbersRequest) ProtoMessage 

func (*GetCacheGenNumbersRequest) ProtoMessage()

func (*GetCacheGenNumbersRequest) Reset 

func (m *GetCacheGenNumbersRequest) Reset()

func (*GetCacheGenNumbersRequest) Size 

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

func (*GetCacheGenNumbersRequest) String 

func (this *GetCacheGenNumbersRequest) String() string

func (*GetCacheGenNumbersRequest) Unmarshal 

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

func (*GetCacheGenNumbersRequest) XXX_DiscardUnknown 

func (m *GetCacheGenNumbersRequest) XXX_DiscardUnknown()

func (*GetCacheGenNumbersRequest) XXX_Marshal 

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

func (*GetCacheGenNumbersRequest) XXX_Merge 

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

func (*GetCacheGenNumbersRequest) XXX_Size 

func (m *GetCacheGenNumbersRequest) XXX_Size() int

func (*GetCacheGenNumbersRequest) XXX_Unmarshal 

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

type GetCacheGenNumbersResponse 

type GetCacheGenNumbersResponse struct {
	ResultsCacheGen string `protobuf:"bytes,1,opt,name=resultsCacheGen,proto3" json:"resultsCacheGen,omitempty"`
}

func (*GetCacheGenNumbersResponse) Descriptor 

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

func (*GetCacheGenNumbersResponse) Equal 

func (this *GetCacheGenNumbersResponse) Equal(that interface{}) bool

func (*GetCacheGenNumbersResponse) GetResultsCacheGen 

func (m *GetCacheGenNumbersResponse) GetResultsCacheGen() string

func (*GetCacheGenNumbersResponse) GoString 

func (this *GetCacheGenNumbersResponse) GoString() string

func (*GetCacheGenNumbersResponse) Marshal 

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

func (*GetCacheGenNumbersResponse) MarshalTo 

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

func (*GetCacheGenNumbersResponse) MarshalToSizedBuffer 

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

func (*GetCacheGenNumbersResponse) ProtoMessage 

func (*GetCacheGenNumbersResponse) ProtoMessage()

func (*GetCacheGenNumbersResponse) Reset 

func (m *GetCacheGenNumbersResponse) Reset()

func (*GetCacheGenNumbersResponse) Size 

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

func (*GetCacheGenNumbersResponse) String 

func (this *GetCacheGenNumbersResponse) String() string

func (*GetCacheGenNumbersResponse) Unmarshal 

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

func (*GetCacheGenNumbersResponse) XXX_DiscardUnknown 

func (m *GetCacheGenNumbersResponse) XXX_DiscardUnknown()

func (*GetCacheGenNumbersResponse) XXX_Marshal 

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

func (*GetCacheGenNumbersResponse) XXX_Merge 

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

func (*GetCacheGenNumbersResponse) XXX_Size 

func (m *GetCacheGenNumbersResponse) XXX_Size() int

func (*GetCacheGenNumbersResponse) XXX_Unmarshal 

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

type GetDeleteRequestsRequest 

type GetDeleteRequestsRequest struct {
	ForQuerytimeFiltering bool `protobuf:"varint,1,opt,name=forQuerytimeFiltering,proto3" json:"forQuerytimeFiltering,omitempty"`
	// Time range for overlap filtering. If present, only returns delete requests
	// that overlap with the given time range.
	StartTime time.Time `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time"`
	EndTime   time.Time `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time"`
}

func (*GetDeleteRequestsRequest) Descriptor 

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

func (*GetDeleteRequestsRequest) Equal 

func (this *GetDeleteRequestsRequest) Equal(that interface{}) bool

func (*GetDeleteRequestsRequest) GetEndTime added in v3.7.0 

func (m *GetDeleteRequestsRequest) GetEndTime() time.Time

func (*GetDeleteRequestsRequest) GetForQuerytimeFiltering added in v3.5.0 

func (m *GetDeleteRequestsRequest) GetForQuerytimeFiltering() bool

func (*GetDeleteRequestsRequest) GetStartTime added in v3.7.0 

func (m *GetDeleteRequestsRequest) GetStartTime() time.Time

func (*GetDeleteRequestsRequest) GoString 

func (this *GetDeleteRequestsRequest) GoString() string

func (*GetDeleteRequestsRequest) Marshal 

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

func (*GetDeleteRequestsRequest) MarshalTo 

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

func (*GetDeleteRequestsRequest) MarshalToSizedBuffer 

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

func (*GetDeleteRequestsRequest) ProtoMessage 

func (*GetDeleteRequestsRequest) ProtoMessage()

func (*GetDeleteRequestsRequest) Reset 

func (m *GetDeleteRequestsRequest) Reset()

func (*GetDeleteRequestsRequest) Size 

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

func (*GetDeleteRequestsRequest) String 

func (this *GetDeleteRequestsRequest) String() string

func (*GetDeleteRequestsRequest) Unmarshal 

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

func (*GetDeleteRequestsRequest) XXX_DiscardUnknown 

func (m *GetDeleteRequestsRequest) XXX_DiscardUnknown()

func (*GetDeleteRequestsRequest) XXX_Marshal 

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

func (*GetDeleteRequestsRequest) XXX_Merge 

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

func (*GetDeleteRequestsRequest) XXX_Size 

func (m *GetDeleteRequestsRequest) XXX_Size() int

func (*GetDeleteRequestsRequest) XXX_Unmarshal 

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

type GetDeleteRequestsResponse 

type GetDeleteRequestsResponse struct {
	DeleteRequests []*deletionproto.DeleteRequest `protobuf:"bytes,1,rep,name=deleteRequests,proto3" json:"deleteRequests,omitempty"`
}

func (*GetDeleteRequestsResponse) Descriptor 

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

func (*GetDeleteRequestsResponse) Equal 

func (this *GetDeleteRequestsResponse) Equal(that interface{}) bool

func (*GetDeleteRequestsResponse) GetDeleteRequests 

func (m *GetDeleteRequestsResponse) GetDeleteRequests() []*deletionproto.DeleteRequest

func (*GetDeleteRequestsResponse) GoString 

func (this *GetDeleteRequestsResponse) GoString() string

func (*GetDeleteRequestsResponse) Marshal 

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

func (*GetDeleteRequestsResponse) MarshalTo 

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

func (*GetDeleteRequestsResponse) MarshalToSizedBuffer 

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

func (*GetDeleteRequestsResponse) ProtoMessage 

func (*GetDeleteRequestsResponse) ProtoMessage()

func (*GetDeleteRequestsResponse) Reset 

func (m *GetDeleteRequestsResponse) Reset()

func (*GetDeleteRequestsResponse) Size 

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

func (*GetDeleteRequestsResponse) String 

func (this *GetDeleteRequestsResponse) String() string

func (*GetDeleteRequestsResponse) Unmarshal 

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

func (*GetDeleteRequestsResponse) XXX_DiscardUnknown 

func (m *GetDeleteRequestsResponse) XXX_DiscardUnknown()

func (*GetDeleteRequestsResponse) XXX_Marshal 

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

func (*GetDeleteRequestsResponse) XXX_Merge 

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

func (*GetDeleteRequestsResponse) XXX_Size 

func (m *GetDeleteRequestsResponse) XXX_Size() int

func (*GetDeleteRequestsResponse) XXX_Unmarshal 

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

type Job added in v3.6.0 

type Job struct {
	Id      string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type    JobType `protobuf:"varint,2,opt,name=type,proto3,enum=grpc.JobType" json:"type,omitempty"`
	Payload []byte  `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
}

Job represents a single job in the queue

func (*Job) Descriptor added in v3.6.0 

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

func (*Job) Equal added in v3.6.0 

func (this *Job) Equal(that interface{}) bool

func (*Job) GetId added in v3.6.0 

func (m *Job) GetId() string

func (*Job) GetPayload added in v3.6.0 

func (m *Job) GetPayload() []byte

func (*Job) GetType added in v3.6.0 

func (m *Job) GetType() JobType

func (*Job) GoString added in v3.6.0 

func (this *Job) GoString() string

func (*Job) Marshal added in v3.6.0 

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

func (*Job) MarshalTo added in v3.6.0 

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

func (*Job) MarshalToSizedBuffer added in v3.6.0 

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

func (*Job) ProtoMessage added in v3.6.0 

func (*Job) ProtoMessage()

func (*Job) Reset added in v3.6.0 

func (m *Job) Reset()

func (*Job) Size added in v3.6.0 

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

func (*Job) String added in v3.6.0 

func (this *Job) String() string

func (*Job) Unmarshal added in v3.6.0 

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

func (*Job) XXX_DiscardUnknown added in v3.6.0 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal added in v3.6.0 

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

func (*Job) XXX_Merge added in v3.6.0 

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

func (*Job) XXX_Size added in v3.6.0 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal added in v3.6.0 

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

type JobQueueClient added in v3.6.0 

type JobQueueClient interface {
	// After calling this method, both Worker and JobQueue enter a loop, in which worker waits for
	// "Job" messages containing job details and processes them. After processing the job,
	// worker signals that it is ready to accept another one by sending JobResult message which contains execution result of previous job it finished.
	// Since the Worker and JobQueue enter the loop when Worker makes the first call so the JobResult with the first call is expected to be empty.
	Loop(ctx context.Context, opts ...grpc.CallOption) (JobQueue_LoopClient, error)
}

JobQueueClient is the client API for JobQueue service.

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

func NewJobQueueClient added in v3.6.0 

func NewJobQueueClient(cc *grpc.ClientConn) JobQueueClient

type JobQueueServer added in v3.6.0 

type JobQueueServer interface {
	// After calling this method, both Worker and JobQueue enter a loop, in which worker waits for
	// "Job" messages containing job details and processes them. After processing the job,
	// worker signals that it is ready to accept another one by sending JobResult message which contains execution result of previous job it finished.
	// Since the Worker and JobQueue enter the loop when Worker makes the first call so the JobResult with the first call is expected to be empty.
	Loop(JobQueue_LoopServer) error
}

JobQueueServer is the server API for JobQueue service.

type JobQueue_LoopClient added in v3.6.0 

type JobQueue_LoopClient interface {
	Send(*JobResult) error
	Recv() (*Job, error)
	grpc.ClientStream
}

type JobQueue_LoopServer added in v3.6.0 

type JobQueue_LoopServer interface {
	Send(*Job) error
	Recv() (*JobResult, error)
	grpc.ServerStream
}

type JobResult added in v3.6.0 

type JobResult struct {
	JobId   string  `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	JobType JobType `protobuf:"varint,2,opt,name=job_type,json=jobType,proto3,enum=grpc.JobType" json:"job_type,omitempty"`
	Error   string  `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Result  []byte  `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
}

JobResult is used to report the result of executing a job

func (*JobResult) Descriptor added in v3.6.0 

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

func (*JobResult) Equal added in v3.6.0 

func (this *JobResult) Equal(that interface{}) bool

func (*JobResult) GetError added in v3.6.0 

func (m *JobResult) GetError() string

func (*JobResult) GetJobId added in v3.6.0 

func (m *JobResult) GetJobId() string

func (*JobResult) GetJobType added in v3.6.0 

func (m *JobResult) GetJobType() JobType

func (*JobResult) GetResult added in v3.6.0 

func (m *JobResult) GetResult() []byte

func (*JobResult) GoString added in v3.6.0 

func (this *JobResult) GoString() string

func (*JobResult) Marshal added in v3.6.0 

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

func (*JobResult) MarshalTo added in v3.6.0 

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

func (*JobResult) MarshalToSizedBuffer added in v3.6.0 

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

func (*JobResult) ProtoMessage added in v3.6.0 

func (*JobResult) ProtoMessage()

func (*JobResult) Reset added in v3.6.0 

func (m *JobResult) Reset()

func (*JobResult) Size added in v3.6.0 

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

func (*JobResult) String added in v3.6.0 

func (this *JobResult) String() string

func (*JobResult) Unmarshal added in v3.6.0 

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

func (*JobResult) XXX_DiscardUnknown added in v3.6.0 

func (m *JobResult) XXX_DiscardUnknown()

func (*JobResult) XXX_Marshal added in v3.6.0 

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

func (*JobResult) XXX_Merge added in v3.6.0 

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

func (*JobResult) XXX_Size added in v3.6.0 

func (m *JobResult) XXX_Size() int

func (*JobResult) XXX_Unmarshal added in v3.6.0 

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

type JobType added in v3.6.0 

type JobType int32

JobType represents the type of job 

const (
	JOB_TYPE_DELETION JobType = 0
)

func (JobType) EnumDescriptor added in v3.6.0 

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

func (JobType) Humanize added in v3.6.0 

func (x JobType) Humanize() string

Humanize returns a more human-friendly string form of job types.

func (JobType) String added in v3.6.0 

func (x JobType) String() string

type ReportJobResultResponse added in v3.6.0 

type ReportJobResultResponse struct {
}

ReportJobResultResponse is the response to reporting a job result

func (*ReportJobResultResponse) Descriptor added in v3.6.0 

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

func (*ReportJobResultResponse) Equal added in v3.6.0 

func (this *ReportJobResultResponse) Equal(that interface{}) bool

func (*ReportJobResultResponse) GoString added in v3.6.0 

func (this *ReportJobResultResponse) GoString() string

func (*ReportJobResultResponse) Marshal added in v3.6.0 

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

func (*ReportJobResultResponse) MarshalTo added in v3.6.0 

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

func (*ReportJobResultResponse) MarshalToSizedBuffer added in v3.6.0 

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

func (*ReportJobResultResponse) ProtoMessage added in v3.6.0 

func (*ReportJobResultResponse) ProtoMessage()

func (*ReportJobResultResponse) Reset added in v3.6.0 

func (m *ReportJobResultResponse) Reset()

func (*ReportJobResultResponse) Size added in v3.6.0 

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

func (*ReportJobResultResponse) String added in v3.6.0 

func (this *ReportJobResultResponse) String() string

func (*ReportJobResultResponse) Unmarshal added in v3.6.0 

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

func (*ReportJobResultResponse) XXX_DiscardUnknown added in v3.6.0 

func (m *ReportJobResultResponse) XXX_DiscardUnknown()

func (*ReportJobResultResponse) XXX_Marshal added in v3.6.0 

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

func (*ReportJobResultResponse) XXX_Merge added in v3.6.0 

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

func (*ReportJobResultResponse) XXX_Size added in v3.6.0 

func (m *ReportJobResultResponse) XXX_Size() int

func (*ReportJobResultResponse) XXX_Unmarshal added in v3.6.0 

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

type UnimplementedCompactorServer 

type UnimplementedCompactorServer struct {
}

UnimplementedCompactorServer can be embedded to have forward compatible implementations.

func (*UnimplementedCompactorServer) GetCacheGenNumbers 

func (*UnimplementedCompactorServer) GetCacheGenNumbers(ctx context.Context, req *GetCacheGenNumbersRequest) (*GetCacheGenNumbersResponse, error)

func (*UnimplementedCompactorServer) GetDeleteRequests 

func (*UnimplementedCompactorServer) GetDeleteRequests(ctx context.Context, req *GetDeleteRequestsRequest) (*GetDeleteRequestsResponse, error)

type UnimplementedJobQueueServer added in v3.6.0 

type UnimplementedJobQueueServer struct {
}

UnimplementedJobQueueServer can be embedded to have forward compatible implementations.

func (*UnimplementedJobQueueServer) Loop added in v3.6.0 

func (*UnimplementedJobQueueServer) Loop(srv JobQueue_LoopServer) error

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.