grpc

package

Go to main page

Versions in this module

v0

v0.0.16

Oct 16, 2025

v0.0.15

Oct 16, 2025

Changes in this version

type CloudEvent

+ func CloudEventToProto(event cloudevent.CloudEvent[json.RawMessage]) *CloudEvent

type CloudEventHeader

+ Signature string

+ func CloudEventHeaderToProto(event *cloudevent.CloudEventHeader) *CloudEventHeader

+ func (x *CloudEventHeader) GetSignature() string

v0.0.14

Sep 15, 2025

Changes in this version

+ type AdvancedSearchOptions struct

+ After *timestamppb.Timestamp

+ Before *timestamppb.Timestamp

+ DataVersion *StringFilterOption

+ Extras *StringFilterOption

+ Id *StringFilterOption

+ Producer *StringFilterOption

+ Source *StringFilterOption

+ Subject *StringFilterOption

+ Tags *ArrayFilterOption

+ TimestampAsc *wrapperspb.BoolValue

+ Type *StringFilterOption

+ func (*AdvancedSearchOptions) Descriptor() ([]byte, []int)

+ func (*AdvancedSearchOptions) ProtoMessage()

+ func (x *AdvancedSearchOptions) GetAfter() *timestamppb.Timestamp

+ func (x *AdvancedSearchOptions) GetBefore() *timestamppb.Timestamp

+ func (x *AdvancedSearchOptions) GetDataVersion() *StringFilterOption

+ func (x *AdvancedSearchOptions) GetExtras() *StringFilterOption

+ func (x *AdvancedSearchOptions) GetId() *StringFilterOption

+ func (x *AdvancedSearchOptions) GetProducer() *StringFilterOption

+ func (x *AdvancedSearchOptions) GetSource() *StringFilterOption

+ func (x *AdvancedSearchOptions) GetSubject() *StringFilterOption

+ func (x *AdvancedSearchOptions) GetTags() *ArrayFilterOption

+ func (x *AdvancedSearchOptions) GetTimestampAsc() *wrapperspb.BoolValue

+ func (x *AdvancedSearchOptions) GetType() *StringFilterOption

+ func (x *AdvancedSearchOptions) ProtoReflect() protoreflect.Message

+ func (x *AdvancedSearchOptions) Reset()

+ func (x *AdvancedSearchOptions) String() string

+ type ArrayFilterOption struct

+ ContainsAll []string

+ ContainsAny []string

+ NotContainsAll []string

+ NotContainsAny []string

+ Or []*ArrayFilterOption

+ func (*ArrayFilterOption) Descriptor() ([]byte, []int)

+ func (*ArrayFilterOption) ProtoMessage()

+ func (x *ArrayFilterOption) GetContainsAll() []string

+ func (x *ArrayFilterOption) GetContainsAny() []string

+ func (x *ArrayFilterOption) GetNotContainsAll() []string

+ func (x *ArrayFilterOption) GetNotContainsAny() []string

+ func (x *ArrayFilterOption) GetOr() []*ArrayFilterOption

+ func (x *ArrayFilterOption) ProtoReflect() protoreflect.Message

+ func (x *ArrayFilterOption) Reset()

+ func (x *ArrayFilterOption) String() string

type CloudEventHeader

+ Tags []string

+ func (x *CloudEventHeader) GetTags() []string

type GetLatestCloudEventRequest

+ AdvancedOptions *AdvancedSearchOptions

+ func (x *GetLatestCloudEventRequest) GetAdvancedOptions() *AdvancedSearchOptions

type GetLatestIndexRequest

+ AdvancedOptions *AdvancedSearchOptions

+ func (x *GetLatestIndexRequest) GetAdvancedOptions() *AdvancedSearchOptions

type ListCloudEventsRequest

+ AdvancedOptions *AdvancedSearchOptions

+ func (x *ListCloudEventsRequest) GetAdvancedOptions() *AdvancedSearchOptions

type ListIndexesRequest

+ AdvancedOptions *AdvancedSearchOptions

