fetchapi

type AdvancedSearchOptions struct {

	// Only include events after this timestamp.
	After *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=after,proto3" json:"after,omitempty"`
	// Only include events before this timestamp.
	Before *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=before,proto3" json:"before,omitempty"`
	// Whether to sort results in ascending order by timestamp.
	TimestampAsc *wrapperspb.BoolValue `protobuf:"bytes,3,opt,name=timestamp_asc,json=timestampAsc,proto3" json:"timestamp_asc,omitempty"`
	// Advanced filtering for event type
	Type *StringFilterOption `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// Advanced filtering for data version
	DataVersion *StringFilterOption `protobuf:"bytes,5,opt,name=data_version,json=dataVersion,proto3" json:"data_version,omitempty"`
	// Advanced filtering for event subject
	Subject *StringFilterOption `protobuf:"bytes,6,opt,name=subject,proto3" json:"subject,omitempty"`
	// Advanced filtering for source identifier
	Source *StringFilterOption `protobuf:"bytes,8,opt,name=source,proto3" json:"source,omitempty"`
	// Advanced filtering for producer
	Producer *StringFilterOption `protobuf:"bytes,9,opt,name=producer,proto3" json:"producer,omitempty"`
	// Advanced filtering for extras (JSON string from cloud event header)
	Extras *StringFilterOption `protobuf:"bytes,10,opt,name=extras,proto3" json:"extras,omitempty"`
	// Advanced filtering for event ID
	Id *StringFilterOption `protobuf:"bytes,11,opt,name=id,proto3" json:"id,omitempty"`
	// Tags are a list of tags that can be used to filter the events.
	Tags *ArrayFilterOption `protobuf:"bytes,12,opt,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

type ArrayFilterOption struct {

	// Match if the field has any of these values.
	ContainsAny []string `protobuf:"bytes,1,rep,name=contains_any,json=containsAny,proto3" json:"contains_any,omitempty"`
	// Match if the field has all of these values.
	ContainsAll []string `protobuf:"bytes,2,rep,name=contains_all,json=containsAll,proto3" json:"contains_all,omitempty"`
	// Match if the field does not have any of these values.
	NotContainsAny []string `protobuf:"bytes,3,rep,name=not_contains_any,json=notContainsAny,proto3" json:"not_contains_any,omitempty"`
	// Match if the field does not have all of these values.
	NotContainsAll []string `protobuf:"bytes,4,rep,name=not_contains_all,json=notContainsAll,proto3" json:"not_contains_all,omitempty"`
	// Additional filter condition to combine with this one using OR logic.
	Or []*ArrayFilterOption `protobuf:"bytes,5,rep,name=or,proto3" json:"or,omitempty"`
	// contains filtered or unexported fields
}

type CloudEvent struct {
	Header *CloudEventHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Data   []byte            `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type CloudEventHeader struct {

	// ID is an identifier for the event. The combination of ID and Source must
	// be unique.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Source is the context in which the event happened. In a distributed system it might consist of multiple Producers.
	// Typically the 0x address.
	Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// Producer is a specific instance, process or device that creates the data structure describing the CloudEvent.
	// Typically a DID of a nft.
	Producer string `protobuf:"bytes,3,opt,name=producer,proto3" json:"producer,omitempty"`
	// SpecVersion is the version of CloudEvents specification used.
	// This is always hardcoded "1.0".
	SpecVersion string `protobuf:"bytes,4,opt,name=spec_version,json=specVersion,proto3" json:"spec_version,omitempty"`
	// Subject is an optional field identifying the subject of the event within
	// the context of the event producer.
	// Typically the DID of the nft.
	Subject string `protobuf:"bytes,5,opt,name=subject,proto3" json:"subject,omitempty"`
	// Time which the event occurred.
	Time *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=time,proto3" json:"time,omitempty"`
	// Type describes the type of event.
	// Typically a one of the predefined DIMO types. (dimo.status, dimo.fingerprint, dimo.verfiabaleCredential...)
	Type string `protobuf:"bytes,7,opt,name=type,proto3" json:"type,omitempty"`
	// DataContentType is an optional MIME type for the data field. We almost
	// always serialize to JSON and in that case this field is implicitly
	// "application/json".
	DataContentType string `protobuf:"bytes,8,opt,name=data_content_type,json=dataContentType,proto3" json:"data_content_type,omitempty"`
	// DataSchema is an optional URI pointing to a schema for the data field.
	DataSchema string `protobuf:"bytes,9,opt,name=data_schema,json=dataSchema,proto3" json:"data_schema,omitempty"`
	// DataVersion is the controlled by the source of the event and is used to provide information about the data.
	DataVersion string `protobuf:"bytes,10,opt,name=data_version,json=dataVersion,proto3" json:"data_version,omitempty"`
	// Extras contains any additional fields that are not part of the CloudEvent excluding the data field.
	Extras map[string][]byte `` /* 140-byte string literal not displayed */
	// Tags are a list of tags that can be used to filter the events.
	Tags []string `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags,omitempty"`
	// Signature hold the signature of the a cloudevent's data field.
	Signature string `protobuf:"bytes,13,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

type CloudEventIndex struct {

	// The cloud event header of the cloud event.
	Header *CloudEventHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// The index key of the cloud event.
	Data *ObjectInfo `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type FetchServiceClient interface {
	// GetLatestIndexreturns the latest index key for the given options
	GetLatestIndex(ctx context.Context, in *GetLatestIndexRequest, opts ...grpc.CallOption) (*GetLatestIndexResponse, error)
	// ListIndexes fetches and returns the list of cloud event index objects that match the specified options
	ListIndexes(ctx context.Context, in *ListIndexesRequest, opts ...grpc.CallOption) (*ListIndexesResponse, error)
	// GetLatestCloudEvent fetches and returns the latest object that matches the specified options
	GetLatestCloudEvent(ctx context.Context, in *GetLatestCloudEventRequest, opts ...grpc.CallOption) (*GetLatestCloudEventResponse, error)
	// ListCloudEvents fetches and returns the list of objects that match the specified options
	ListCloudEvents(ctx context.Context, in *ListCloudEventsRequest, opts ...grpc.CallOption) (*ListCloudEventsResponse, error)
	// ListCloudEventsFromKeys fetches and returns the list of objects that match the specified index key
	ListCloudEventsFromIndex(ctx context.Context, in *ListCloudEventsFromKeysRequest, opts ...grpc.CallOption) (*ListCloudEventsFromKeysResponse, error)
}

type FetchServiceServer interface {
	// GetLatestIndexreturns the latest index key for the given options
	GetLatestIndex(context.Context, *GetLatestIndexRequest) (*GetLatestIndexResponse, error)
	// ListIndexes fetches and returns the list of cloud event index objects that match the specified options
	ListIndexes(context.Context, *ListIndexesRequest) (*ListIndexesResponse, error)
	// GetLatestCloudEvent fetches and returns the latest object that matches the specified options
	GetLatestCloudEvent(context.Context, *GetLatestCloudEventRequest) (*GetLatestCloudEventResponse, error)
	// ListCloudEvents fetches and returns the list of objects that match the specified options
	ListCloudEvents(context.Context, *ListCloudEventsRequest) (*ListCloudEventsResponse, error)
	// ListCloudEventsFromKeys fetches and returns the list of objects that match the specified index key
	ListCloudEventsFromIndex(context.Context, *ListCloudEventsFromKeysRequest) (*ListCloudEventsFromKeysResponse, error)
	// contains filtered or unexported methods
}

type GetLatestCloudEventRequest struct {

	// Search options to filter the events.
	Options *SearchOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// Advanced search options to filter the events.
	AdvancedOptions *AdvancedSearchOptions `protobuf:"bytes,2,opt,name=advanced_options,json=advancedOptions,proto3" json:"advanced_options,omitempty"`
	// contains filtered or unexported fields
}

type GetLatestCloudEventResponse struct {

	// The data retrieved from the latest cloud event.
	CloudEvent *CloudEvent `protobuf:"bytes,1,opt,name=cloud_event,json=cloudEvent,proto3" json:"cloud_event,omitempty"`
	// contains filtered or unexported fields
}

type GetLatestIndexRequest struct {
	Options         *SearchOptions         `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	AdvancedOptions *AdvancedSearchOptions `protobuf:"bytes,2,opt,name=advanced_options,json=advancedOptions,proto3" json:"advanced_options,omitempty"`
	// contains filtered or unexported fields
}

type GetLatestIndexResponse struct {

	// The latest index key retrieved for the specified search criteria.
	Index *CloudEventIndex `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

type ListCloudEventsFromKeysRequest struct {

	// The list of index objects whose underlying cloud events are to be retrieved.
	Indexes []*CloudEventIndex `protobuf:"bytes,1,rep,name=indexes,proto3" json:"indexes,omitempty"`
	// contains filtered or unexported fields
}

type ListCloudEventsFromKeysResponse struct {

	// The list of data retrieved from the objects.
	CloudEvents []*CloudEvent `protobuf:"bytes,1,rep,name=cloud_events,json=cloudEvents,proto3" json:"cloud_events,omitempty"`
	// contains filtered or unexported fields
}

type ListCloudEventsRequest struct {

	// Search options to filter the events.
	Options *SearchOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// The maximum number of objects to return.
	Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// Advanced search options to filter the events.
	AdvancedOptions *AdvancedSearchOptions `protobuf:"bytes,3,opt,name=advanced_options,json=advancedOptions,proto3" json:"advanced_options,omitempty"`
	// contains filtered or unexported fields
}

type ListCloudEventsResponse struct {

	// The list of data retrieved from the objects.
	CloudEvents []*CloudEvent `protobuf:"bytes,1,rep,name=cloud_events,json=cloudEvents,proto3" json:"cloud_events,omitempty"`
	// contains filtered or unexported fields
}

type ListIndexesRequest struct {

	// Search options to filter the events.
	Options *SearchOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// The maximum number of index objects to return.
	Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// Advanced search options to filter the events.
	AdvancedOptions *AdvancedSearchOptions `protobuf:"bytes,3,opt,name=advanced_options,json=advancedOptions,proto3" json:"advanced_options,omitempty"`
	// contains filtered or unexported fields
}

type ListIndexesResponse struct {

	// The list of index objects retrieved for the specified search criteria.
	Indexes []*CloudEventIndex `protobuf:"bytes,1,rep,name=indexes,proto3" json:"indexes,omitempty"`
	// contains filtered or unexported fields
}

type ObjectInfo struct {

	// The index key of the cloud event.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type SearchOptions struct {

	// Only include events after this timestamp.
	After *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=after,proto3" json:"after,omitempty"`
	// Only include events before this timestamp.
	Before *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=before,proto3" json:"before,omitempty"`
	// Whether to sort results in ascending order by timestamp.
	TimestampAsc *wrapperspb.BoolValue `protobuf:"bytes,3,opt,name=timestamp_asc,json=timestampAsc,proto3" json:"timestamp_asc,omitempty"`
	// Type of the event to filter.
	Type *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// DataVersion of the event to filter.
	DataVersion *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=data_version,json=dataVersion,proto3" json:"data_version,omitempty"`
	// The subject of the event to filter.
	Subject *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=subject,proto3" json:"subject,omitempty"`
	// The source identifier responsible for creating the data.
	Source *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=source,proto3" json:"source,omitempty"`
	// The producer of the data, source entity responsible for creating the data.
	Producer *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=producer,proto3" json:"producer,omitempty"`
	// exta values from the cloud event header this is a JSON string.
	Extras *wrapperspb.StringValue `protobuf:"bytes,10,opt,name=extras,proto3" json:"extras,omitempty"`
	// ID of the event to filter.
	Id *wrapperspb.StringValue `protobuf:"bytes,11,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type StringFilterOption struct {

	// Match if the field is in the list of values.
	In []string `protobuf:"bytes,1,rep,name=in,proto3" json:"in,omitempty"`
	// Match if the field is not in the list of values.
	NotIn []string `protobuf:"bytes,2,rep,name=not_in,json=notIn,proto3" json:"not_in,omitempty"`
	// Additional filter condition to combine with this one using OR logic.
	Or []*StringFilterOption `protobuf:"bytes,3,rep,name=or,proto3" json:"or,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedFetchServiceServer struct{}

type UnsafeFetchServiceServer interface {
	// contains filtered or unexported methods
}