grpc

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	FetchService_GetLatestMetadata_FullMethodName       = "/grpc.FetchService/GetLatestMetadata"
	FetchService_ListMetadata_FullMethodName            = "/grpc.FetchService/ListMetadata"
	FetchService_GetLatestCloudEvent_FullMethodName     = "/grpc.FetchService/GetLatestCloudEvent"
	FetchService_ListCloudEvents_FullMethodName         = "/grpc.FetchService/ListCloudEvents"
	FetchService_ListCloudEventsFromKeys_FullMethodName = "/grpc.FetchService/ListCloudEventsFromKeys"
)

Variables

View Source 
var FetchService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc.FetchService",
	HandlerType: (*FetchServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetLatestMetadata",
			Handler:    _FetchService_GetLatestMetadata_Handler,
		},
		{
			MethodName: "ListMetadata",
			Handler:    _FetchService_ListMetadata_Handler,
		},
		{
			MethodName: "GetLatestCloudEvent",
			Handler:    _FetchService_GetLatestCloudEvent_Handler,
		},
		{
			MethodName: "ListCloudEvents",
			Handler:    _FetchService_ListCloudEvents_Handler,
		},
		{
			MethodName: "ListCloudEventsFromKeys",
			Handler:    _FetchService_ListCloudEventsFromKeys_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/grpc/fetch-api.proto",
}

FetchService_ServiceDesc is the grpc.ServiceDesc for FetchService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pkg_grpc_cloudevent_proto protoreflect.FileDescriptor
View Source 
var File_pkg_grpc_fetch_api_proto protoreflect.FileDescriptor

Functions

func RegisterFetchServiceServer 

func RegisterFetchServiceServer(s grpc.ServiceRegistrar, srv FetchServiceServer)

Types

type CloudEvent added in v0.0.3 

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
}

CloudEvent represents a CloudEvent with a header and data.

func (*CloudEvent) AsCloudEvent added in v0.0.3 

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

AsCloudEvent converts the CloudEvent to a cloudevent.CloudEvent[json.RawMessage].

func (*CloudEvent) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use CloudEvent.ProtoReflect.Descriptor instead.

func (*CloudEvent) GetData added in v0.0.3 

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

func (*CloudEvent) GetHeader added in v0.0.3 

func (x *CloudEvent) GetHeader() *CloudEventHeader

func (*CloudEvent) ProtoMessage added in v0.0.3 

func (*CloudEvent) ProtoMessage()

func (*CloudEvent) ProtoReflect added in v0.0.3 

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

func (*CloudEvent) Reset added in v0.0.3 

func (x *CloudEvent) Reset()

func (*CloudEvent) String added in v0.0.3 

func (x *CloudEvent) String() string