+ func (x *ListIndexesRequest) GetAdvancedOptions() *AdvancedSearchOptions

+ type StringFilterOption struct

+ In []string

+ NotIn []string

+ Or []*StringFilterOption

+ func (*StringFilterOption) Descriptor() ([]byte, []int)

+ func (*StringFilterOption) ProtoMessage()

+ func (x *StringFilterOption) GetIn() []string

+ func (x *StringFilterOption) GetNotIn() []string

+ func (x *StringFilterOption) GetOr() []*StringFilterOption

+ func (x *StringFilterOption) ProtoReflect() protoreflect.Message

+ func (x *StringFilterOption) Reset()

+ func (x *StringFilterOption) String() string

v0.0.13

Aug 14, 2025

v0.0.12

May 20, 2025

Changes in this version

type SearchOptions

+ Id *wrapperspb.StringValue

+ func (x *SearchOptions) GetId() *wrapperspb.StringValue

v0.0.11

May 16, 2025

v0.0.10

Mar 30, 2025

v0.0.9

Mar 20, 2025

v0.0.8

Mar 18, 2025

v0.0.7

Feb 24, 2025

v0.0.6

Feb 11, 2025

v0.0.5

Jan 6, 2025

v0.0.4

Jan 3, 2025

Changes in this version

+ const FetchService_GetLatestIndex_FullMethodName

+ const FetchService_ListCloudEventsFromIndex_FullMethodName

+ const FetchService_ListIndexes_FullMethodName

+ type CloudEventIndex struct

+ Data *ObjectInfo

+ Header *CloudEventHeader

+ func (*CloudEventIndex) Descriptor() ([]byte, []int)

+ func (*CloudEventIndex) ProtoMessage()

+ func (x *CloudEventIndex) GetData() *ObjectInfo

+ func (x *CloudEventIndex) GetHeader() *CloudEventHeader

+ func (x *CloudEventIndex) ProtoReflect() protoreflect.Message

+ func (x *CloudEventIndex) Reset()

+ func (x *CloudEventIndex) String() string

type FetchServiceClient

+ GetLatestIndex func(ctx context.Context, in *GetLatestIndexRequest, opts ...grpc.CallOption) (*GetLatestIndexResponse, error)

+ ListCloudEventsFromIndex func(ctx context.Context, in *ListCloudEventsFromKeysRequest, ...) (*ListCloudEventsFromKeysResponse, error)

+ ListIndexes func(ctx context.Context, in *ListIndexesRequest, opts ...grpc.CallOption) (*ListIndexesResponse, error)

type FetchServiceServer

+ GetLatestIndex func(context.Context, *GetLatestIndexRequest) (*GetLatestIndexResponse, error)

+ ListCloudEventsFromIndex func(context.Context, *ListCloudEventsFromKeysRequest) (*ListCloudEventsFromKeysResponse, error)

+ ListIndexes func(context.Context, *ListIndexesRequest) (*ListIndexesResponse, error)

+ type GetLatestIndexRequest struct

+ Options *SearchOptions

+ func (*GetLatestIndexRequest) Descriptor() ([]byte, []int)

+ func (*GetLatestIndexRequest) ProtoMessage()

+ func (x *GetLatestIndexRequest) GetOptions() *SearchOptions

+ func (x *GetLatestIndexRequest) ProtoReflect() protoreflect.Message

+ func (x *GetLatestIndexRequest) Reset()

+ func (x *GetLatestIndexRequest) String() string

+ type GetLatestIndexResponse struct

+ Index *CloudEventIndex

+ func (*GetLatestIndexResponse) Descriptor() ([]byte, []int)

+ func (*GetLatestIndexResponse) ProtoMessage()

+ func (x *GetLatestIndexResponse) GetIndex() *CloudEventIndex

+ func (x *GetLatestIndexResponse) ProtoReflect() protoreflect.Message

+ func (x *GetLatestIndexResponse) Reset()

+ func (x *GetLatestIndexResponse) String() string

