grpc

package
v3.3.2 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: AGPL-3.0 Imports: 11 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")
)

Functions

func RegisterCompactorServer 

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

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 DeleteRequest 

type DeleteRequest struct {
	RequestID string `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"`
	StartTime int64  `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime   int64  `protobuf:"varint,3,opt,name=endTime,proto3" json:"endTime,omitempty"`
	Query     string `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	Status    string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	CreatedAt int64  `protobuf:"varint,6,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) Equal 

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

func (*DeleteRequest) GetCreatedAt 

func (m *DeleteRequest) GetCreatedAt() int64

func (*DeleteRequest) GetEndTime 

func (m *DeleteRequest) GetEndTime() int64

func (*DeleteRequest) GetQuery 

func (m *DeleteRequest) GetQuery() string

func (*DeleteRequest) GetRequestID 

func (m *DeleteRequest) GetRequestID() string

func (*DeleteRequest) GetStartTime 

func (m *DeleteRequest) GetStartTime() int64

func (*DeleteRequest) GetStatus 

func (m *DeleteRequest) GetStatus() string

func (*DeleteRequest) GoString 

func (this *DeleteRequest) GoString() string

func (*DeleteRequest) Marshal 

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

func (*DeleteRequest) MarshalTo 

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

func (*DeleteRequest) MarshalToSizedBuffer 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

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

func (*DeleteRequest) String 

func (this *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

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

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

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 {
}

func (*GetDeleteRequestsRequest) Descriptor 

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

func (*GetDeleteRequestsRequest) Equal 

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

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 []*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() []*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 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)

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.