type CloudEventHeader added in v0.0.3 

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 `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

CloudEventHeader represents the header structure of a CloudEvent.

func (*CloudEventHeader) AsCloudEventHeader added in v0.0.3 

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

AsCloudEventHeader converts the CloudEventHeader to a cloudevent.CloudEventHeader.

func (*CloudEventHeader) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use CloudEventHeader.ProtoReflect.Descriptor instead.

func (*CloudEventHeader) GetDataContentType added in v0.0.3 

func (x *CloudEventHeader) GetDataContentType() string

func (*CloudEventHeader) GetDataSchema added in v0.0.3 

func (x *CloudEventHeader) GetDataSchema() string

func (*CloudEventHeader) GetDataVersion added in v0.0.3 

func (x *CloudEventHeader) GetDataVersion() string

func (*CloudEventHeader) GetExtras added in v0.0.3 

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

func (*CloudEventHeader) GetId added in v0.0.3 

func (x *CloudEventHeader) GetId() string

func (*CloudEventHeader) GetProducer added in v0.0.3 

func (x *CloudEventHeader) GetProducer() string

func (*CloudEventHeader) GetSource added in v0.0.3 

func (x *CloudEventHeader) GetSource() string

func (*CloudEventHeader) GetSpecVersion added in v0.0.3 

func (x *CloudEventHeader) GetSpecVersion() string

func (*CloudEventHeader) GetSubject added in v0.0.3 

func (x *CloudEventHeader) GetSubject() string

func (*CloudEventHeader) GetTime added in v0.0.3 

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

func (*CloudEventHeader) GetType added in v0.0.3 

func (x *CloudEventHeader) GetType() string

func (*CloudEventHeader) ProtoMessage added in v0.0.3 

func (*CloudEventHeader) ProtoMessage()

func (*CloudEventHeader) ProtoReflect added in v0.0.3 

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

func (*CloudEventHeader) Reset added in v0.0.3 

func (x *CloudEventHeader) Reset()

func (*CloudEventHeader) String added in v0.0.3 

func (x *CloudEventHeader) String() string

type CloudEventMetadata added in v0.0.3 

type CloudEventMetadata 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.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*CloudEventMetadata) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use CloudEventMetadata.ProtoReflect.Descriptor instead.

func (*CloudEventMetadata) GetHeader added in v0.0.3 

func (x *CloudEventMetadata) GetHeader() *CloudEventHeader

func (*CloudEventMetadata) GetKey added in v0.0.3 

func (x *CloudEventMetadata) GetKey() string

func (*CloudEventMetadata) ProtoMessage added in v0.0.3 

func (*CloudEventMetadata) ProtoMessage()

func (*CloudEventMetadata) ProtoReflect added in v0.0.3 

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

func (*CloudEventMetadata) Reset added in v0.0.3 

func (x *CloudEventMetadata) Reset()

func (*CloudEventMetadata) String added in v0.0.3 

func (x *CloudEventMetadata) String() string

type FetchServiceClient 

type FetchServiceClient interface {
	// GetLatestMetadatareturns the latest index key for the given options
	GetLatestMetadata(ctx context.Context, in *GetLatestMetadataRequest, opts ...grpc.CallOption) (*GetLatestMetadataResponse, error)
	// ListMetadata fetches and returns the list of cloud event metadata objects that match the specified options
	ListMetadata(ctx context.Context, in *ListMetadataRequest, opts ...grpc.CallOption) (*ListMetadataResponse, 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
	ListCloudEventsFromKeys(ctx context.Context, in *ListCloudEventsFromKeysRequest, opts ...grpc.CallOption) (*ListCloudEventsFromKeysResponse, error)
}

FetchServiceClient is the client API for FetchService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

FetchService defines the gRPC service for fetching DIMO objects

func NewFetchServiceClient 

func NewFetchServiceClient(cc grpc.ClientConnInterface) FetchServiceClient

type FetchServiceServer 

type FetchServiceServer interface {
	// GetLatestMetadatareturns the latest index key for the given options
	GetLatestMetadata(context.Context, *GetLatestMetadataRequest) (*GetLatestMetadataResponse, error)
	// ListMetadata fetches and returns the list of cloud event metadata objects that match the specified options
	ListMetadata(context.Context, *ListMetadataRequest) (*ListMetadataResponse, 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
	ListCloudEventsFromKeys(context.Context, *ListCloudEventsFromKeysRequest) (*ListCloudEventsFromKeysResponse, error)
	// contains filtered or unexported methods
}

FetchServiceServer is the server API for FetchService service. All implementations must embed UnimplementedFetchServiceServer for forward compatibility.

FetchService defines the gRPC service for fetching DIMO objects

type GetLatestCloudEventRequest added in v0.0.3 

type GetLatestCloudEventRequest struct {

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

GetLatestCloudEventRequest includes search options to filter the events.

func (*GetLatestCloudEventRequest) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use GetLatestCloudEventRequest.ProtoReflect.Descriptor instead.

func (*GetLatestCloudEventRequest) GetOptions added in v0.0.3 

func (x *GetLatestCloudEventRequest) GetOptions() *SearchOptions

func (*GetLatestCloudEventRequest) ProtoMessage added in v0.0.3 

func (*GetLatestCloudEventRequest) ProtoMessage()

func (*GetLatestCloudEventRequest) ProtoReflect added in v0.0.3 

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

func (*GetLatestCloudEventRequest) Reset added in v0.0.3 

func (x *GetLatestCloudEventRequest) Reset()

func (*GetLatestCloudEventRequest) String added in v0.0.3 

func (x *GetLatestCloudEventRequest) String() string

type GetLatestCloudEventResponse added in v0.0.3 

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
}

GetLatestCloudEventResponse provides the data retrieved from the latest cloud event.

func (*GetLatestCloudEventResponse) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use GetLatestCloudEventResponse.ProtoReflect.Descriptor instead.

func (*GetLatestCloudEventResponse) GetCloudEvent added in v0.0.3 

func (x *GetLatestCloudEventResponse) GetCloudEvent() *CloudEvent

func (*GetLatestCloudEventResponse) ProtoMessage added in v0.0.3 

func (*GetLatestCloudEventResponse) ProtoMessage()

func (*GetLatestCloudEventResponse) ProtoReflect added in v0.0.3 

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

func (*GetLatestCloudEventResponse) Reset added in v0.0.3 

func (x *GetLatestCloudEventResponse) Reset()

func (*GetLatestCloudEventResponse) String added in v0.0.3 

func (x *GetLatestCloudEventResponse) String() string

type GetLatestMetadataRequest added in v0.0.3 

type GetLatestMetadataRequest struct {
	Options *SearchOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

GetLatestMetadataRequest includes search options to filter the events.

func (*GetLatestMetadataRequest) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use GetLatestMetadataRequest.ProtoReflect.Descriptor instead.

func (*GetLatestMetadataRequest) GetOptions added in v0.0.3 

func (x *GetLatestMetadataRequest) GetOptions() *SearchOptions

func (*GetLatestMetadataRequest) ProtoMessage added in v0.0.3 

func (*GetLatestMetadataRequest) ProtoMessage()

func (*GetLatestMetadataRequest) ProtoReflect added in v0.0.3 

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

func (*GetLatestMetadataRequest) Reset added in v0.0.3 

func (x *GetLatestMetadataRequest) Reset()

func (*GetLatestMetadataRequest) String added in v0.0.3 

func (x *GetLatestMetadataRequest) String() string

type GetLatestMetadataResponse added in v0.0.3 

type GetLatestMetadataResponse struct {

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

GetLatestMetadataResponse provides the latest metadata retrieved for the specified search criteria.

func (*GetLatestMetadataResponse) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use GetLatestMetadataResponse.ProtoReflect.Descriptor instead.

func (*GetLatestMetadataResponse) GetMetadata added in v0.0.3 

func (x *GetLatestMetadataResponse) GetMetadata() *CloudEventMetadata

func (*GetLatestMetadataResponse) ProtoMessage added in v0.0.3 

func (*GetLatestMetadataResponse) ProtoMessage()

func (*GetLatestMetadataResponse) ProtoReflect added in v0.0.3 

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

func (*GetLatestMetadataResponse) Reset added in v0.0.3 

func (x *GetLatestMetadataResponse) Reset()

func (*GetLatestMetadataResponse) String added in v0.0.3 

func (x *GetLatestMetadataResponse) String() string

type ListCloudEventsFromKeysRequest added in v0.0.3 

type ListCloudEventsFromKeysRequest struct {

	// The index_keys that will be retrieved.
	IndexKeys []string `protobuf:"bytes,1,rep,name=index_keys,json=indexKeys,proto3" json:"index_keys,omitempty"`
	// contains filtered or unexported fields
}

ListCloudEventsFromKeysRequest includes the index key to filter the events.

func (*ListCloudEventsFromKeysRequest) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use ListCloudEventsFromKeysRequest.ProtoReflect.Descriptor instead.

func (*ListCloudEventsFromKeysRequest) GetIndexKeys added in v0.0.3 

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

func (*ListCloudEventsFromKeysRequest) ProtoMessage added in v0.0.3 

func (*ListCloudEventsFromKeysRequest) ProtoMessage()

func (*ListCloudEventsFromKeysRequest) ProtoReflect added in v0.0.3 

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

func (*ListCloudEventsFromKeysRequest) Reset added in v0.0.3 

func (x *ListCloudEventsFromKeysRequest) Reset()

func (*ListCloudEventsFromKeysRequest) String added in v0.0.3 

func (x *ListCloudEventsFromKeysRequest) String() string

type ListCloudEventsFromKeysResponse added in v0.0.3 

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
}

ListCloudEventsFromNameResponse provides the list of data retrieved from the objects.

func (*ListCloudEventsFromKeysResponse) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use ListCloudEventsFromKeysResponse.ProtoReflect.Descriptor instead.

func (*ListCloudEventsFromKeysResponse) GetCloudEvents added in v0.0.3 

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

func (*ListCloudEventsFromKeysResponse) ProtoMessage added in v0.0.3 

func (*ListCloudEventsFromKeysResponse) ProtoMessage()

func (*ListCloudEventsFromKeysResponse) ProtoReflect added in v0.0.3 

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

func (*ListCloudEventsFromKeysResponse) Reset added in v0.0.3 

func (x *ListCloudEventsFromKeysResponse) Reset()

func (*ListCloudEventsFromKeysResponse) String added in v0.0.3 

func (x *ListCloudEventsFromKeysResponse) String() string

type ListCloudEventsRequest added in v0.0.3 

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"`
	// contains filtered or unexported fields
}