type ListCloudEventsFromKeysRequest

+ Indexes []*CloudEventIndex

+ func (x *ListCloudEventsFromKeysRequest) GetIndexes() []*CloudEventIndex

+ type ListIndexesRequest struct

+ Limit int32

+ Options *SearchOptions

+ func (*ListIndexesRequest) Descriptor() ([]byte, []int)

+ func (*ListIndexesRequest) ProtoMessage()

+ func (x *ListIndexesRequest) GetLimit() int32

+ func (x *ListIndexesRequest) GetOptions() *SearchOptions

+ func (x *ListIndexesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListIndexesRequest) Reset()

+ func (x *ListIndexesRequest) String() string

+ type ListIndexesResponse struct

+ Indexes []*CloudEventIndex

+ func (*ListIndexesResponse) Descriptor() ([]byte, []int)

+ func (*ListIndexesResponse) ProtoMessage()

+ func (x *ListIndexesResponse) GetIndexes() []*CloudEventIndex

+ func (x *ListIndexesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListIndexesResponse) Reset()

+ func (x *ListIndexesResponse) String() string

+ type ObjectInfo struct

+ Key string

+ func (*ObjectInfo) Descriptor() ([]byte, []int)

+ func (*ObjectInfo) ProtoMessage()

+ func (x *ObjectInfo) GetKey() string

+ func (x *ObjectInfo) ProtoReflect() protoreflect.Message

+ func (x *ObjectInfo) Reset()

+ func (x *ObjectInfo) String() string

type SearchOptions

+ Extras *wrapperspb.StringValue

+ func (x *SearchOptions) GetExtras() *wrapperspb.StringValue

type UnimplementedFetchServiceServer

+ func (UnimplementedFetchServiceServer) GetLatestIndex(context.Context, *GetLatestIndexRequest) (*GetLatestIndexResponse, error)

+ func (UnimplementedFetchServiceServer) ListCloudEventsFromIndex(context.Context, *ListCloudEventsFromKeysRequest) (*ListCloudEventsFromKeysResponse, error)

+ func (UnimplementedFetchServiceServer) ListIndexes(context.Context, *ListIndexesRequest) (*ListIndexesResponse, error)

v0.0.3

Dec 2, 2024

Changes in this version

+ const FetchService_GetLatestCloudEvent_FullMethodName

+ const FetchService_GetLatestMetadata_FullMethodName

+ const FetchService_ListCloudEventsFromKeys_FullMethodName

+ const FetchService_ListCloudEvents_FullMethodName

+ const FetchService_ListMetadata_FullMethodName

+ var File_pkg_grpc_cloudevent_proto protoreflect.FileDescriptor

+ type CloudEvent struct

+ Data []byte

+ Header *CloudEventHeader

+ func (*CloudEvent) Descriptor() ([]byte, []int)

+ func (*CloudEvent) ProtoMessage()

+ func (c *CloudEvent) AsCloudEvent() cloudevent.CloudEvent[json.RawMessage]

+ func (x *CloudEvent) GetData() []byte

+ func (x *CloudEvent) GetHeader() *CloudEventHeader

+ func (x *CloudEvent) ProtoReflect() protoreflect.Message

+ func (x *CloudEvent) Reset()

+ func (x *CloudEvent) String() string

+ type CloudEventHeader struct

+ DataContentType string

+ DataSchema string

+ DataVersion string

+ Extras map[string][]byte

+ Id string

+ Producer string

+ Source string

+ SpecVersion string

+ Subject string

+ Time *timestamppb.Timestamp

+ Type string

+ func (*CloudEventHeader) Descriptor() ([]byte, []int)

+ func (*CloudEventHeader) ProtoMessage()

+ func (c *CloudEventHeader) AsCloudEventHeader() cloudevent.CloudEventHeader

+ func (x *CloudEventHeader) GetDataContentType() string

+ func (x *CloudEventHeader) GetDataSchema() string

+ func (x *CloudEventHeader) GetDataVersion() string

