Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + var ErrIntOverflowGrpc = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthGrpc = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterCompactorServer(s *grpc.Server, srv CompactorServer) + type CompactorClient interface + GetCacheGenNumbers func(ctx context.Context, in *GetCacheGenNumbersRequest, opts ...grpc.CallOption) (*GetCacheGenNumbersResponse, error) + GetDeleteRequests func(ctx context.Context, in *GetDeleteRequestsRequest, opts ...grpc.CallOption) (*GetDeleteRequestsResponse, error) + func NewCompactorClient(cc *grpc.ClientConn) CompactorClient + type CompactorServer interface + GetCacheGenNumbers func(context.Context, *GetCacheGenNumbersRequest) (*GetCacheGenNumbersResponse, error) + GetDeleteRequests func(context.Context, *GetDeleteRequestsRequest) (*GetDeleteRequestsResponse, error) + type DeleteRequest struct + CreatedAt int64 + EndTime int64 + Query string + RequestID string + StartTime int64 + Status string + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (m *DeleteRequest) GetCreatedAt() int64 + func (m *DeleteRequest) GetEndTime() int64 + func (m *DeleteRequest) GetQuery() string + func (m *DeleteRequest) GetRequestID() string + func (m *DeleteRequest) GetStartTime() int64 + func (m *DeleteRequest) GetStatus() string + func (m *DeleteRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteRequest) Reset() + func (m *DeleteRequest) Size() (n int) + func (m *DeleteRequest) Unmarshal(dAtA []byte) error + func (m *DeleteRequest) XXX_DiscardUnknown() + func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteRequest) XXX_Merge(src proto.Message) + func (m *DeleteRequest) XXX_Size() int + func (m *DeleteRequest) XXX_Unmarshal(b []byte) error + func (this *DeleteRequest) Equal(that interface{}) bool + func (this *DeleteRequest) GoString() string + func (this *DeleteRequest) String() string + type GetCacheGenNumbersRequest struct + func (*GetCacheGenNumbersRequest) Descriptor() ([]byte, []int) + func (*GetCacheGenNumbersRequest) ProtoMessage() + func (m *GetCacheGenNumbersRequest) Marshal() (dAtA []byte, err error) + func (m *GetCacheGenNumbersRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetCacheGenNumbersRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetCacheGenNumbersRequest) Reset() + func (m *GetCacheGenNumbersRequest) Size() (n int) + func (m *GetCacheGenNumbersRequest) Unmarshal(dAtA []byte) error + func (m *GetCacheGenNumbersRequest) XXX_DiscardUnknown() + func (m *GetCacheGenNumbersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetCacheGenNumbersRequest) XXX_Merge(src proto.Message) + func (m *GetCacheGenNumbersRequest) XXX_Size() int + func (m *GetCacheGenNumbersRequest) XXX_Unmarshal(b []byte) error + func (this *GetCacheGenNumbersRequest) Equal(that interface{}) bool + func (this *GetCacheGenNumbersRequest) GoString() string + func (this *GetCacheGenNumbersRequest) String() string + type GetCacheGenNumbersResponse struct + ResultsCacheGen string + func (*GetCacheGenNumbersResponse) Descriptor() ([]byte, []int) + func (*GetCacheGenNumbersResponse) ProtoMessage() + func (m *GetCacheGenNumbersResponse) GetResultsCacheGen() string + func (m *GetCacheGenNumbersResponse) Marshal() (dAtA []byte, err error) + func (m *GetCacheGenNumbersResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetCacheGenNumbersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetCacheGenNumbersResponse) Reset() + func (m *GetCacheGenNumbersResponse) Size() (n int) + func (m *GetCacheGenNumbersResponse) Unmarshal(dAtA []byte) error + func (m *GetCacheGenNumbersResponse) XXX_DiscardUnknown() + func (m *GetCacheGenNumbersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetCacheGenNumbersResponse) XXX_Merge(src proto.Message) + func (m *GetCacheGenNumbersResponse) XXX_Size() int + func (m *GetCacheGenNumbersResponse) XXX_Unmarshal(b []byte) error + func (this *GetCacheGenNumbersResponse) Equal(that interface{}) bool + func (this *GetCacheGenNumbersResponse) GoString() string + func (this *GetCacheGenNumbersResponse) String() string + type GetDeleteRequestsRequest struct + func (*GetDeleteRequestsRequest) Descriptor() ([]byte, []int) + func (*GetDeleteRequestsRequest) ProtoMessage() + func (m *GetDeleteRequestsRequest) Marshal() (dAtA []byte, err error) + func (m *GetDeleteRequestsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetDeleteRequestsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetDeleteRequestsRequest) Reset() + func (m *GetDeleteRequestsRequest) Size() (n int) + func (m *GetDeleteRequestsRequest) Unmarshal(dAtA []byte) error + func (m *GetDeleteRequestsRequest) XXX_DiscardUnknown() + func (m *GetDeleteRequestsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetDeleteRequestsRequest) XXX_Merge(src proto.Message) + func (m *GetDeleteRequestsRequest) XXX_Size() int + func (m *GetDeleteRequestsRequest) XXX_Unmarshal(b []byte) error + func (this *GetDeleteRequestsRequest) Equal(that interface{}) bool + func (this *GetDeleteRequestsRequest) GoString() string + func (this *GetDeleteRequestsRequest) String() string + type GetDeleteRequestsResponse struct + DeleteRequests []*DeleteRequest + func (*GetDeleteRequestsResponse) Descriptor() ([]byte, []int) + func (*GetDeleteRequestsResponse) ProtoMessage() + func (m *GetDeleteRequestsResponse) GetDeleteRequests() []*DeleteRequest + func (m *GetDeleteRequestsResponse) Marshal() (dAtA []byte, err error) + func (m *GetDeleteRequestsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetDeleteRequestsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetDeleteRequestsResponse) Reset() + func (m *GetDeleteRequestsResponse) Size() (n int) + func (m *GetDeleteRequestsResponse) Unmarshal(dAtA []byte) error + func (m *GetDeleteRequestsResponse) XXX_DiscardUnknown() + func (m *GetDeleteRequestsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetDeleteRequestsResponse) XXX_Merge(src proto.Message) + func (m *GetDeleteRequestsResponse) XXX_Size() int + func (m *GetDeleteRequestsResponse) XXX_Unmarshal(b []byte) error + func (this *GetDeleteRequestsResponse) Equal(that interface{}) bool + func (this *GetDeleteRequestsResponse) GoString() string + func (this *GetDeleteRequestsResponse) String() string + type UnimplementedCompactorServer struct + func (*UnimplementedCompactorServer) GetCacheGenNumbers(ctx context.Context, req *GetCacheGenNumbersRequest) (*GetCacheGenNumbersResponse, error) + func (*UnimplementedCompactorServer) GetDeleteRequests(ctx context.Context, req *GetDeleteRequestsRequest) (*GetDeleteRequestsResponse, error)