ListCloudEventsRequest includes search options to filter the events.

func (*ListCloudEventsRequest) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use ListCloudEventsRequest.ProtoReflect.Descriptor instead.

func (*ListCloudEventsRequest) GetLimit added in v0.0.3 

func (x *ListCloudEventsRequest) GetLimit() int32

func (*ListCloudEventsRequest) GetOptions added in v0.0.3 

func (x *ListCloudEventsRequest) GetOptions() *SearchOptions

func (*ListCloudEventsRequest) ProtoMessage added in v0.0.3 

func (*ListCloudEventsRequest) ProtoMessage()

func (*ListCloudEventsRequest) ProtoReflect added in v0.0.3 

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

func (*ListCloudEventsRequest) Reset added in v0.0.3 

func (x *ListCloudEventsRequest) Reset()

func (*ListCloudEventsRequest) String added in v0.0.3 

func (x *ListCloudEventsRequest) String() string

type ListCloudEventsResponse added in v0.0.3 

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
}

ListCloudEventsResponse provides the list of data retrieved from the objects.

func (*ListCloudEventsResponse) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use ListCloudEventsResponse.ProtoReflect.Descriptor instead.

func (*ListCloudEventsResponse) GetCloudEvents added in v0.0.3 

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

func (*ListCloudEventsResponse) ProtoMessage added in v0.0.3 