+ func (x *CloudEventHeader) GetExtras() map[string][]byte

+ func (x *CloudEventHeader) GetId() string

+ func (x *CloudEventHeader) GetProducer() string

+ func (x *CloudEventHeader) GetSource() string

+ func (x *CloudEventHeader) GetSpecVersion() string

+ func (x *CloudEventHeader) GetSubject() string

+ func (x *CloudEventHeader) GetTime() *timestamppb.Timestamp

+ func (x *CloudEventHeader) GetType() string

+ func (x *CloudEventHeader) ProtoReflect() protoreflect.Message

+ func (x *CloudEventHeader) Reset()

+ func (x *CloudEventHeader) String() string

+ type CloudEventMetadata struct

+ Header *CloudEventHeader

+ Key string

+ func (*CloudEventMetadata) Descriptor() ([]byte, []int)

+ func (*CloudEventMetadata) ProtoMessage()

+ func (x *CloudEventMetadata) GetHeader() *CloudEventHeader

+ func (x *CloudEventMetadata) GetKey() string

+ func (x *CloudEventMetadata) ProtoReflect() protoreflect.Message

+ func (x *CloudEventMetadata) Reset()

+ func (x *CloudEventMetadata) String() string

type FetchServiceClient

+ GetLatestCloudEvent func(ctx context.Context, in *GetLatestCloudEventRequest, opts ...grpc.CallOption) (*GetLatestCloudEventResponse, error)

+ GetLatestMetadata func(ctx context.Context, in *GetLatestMetadataRequest, opts ...grpc.CallOption) (*GetLatestMetadataResponse, error)

+ ListCloudEvents func(ctx context.Context, in *ListCloudEventsRequest, opts ...grpc.CallOption) (*ListCloudEventsResponse, error)

+ ListCloudEventsFromKeys func(ctx context.Context, in *ListCloudEventsFromKeysRequest, ...) (*ListCloudEventsFromKeysResponse, error)

+ ListMetadata func(ctx context.Context, in *ListMetadataRequest, opts ...grpc.CallOption) (*ListMetadataResponse, error)

type FetchServiceServer

+ GetLatestCloudEvent func(context.Context, *GetLatestCloudEventRequest) (*GetLatestCloudEventResponse, error)

+ GetLatestMetadata func(context.Context, *GetLatestMetadataRequest) (*GetLatestMetadataResponse, error)

+ ListCloudEvents func(context.Context, *ListCloudEventsRequest) (*ListCloudEventsResponse, error)

+ ListCloudEventsFromKeys func(context.Context, *ListCloudEventsFromKeysRequest) (*ListCloudEventsFromKeysResponse, error)

+ ListMetadata func(context.Context, *ListMetadataRequest) (*ListMetadataResponse, error)

+ type GetLatestCloudEventRequest struct

+ Options *SearchOptions

+ func (*GetLatestCloudEventRequest) Descriptor() ([]byte, []int)

+ func (*GetLatestCloudEventRequest) ProtoMessage()

+ func (x *GetLatestCloudEventRequest) GetOptions() *SearchOptions

+ func (x *GetLatestCloudEventRequest) ProtoReflect() protoreflect.Message

+ func (x *GetLatestCloudEventRequest) Reset()

+ func (x *GetLatestCloudEventRequest) String() string

+ type GetLatestCloudEventResponse struct

+ CloudEvent *CloudEvent

+ func (*GetLatestCloudEventResponse) Descriptor() ([]byte, []int)

+ func (*GetLatestCloudEventResponse) ProtoMessage()

+ func (x *GetLatestCloudEventResponse) GetCloudEvent() *CloudEvent

+ func (x *GetLatestCloudEventResponse) ProtoReflect() protoreflect.Message

+ func (x *GetLatestCloudEventResponse) Reset()

+ func (x *GetLatestCloudEventResponse) String() string

+ type GetLatestMetadataRequest struct

+ Options *SearchOptions

+ func (*GetLatestMetadataRequest) Descriptor() ([]byte, []int)

