Versions in this module Expand all Collapse all v0 v0.6.0 Mar 30, 2026 Changes in this version + const FetchService_GetLatestCloudEvent_FullMethodName + const FetchService_GetLatestIndex_FullMethodName + const FetchService_ListCloudEventsFromIndex_FullMethodName + const FetchService_ListCloudEvents_FullMethodName + const FetchService_ListIndexes_FullMethodName + var FetchService_ServiceDesc = grpc.ServiceDesc + var File_pkg_grpc_cloudevent_proto protoreflect.FileDescriptor + var File_pkg_grpc_fetch_api_proto protoreflect.FileDescriptor + func RegisterFetchServiceServer(s grpc.ServiceRegistrar, srv FetchServiceServer) + 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 CloudEvent struct + Data []byte + Header *CloudEventHeader + func (*CloudEvent) Descriptor() ([]byte, []int) + func (*CloudEvent) ProtoMessage() + 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 + Signature string + Source string + SpecVersion string + Subject string + Tags []string + Time *timestamppb.Timestamp + Type string + func (*CloudEventHeader) Descriptor() ([]byte, []int) + func (*CloudEventHeader) ProtoMessage() + 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) GetSignature() string + func (x *CloudEventHeader) GetSource() string + func (x *CloudEventHeader) GetSpecVersion() string + func (x *CloudEventHeader) GetSubject() string + func (x *CloudEventHeader) GetTags() []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 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 interface + GetLatestCloudEvent func(ctx context.Context, in *GetLatestCloudEventRequest, opts ...grpc.CallOption) (*GetLatestCloudEventResponse, error) + GetLatestIndex func(ctx context.Context, in *GetLatestIndexRequest, opts ...grpc.CallOption) (*GetLatestIndexResponse, error) + ListCloudEvents func(ctx context.Context, in *ListCloudEventsRequest, opts ...grpc.CallOption) (*ListCloudEventsResponse, error) + ListCloudEventsFromIndex func(ctx context.Context, in *ListCloudEventsFromKeysRequest, ...) (*ListCloudEventsFromKeysResponse, error) + ListIndexes func(ctx context.Context, in *ListIndexesRequest, opts ...grpc.CallOption) (*ListIndexesResponse, error) + func NewFetchServiceClient(cc grpc.ClientConnInterface) FetchServiceClient + type FetchServiceServer interface + GetLatestCloudEvent func(context.Context, *GetLatestCloudEventRequest) (*GetLatestCloudEventResponse, error) + GetLatestIndex func(context.Context, *GetLatestIndexRequest) (*GetLatestIndexResponse, error) + ListCloudEvents func(context.Context, *ListCloudEventsRequest) (*ListCloudEventsResponse, error) + ListCloudEventsFromIndex func(context.Context, *ListCloudEventsFromKeysRequest) (*ListCloudEventsFromKeysResponse, error) + ListIndexes func(context.Context, *ListIndexesRequest) (*ListIndexesResponse, error) + type GetLatestCloudEventRequest struct + AdvancedOptions *AdvancedSearchOptions + Options *SearchOptions + func (*GetLatestCloudEventRequest) Descriptor() ([]byte, []int) + func (*GetLatestCloudEventRequest) ProtoMessage() + func (x *GetLatestCloudEventRequest) GetAdvancedOptions() *AdvancedSearchOptions + 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 GetLatestIndexRequest struct + AdvancedOptions *AdvancedSearchOptions + Options *SearchOptions + func (*GetLatestIndexRequest) Descriptor() ([]byte, []int) + func (*GetLatestIndexRequest) ProtoMessage() + func (x *GetLatestIndexRequest) GetAdvancedOptions() *AdvancedSearchOptions + 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 struct + Indexes []*CloudEventIndex + func (*ListCloudEventsFromKeysRequest) Descriptor() ([]byte, []int) + func (*ListCloudEventsFromKeysRequest) ProtoMessage() + func (x *ListCloudEventsFromKeysRequest) GetIndexes() []*CloudEventIndex + 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 + AdvancedOptions *AdvancedSearchOptions + Limit int32 + Options *SearchOptions + func (*ListCloudEventsRequest) Descriptor() ([]byte, []int) + func (*ListCloudEventsRequest) ProtoMessage() + func (x *ListCloudEventsRequest) GetAdvancedOptions() *AdvancedSearchOptions + 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 ListIndexesRequest struct + AdvancedOptions *AdvancedSearchOptions + Limit int32 + Options *SearchOptions + func (*ListIndexesRequest) Descriptor() ([]byte, []int) + func (*ListIndexesRequest) ProtoMessage() + func (x *ListIndexesRequest) GetAdvancedOptions() *AdvancedSearchOptions + 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 struct + After *timestamppb.Timestamp + Before *timestamppb.Timestamp + DataVersion *wrapperspb.StringValue + Extras *wrapperspb.StringValue + Id *wrapperspb.StringValue + Producer *wrapperspb.StringValue + Source *wrapperspb.StringValue + Subject *wrapperspb.StringValue + TimestampAsc *wrapperspb.BoolValue + Type *wrapperspb.StringValue + func (*SearchOptions) Descriptor() ([]byte, []int) + func (*SearchOptions) ProtoMessage() + func (x *SearchOptions) GetAfter() *timestamppb.Timestamp + func (x *SearchOptions) GetBefore() *timestamppb.Timestamp + func (x *SearchOptions) GetDataVersion() *wrapperspb.StringValue + func (x *SearchOptions) GetExtras() *wrapperspb.StringValue + func (x *SearchOptions) GetId() *wrapperspb.StringValue + func (x *SearchOptions) GetProducer() *wrapperspb.StringValue + func (x *SearchOptions) GetSource() *wrapperspb.StringValue + func (x *SearchOptions) GetSubject() *wrapperspb.StringValue + func (x *SearchOptions) GetTimestampAsc() *wrapperspb.BoolValue + func (x *SearchOptions) GetType() *wrapperspb.StringValue + func (x *SearchOptions) ProtoReflect() protoreflect.Message + func (x *SearchOptions) Reset() + func (x *SearchOptions) String() string + 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 + type UnimplementedFetchServiceServer struct + func (UnimplementedFetchServiceServer) GetLatestCloudEvent(context.Context, *GetLatestCloudEventRequest) (*GetLatestCloudEventResponse, error) + func (UnimplementedFetchServiceServer) GetLatestIndex(context.Context, *GetLatestIndexRequest) (*GetLatestIndexResponse, error) + func (UnimplementedFetchServiceServer) ListCloudEvents(context.Context, *ListCloudEventsRequest) (*ListCloudEventsResponse, error) + func (UnimplementedFetchServiceServer) ListCloudEventsFromIndex(context.Context, *ListCloudEventsFromKeysRequest) (*ListCloudEventsFromKeysResponse, error) + func (UnimplementedFetchServiceServer) ListIndexes(context.Context, *ListIndexesRequest) (*ListIndexesResponse, error) + type UnsafeFetchServiceServer interface
Go to main page