func (*ListCloudEventsResponse) ProtoMessage()

func (*ListCloudEventsResponse) ProtoReflect added in v0.0.3 

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

func (*ListCloudEventsResponse) Reset added in v0.0.3 

func (x *ListCloudEventsResponse) Reset()

func (*ListCloudEventsResponse) String added in v0.0.3 

func (x *ListCloudEventsResponse) String() string

type ListMetadataRequest added in v0.0.3 

type ListMetadataRequest struct {

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

ListMetadataRequest includes search options to filter the events.

func (*ListMetadataRequest) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use ListMetadataRequest.ProtoReflect.Descriptor instead.

func (*ListMetadataRequest) GetLimit added in v0.0.3 

func (x *ListMetadataRequest) GetLimit() int32

func (*ListMetadataRequest) GetOptions added in v0.0.3 

func (x *ListMetadataRequest) GetOptions() *SearchOptions

func (*ListMetadataRequest) ProtoMessage added in v0.0.3 

func (*ListMetadataRequest) ProtoMessage()

func (*ListMetadataRequest) ProtoReflect added in v0.0.3 

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

func (*ListMetadataRequest) Reset added in v0.0.3 

func (x *ListMetadataRequest) Reset()

func (*ListMetadataRequest) String added in v0.0.3 

func (x *ListMetadataRequest) String() string

type ListMetadataResponse added in v0.0.3 

type ListMetadataResponse struct {

	// The list of metadata objects retrieved for the specified search criteria.
	MetadataList []*CloudEventMetadata `protobuf:"bytes,1,rep,name=metadata_list,json=metadataList,proto3" json:"metadata_list,omitempty"`
	// contains filtered or unexported fields
}

ListMetadataResponse returns the list of metadata for cloud events retrieved for the specified search criteria.

func (*ListMetadataResponse) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use ListMetadataResponse.ProtoReflect.Descriptor instead.

func (*ListMetadataResponse) GetMetadataList added in v0.0.3 

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

func (*ListMetadataResponse) ProtoMessage added in v0.0.3 

func (*ListMetadataResponse) ProtoMessage()

func (*ListMetadataResponse) ProtoReflect added in v0.0.3 

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

func (*ListMetadataResponse) Reset added in v0.0.3 

func (x *ListMetadataResponse) Reset()

func (*ListMetadataResponse) String added in v0.0.3 

func (x *ListMetadataResponse) String() string

type SearchOptions 

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"`
	// Additional optional metadata for more precise filtering.
	Optional *wrapperspb.StringValue `protobuf:"bytes,10,opt,name=optional,proto3" json:"optional,omitempty"`
	// contains filtered or unexported fields
}

SearchOptions provides filtering options to narrow down the search results for objects based on various criteria. If a field is not set, it is not used for filtering.

func (*SearchOptions) Descriptor deprecated 

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

Deprecated: Use SearchOptions.ProtoReflect.Descriptor instead.

func (*SearchOptions) GetAfter 

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

func (*SearchOptions) GetBefore 

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

func (*SearchOptions) GetDataVersion added in v0.0.3 

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

func (*SearchOptions) GetOptional 

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

func (*SearchOptions) GetProducer 

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

func (*SearchOptions) GetSource 

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

func (*SearchOptions) GetSubject 

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

func (*SearchOptions) GetTimestampAsc 

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

func (*SearchOptions) GetType added in v0.0.3 

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

func (*SearchOptions) ProtoMessage 

func (*SearchOptions) ProtoMessage()

func (*SearchOptions) ProtoReflect 

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

func (*SearchOptions) Reset 

func (x *SearchOptions) Reset()

func (*SearchOptions) String 

func (x *SearchOptions) String() string

type UnimplementedFetchServiceServer 

type UnimplementedFetchServiceServer struct{}

UnimplementedFetchServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedFetchServiceServer) GetLatestCloudEvent added in v0.0.3 

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

func (UnimplementedFetchServiceServer) GetLatestMetadata added in v0.0.3 

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

func (UnimplementedFetchServiceServer) ListCloudEvents added in v0.0.3 

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

func (UnimplementedFetchServiceServer) ListCloudEventsFromKeys added in v0.0.3 

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

func (UnimplementedFetchServiceServer) ListMetadata added in v0.0.3 

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

type UnsafeFetchServiceServer 

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

UnsafeFetchServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FetchServiceServer will result in compilation errors.

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.