+ func (*GetLatestMetadataRequest) ProtoMessage()

+ func (x *GetLatestMetadataRequest) GetOptions() *SearchOptions

+ func (x *GetLatestMetadataRequest) ProtoReflect() protoreflect.Message

+ func (x *GetLatestMetadataRequest) Reset()

+ func (x *GetLatestMetadataRequest) String() string

+ type GetLatestMetadataResponse struct

+ Metadata *CloudEventMetadata

+ func (*GetLatestMetadataResponse) Descriptor() ([]byte, []int)

+ func (*GetLatestMetadataResponse) ProtoMessage()

+ func (x *GetLatestMetadataResponse) GetMetadata() *CloudEventMetadata

+ func (x *GetLatestMetadataResponse) ProtoReflect() protoreflect.Message

+ func (x *GetLatestMetadataResponse) Reset()

+ func (x *GetLatestMetadataResponse) String() string

+ type ListCloudEventsFromKeysRequest struct

+ IndexKeys []string

+ func (*ListCloudEventsFromKeysRequest) Descriptor() ([]byte, []int)

+ func (*ListCloudEventsFromKeysRequest) ProtoMessage()

+ func (x *ListCloudEventsFromKeysRequest) GetIndexKeys() []string

+ func (x *ListCloudEventsFromKeysRequest) ProtoReflect() protoreflect.Message

+ func (x *ListCloudEventsFromKeysRequest) Reset()

+ func (x *ListCloudEventsFromKeysRequest) String() string

+ type ListCloudEventsFromKeysResponse struct

+ CloudEvents []*CloudEvent

+ func (*ListCloudEventsFromKeysResponse) Descriptor() ([]byte, []int)

+ func (*ListCloudEventsFromKeysResponse) ProtoMessage()

+ func (x *ListCloudEventsFromKeysResponse) GetCloudEvents() []*CloudEvent

+ func (x *ListCloudEventsFromKeysResponse) ProtoReflect() protoreflect.Message

+ func (x *ListCloudEventsFromKeysResponse) Reset()

+ func (x *ListCloudEventsFromKeysResponse) String() string

+ type ListCloudEventsRequest struct

+ Limit int32

+ Options *SearchOptions

+ func (*ListCloudEventsRequest) Descriptor() ([]byte, []int)

+ func (*ListCloudEventsRequest) ProtoMessage()

+ func (x *ListCloudEventsRequest) GetLimit() int32

+ func (x *ListCloudEventsRequest) GetOptions() *SearchOptions

+ func (x *ListCloudEventsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListCloudEventsRequest) Reset()

+ func (x *ListCloudEventsRequest) String() string

+ type ListCloudEventsResponse struct

+ CloudEvents []*CloudEvent

+ func (*ListCloudEventsResponse) Descriptor() ([]byte, []int)

+ func (*ListCloudEventsResponse) ProtoMessage()

+ func (x *ListCloudEventsResponse) GetCloudEvents() []*CloudEvent

+ func (x *ListCloudEventsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListCloudEventsResponse) Reset()

+ func (x *ListCloudEventsResponse) String() string

+ type ListMetadataRequest struct

+ Limit int32

+ Options *SearchOptions

+ func (*ListMetadataRequest) Descriptor() ([]byte, []int)

+ func (*ListMetadataRequest) ProtoMessage()

+ func (x *ListMetadataRequest) GetLimit() int32

+ func (x *ListMetadataRequest) GetOptions() *SearchOptions

+ func (x *ListMetadataRequest) ProtoReflect() protoreflect.Message

+ func (x *ListMetadataRequest) Reset()

+ func (x *ListMetadataRequest) String() string

+ type ListMetadataResponse struct

+ MetadataList []*CloudEventMetadata

+ func (*ListMetadataResponse) Descriptor() ([]byte, []int)

+ func (*ListMetadataResponse) ProtoMessage()

+ func (x *ListMetadataResponse) GetMetadataList() []*CloudEventMetadata

+ func (x *ListMetadataResponse) ProtoReflect() protoreflect.Message

+ func (x *ListMetadataResponse) Reset()

+ func (x *ListMetadataResponse) String() string

type SearchOptions

+ DataVersion *wrapperspb.StringValue

+ Type *wrapperspb.StringValue

+ func (x *SearchOptions) GetDataVersion() *wrapperspb.StringValue

+ func (x *SearchOptions) GetType() *wrapperspb.StringValue

type UnimplementedFetchServiceServer

+ func (UnimplementedFetchServiceServer) GetLatestCloudEvent(context.Context, *GetLatestCloudEventRequest) (*GetLatestCloudEventResponse, error)

+ func (UnimplementedFetchServiceServer) GetLatestMetadata(context.Context, *GetLatestMetadataRequest) (*GetLatestMetadataResponse, error)

+ func (UnimplementedFetchServiceServer) ListCloudEvents(context.Context, *ListCloudEventsRequest) (*ListCloudEventsResponse, error)

+ func (UnimplementedFetchServiceServer) ListCloudEventsFromKeys(context.Context, *ListCloudEventsFromKeysRequest) (*ListCloudEventsFromKeysResponse, error)

+ func (UnimplementedFetchServiceServer) ListMetadata(context.Context, *ListMetadataRequest) (*ListMetadataResponse, error)

v0.0.2

Nov 4, 2024

v0.0.1

Nov 1, 2024

Changes in this version

+ const FetchService_GetIndexKeys_FullMethodName

+ const FetchService_GetLatestIndexKey_FullMethodName

+ const FetchService_GetLatestObject_FullMethodName

+ const FetchService_GetObjectsFromIndexKeys_FullMethodName

+ const FetchService_GetObjects_FullMethodName

+ var FetchService_ServiceDesc = grpc.ServiceDesc

+ var File_pkg_grpc_fetch_api_proto protoreflect.FileDescriptor

+ func RegisterFetchServiceServer(s grpc.ServiceRegistrar, srv FetchServiceServer)

+ type DataObject struct

+ Data []byte

+ IndexKey string

+ func (*DataObject) Descriptor() ([]byte, []int)

+ func (*DataObject) ProtoMessage()

+ func (x *DataObject) GetData() []byte

+ func (x *DataObject) GetIndexKey() string

+ func (x *DataObject) ProtoReflect() protoreflect.Message

+ func (x *DataObject) Reset()

+ func (x *DataObject) String() string

+ type FetchServiceClient interface

+ GetIndexKeys func(ctx context.Context, in *GetIndexKeysRequest, opts ...grpc.CallOption) (*GetIndexKeysResponse, error)

+ GetLatestIndexKey func(ctx context.Context, in *GetLatestIndexKeyRequest, opts ...grpc.CallOption) (*GetLatestIndexKeyResponse, error)

+ GetLatestObject func(ctx context.Context, in *GetLatestObjectRequest, opts ...grpc.CallOption) (*GetLatestObjectResponse, error)

+ GetObjects func(ctx context.Context, in *GetObjectsRequest, opts ...grpc.CallOption) (*GetObjectsResponse, error)

+ GetObjectsFromIndexKeys func(ctx context.Context, in *GetObjectsFromIndexKeysRequest, ...) (*GetObjectsFromIndexKeysResponse, error)

+ func NewFetchServiceClient(cc grpc.ClientConnInterface) FetchServiceClient

+ type FetchServiceServer interface

+ GetIndexKeys func(context.Context, *GetIndexKeysRequest) (*GetIndexKeysResponse, error)

+ GetLatestIndexKey func(context.Context, *GetLatestIndexKeyRequest) (*GetLatestIndexKeyResponse, error)

+ GetLatestObject func(context.Context, *GetLatestObjectRequest) (*GetLatestObjectResponse, error)

+ GetObjects func(context.Context, *GetObjectsRequest) (*GetObjectsResponse, error)

+ GetObjectsFromIndexKeys func(context.Context, *GetObjectsFromIndexKeysRequest) (*GetObjectsFromIndexKeysResponse, error)

+ type GetIndexKeysRequest struct

+ Limit int32

+ Options *SearchOptions

+ func (*GetIndexKeysRequest) Descriptor() ([]byte, []int)

+ func (*GetIndexKeysRequest) ProtoMessage()

+ func (x *GetIndexKeysRequest) GetLimit() int32

+ func (x *GetIndexKeysRequest) GetOptions() *SearchOptions

+ func (x *GetIndexKeysRequest) ProtoReflect() protoreflect.Message

+ func (x *GetIndexKeysRequest) Reset()

+ func (x *GetIndexKeysRequest) String() string

+ type GetIndexKeysResponse struct

+ IndexKeys []string

+ func (*GetIndexKeysResponse) Descriptor() ([]byte, []int)

+ func (*GetIndexKeysResponse) ProtoMessage()

+ func (x *GetIndexKeysResponse) GetIndexKeys() []string

+ func (x *GetIndexKeysResponse) ProtoReflect() protoreflect.Message

+ func (x *GetIndexKeysResponse) Reset()

+ func (x *GetIndexKeysResponse) String() string

+ type GetLatestIndexKeyRequest struct

+ Options *SearchOptions

+ func (*GetLatestIndexKeyRequest) Descriptor() ([]byte, []int)

+ func (*GetLatestIndexKeyRequest) ProtoMessage()

+ func (x *GetLatestIndexKeyRequest) GetOptions() *SearchOptions

+ func (x *GetLatestIndexKeyRequest) ProtoReflect() protoreflect.Message

+ func (x *GetLatestIndexKeyRequest) Reset()

+ func (x *GetLatestIndexKeyRequest) String() string

+ type GetLatestIndexKeyResponse struct

+ IndexKey string

+ func (*GetLatestIndexKeyResponse) Descriptor() ([]byte, []int)

+ func (*GetLatestIndexKeyResponse) ProtoMessage()

+ func (x *GetLatestIndexKeyResponse) GetIndexKey() string

+ func (x *GetLatestIndexKeyResponse) ProtoReflect() protoreflect.Message

+ func (x *GetLatestIndexKeyResponse) Reset()

+ func (x *GetLatestIndexKeyResponse) String() string

+ type GetLatestObjectRequest struct

+ Options *SearchOptions

+ func (*GetLatestObjectRequest) Descriptor() ([]byte, []int)

+ func (*GetLatestObjectRequest) ProtoMessage()

+ func (x *GetLatestObjectRequest) GetOptions() *SearchOptions

+ func (x *GetLatestObjectRequest) ProtoReflect() protoreflect.Message

+ func (x *GetLatestObjectRequest) Reset()

+ func (x *GetLatestObjectRequest) String() string

+ type GetLatestObjectResponse struct

+ DataObject *DataObject

+ func (*GetLatestObjectResponse) Descriptor() ([]byte, []int)

+ func (*GetLatestObjectResponse) ProtoMessage()

+ func (x *GetLatestObjectResponse) GetDataObject() *DataObject

+ func (x *GetLatestObjectResponse) ProtoReflect() protoreflect.Message

+ func (x *GetLatestObjectResponse) Reset()

+ func (x *GetLatestObjectResponse) String() string

+ type GetObjectsFromIndexKeysRequest struct

+ IndexKeys []string

+ func (*GetObjectsFromIndexKeysRequest) Descriptor() ([]byte, []int)

+ func (*GetObjectsFromIndexKeysRequest) ProtoMessage()

+ func (x *GetObjectsFromIndexKeysRequest) GetIndexKeys() []string

+ func (x *GetObjectsFromIndexKeysRequest) ProtoReflect() protoreflect.Message

+ func (x *GetObjectsFromIndexKeysRequest) Reset()

+ func (x *GetObjectsFromIndexKeysRequest) String() string

+ type GetObjectsFromIndexKeysResponse struct

+ DataObjects []*DataObject

+ func (*GetObjectsFromIndexKeysResponse) Descriptor() ([]byte, []int)

+ func (*GetObjectsFromIndexKeysResponse) ProtoMessage()

+ func (x *GetObjectsFromIndexKeysResponse) GetDataObjects() []*DataObject

+ func (x *GetObjectsFromIndexKeysResponse) ProtoReflect() protoreflect.Message

+ func (x *GetObjectsFromIndexKeysResponse) Reset()

+ func (x *GetObjectsFromIndexKeysResponse) String() string

+ type GetObjectsRequest struct

+ Limit int32

+ Options *SearchOptions

+ func (*GetObjectsRequest) Descriptor() ([]byte, []int)

+ func (*GetObjectsRequest) ProtoMessage()

+ func (x *GetObjectsRequest) GetLimit() int32

+ func (x *GetObjectsRequest) GetOptions() *SearchOptions

+ func (x *GetObjectsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetObjectsRequest) Reset()

+ func (x *GetObjectsRequest) String() string

+ type GetObjectsResponse struct

+ DataObjects []*DataObject

+ func (*GetObjectsResponse) Descriptor() ([]byte, []int)

+ func (*GetObjectsResponse) ProtoMessage()

+ func (x *GetObjectsResponse) GetDataObjects() []*DataObject

+ func (x *GetObjectsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetObjectsResponse) Reset()

+ func (x *GetObjectsResponse) String() string

+ type SearchOptions struct

+ After *timestamppb.Timestamp

+ Before *timestamppb.Timestamp

+ DataType *wrapperspb.StringValue

+ Optional *wrapperspb.StringValue

+ PrimaryFiller *wrapperspb.StringValue

+ Producer *wrapperspb.StringValue

+ SecondaryFiller *wrapperspb.StringValue

+ Source *wrapperspb.StringValue

+ Subject *wrapperspb.StringValue

+ TimestampAsc *wrapperspb.BoolValue

+ func (*SearchOptions) Descriptor() ([]byte, []int)

+ func (*SearchOptions) ProtoMessage()

+ func (x *SearchOptions) GetAfter() *timestamppb.Timestamp

+ func (x *SearchOptions) GetBefore() *timestamppb.Timestamp

+ func (x *SearchOptions) GetDataType() *wrapperspb.StringValue

+ func (x *SearchOptions) GetOptional() *wrapperspb.StringValue

+ func (x *SearchOptions) GetPrimaryFiller() *wrapperspb.StringValue

+ func (x *SearchOptions) GetProducer() *wrapperspb.StringValue

+ func (x *SearchOptions) GetSecondaryFiller() *wrapperspb.StringValue

+ func (x *SearchOptions) GetSource() *wrapperspb.StringValue

+ func (x *SearchOptions) GetSubject() *wrapperspb.StringValue

+ func (x *SearchOptions) GetTimestampAsc() *wrapperspb.BoolValue

+ func (x *SearchOptions) ProtoReflect() protoreflect.Message

+ func (x *SearchOptions) Reset()

+ func (x *SearchOptions) String() string

+ type UnimplementedFetchServiceServer struct

+ func (UnimplementedFetchServiceServer) GetIndexKeys(context.Context, *GetIndexKeysRequest) (*GetIndexKeysResponse, error)

+ func (UnimplementedFetchServiceServer) GetLatestIndexKey(context.Context, *GetLatestIndexKeyRequest) (*GetLatestIndexKeyResponse, error)

+ func (UnimplementedFetchServiceServer) GetLatestObject(context.Context, *GetLatestObjectRequest) (*GetLatestObjectResponse, error)

+ func (UnimplementedFetchServiceServer) GetObjects(context.Context, *GetObjectsRequest) (*GetObjectsResponse, error)

+ func (UnimplementedFetchServiceServer) GetObjectsFromIndexKeys(context.Context, *GetObjectsFromIndexKeysRequest) (*GetObjectsFromIndexKeysResponse, error)

+ type UnsafeFetchServiceServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL