v1

package
v0.0.0-...-574ae56 Latest Latest
Warning

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

 Go to latest Published: Jul 14, 2023 License: Apache-2.0 Imports: 10 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_cloudevents_proto protoreflect.FileDescriptor
View Source 
var File_cloudevents_service_proto protoreflect.FileDescriptor
View Source 
var File_partition_proto protoreflect.FileDescriptor

Functions

func RegisterPrivateKeyValueServiceServer 

func RegisterPrivateKeyValueServiceServer(s *grpc.Server, srv PrivateKeyValueServiceServer)

func RegisterPublicEventServiceServer 

func RegisterPublicEventServiceServer(s *grpc.Server, srv PublicEventServiceServer)

Types

type CloudEvent 

type CloudEvent struct {

	// Required Attributes
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Source      string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // URI-reference
	SpecVersion string `protobuf:"bytes,3,opt,name=spec_version,json=specVersion,proto3" json:"spec_version,omitempty"`
	Type        string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// Optional & Extension Attributes
	Attributes map[string]*CloudEvent_CloudEventAttributeValue `` /* 161-byte string literal not displayed */
	// -- CloudEvent Data (Bytes, Text, or Proto)
	//
	// Types that are assignable to Data:
	//
	//	*CloudEvent_BinaryData
	//	*CloudEvent_TextData
	//	*CloudEvent_ProtoData
	Data isCloudEvent_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*CloudEvent) Descriptor deprecated 

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

Deprecated: Use CloudEvent.ProtoReflect.Descriptor instead.

func (*CloudEvent) GetAttributes 

func (x *CloudEvent) GetAttributes() map[string]*CloudEvent_CloudEventAttributeValue

func (*CloudEvent) GetBinaryData 

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

func (*CloudEvent) GetData 

func (m *CloudEvent) GetData() isCloudEvent_Data

func (*CloudEvent) GetId 

func (x *CloudEvent) GetId() string

func (*CloudEvent) GetProtoData 

func (x *CloudEvent) GetProtoData() *anypb.Any

func (*CloudEvent) GetSource 

func (x *CloudEvent) GetSource() string

func (*CloudEvent) GetSpecVersion 

func (x *CloudEvent) GetSpecVersion() string

func (*CloudEvent) GetTextData 

func (x *CloudEvent) GetTextData() string

func (*CloudEvent) GetType 

func (x *CloudEvent) GetType() string

func (*CloudEvent) ProtoMessage 

func (*CloudEvent) ProtoMessage()

func (*CloudEvent) ProtoReflect 

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

func (*CloudEvent) Reset 

func (x *CloudEvent) Reset()

func (*CloudEvent) String 

func (x *CloudEvent) String() string

type CloudEventBatch 

type CloudEventBatch struct {
	Events []*CloudEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*CloudEventBatch) Descriptor deprecated 

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

Deprecated: Use CloudEventBatch.ProtoReflect.Descriptor instead.

func (*CloudEventBatch) GetEvents 

func (x *CloudEventBatch) GetEvents() []*CloudEvent

func (*CloudEventBatch) ProtoMessage 

func (*CloudEventBatch) ProtoMessage()

func (*CloudEventBatch) ProtoReflect 

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

func (*CloudEventBatch) Reset 

func (x *CloudEventBatch) Reset()

func (*CloudEventBatch) String 

func (x *CloudEventBatch) String() string

type CloudEventResponse 

type CloudEventResponse struct {
	Offset    uint64                 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Event     *CloudEvent            `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	Key       []byte                 `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Slot      string                 `protobuf:"bytes,4,opt,name=slot,proto3" json:"slot,omitempty"`
	EventType string                 `protobuf:"bytes,5,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*CloudEventResponse) Descriptor deprecated 

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

Deprecated: Use CloudEventResponse.ProtoReflect.Descriptor instead.

func (*CloudEventResponse) GetEvent 

func (x *CloudEventResponse) GetEvent() *CloudEvent

func (*CloudEventResponse) GetEventType 

func (x *CloudEventResponse) GetEventType() string

func (*CloudEventResponse) GetKey 

func (x *CloudEventResponse) GetKey() []byte

func (*CloudEventResponse) GetOffset 

func (x *CloudEventResponse) GetOffset() uint64

func (*CloudEventResponse) GetSlot 

func (x *CloudEventResponse) GetSlot() string

func (*CloudEventResponse) GetTimestamp 

func (x *CloudEventResponse) GetTimestamp() *timestamppb.Timestamp

func (*CloudEventResponse) ProtoMessage 

func (*CloudEventResponse) ProtoMessage()

func (*CloudEventResponse) ProtoReflect 

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

func (*CloudEventResponse) Reset 

func (x *CloudEventResponse) Reset()

func (*CloudEventResponse) String 

func (x *CloudEventResponse) String() string

type CloudEventStoreRequest 

type CloudEventStoreRequest struct {
	Event     *CloudEvent            `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Slot      string                 `protobuf:"bytes,2,opt,name=slot,proto3" json:"slot,omitempty"`
	EventType string                 `protobuf:"bytes,3,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*CloudEventStoreRequest) Descriptor deprecated 

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

Deprecated: Use CloudEventStoreRequest.ProtoReflect.Descriptor instead.

func (*CloudEventStoreRequest) GetEvent 

func (x *CloudEventStoreRequest) GetEvent() *CloudEvent

func (*CloudEventStoreRequest) GetEventType 

func (x *CloudEventStoreRequest) GetEventType() string

func (*CloudEventStoreRequest) GetSlot 

func (x *CloudEventStoreRequest) GetSlot() string

func (*CloudEventStoreRequest) GetTimestamp 

func (x *CloudEventStoreRequest) GetTimestamp() *timestamppb.Timestamp

func (*CloudEventStoreRequest) ProtoMessage 

func (*CloudEventStoreRequest) ProtoMessage()

func (*CloudEventStoreRequest) ProtoReflect 

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

func (*CloudEventStoreRequest) Reset 

func (x *CloudEventStoreRequest) Reset()

func (*CloudEventStoreRequest) String 

func (x *CloudEventStoreRequest) String() string

type CloudEventStoreResult 

type CloudEventStoreResult struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*CloudEventStoreResult) Descriptor deprecated 

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

Deprecated: Use CloudEventStoreResult.ProtoReflect.Descriptor instead.

func (*CloudEventStoreResult) GetMessage 

func (x *CloudEventStoreResult) GetMessage() string

func (*CloudEventStoreResult) ProtoMessage 

func (*CloudEventStoreResult) ProtoMessage()

func (*CloudEventStoreResult) ProtoReflect 

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

func (*CloudEventStoreResult) Reset 

func (x *CloudEventStoreResult) Reset()

func (*CloudEventStoreResult) String 

func (x *CloudEventStoreResult) String() string

type CloudEvent_BinaryData 

type CloudEvent_BinaryData struct {
	BinaryData []byte `protobuf:"bytes,6,opt,name=binary_data,json=binaryData,proto3,oneof"`
}

type CloudEvent_CloudEventAttributeValue 

type CloudEvent_CloudEventAttributeValue struct {

	// Types that are assignable to Attr:
	//
	//	*CloudEvent_CloudEventAttributeValue_CeBoolean
	//	*CloudEvent_CloudEventAttributeValue_CeInteger
	//	*CloudEvent_CloudEventAttributeValue_CeString
	//	*CloudEvent_CloudEventAttributeValue_CeBytes
	//	*CloudEvent_CloudEventAttributeValue_CeUri
	//	*CloudEvent_CloudEventAttributeValue_CeUriRef
	//	*CloudEvent_CloudEventAttributeValue_CeTimestamp
	Attr isCloudEvent_CloudEventAttributeValue_Attr `protobuf_oneof:"attr"`
	// contains filtered or unexported fields
}

func (*CloudEvent_CloudEventAttributeValue) Descriptor deprecated 

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

Deprecated: Use CloudEvent_CloudEventAttributeValue.ProtoReflect.Descriptor instead.

func (*CloudEvent_CloudEventAttributeValue) GetAttr 

func (m *CloudEvent_CloudEventAttributeValue) GetAttr() isCloudEvent_CloudEventAttributeValue_Attr

func (*CloudEvent_CloudEventAttributeValue) GetCeBoolean 

func (x *CloudEvent_CloudEventAttributeValue) GetCeBoolean() bool

func (*CloudEvent_CloudEventAttributeValue) GetCeBytes 

func (x *CloudEvent_CloudEventAttributeValue) GetCeBytes() []byte

func (*CloudEvent_CloudEventAttributeValue) GetCeInteger 

func (x *CloudEvent_CloudEventAttributeValue) GetCeInteger() int32

func (*CloudEvent_CloudEventAttributeValue) GetCeString 

func (x *CloudEvent_CloudEventAttributeValue) GetCeString() string

func (*CloudEvent_CloudEventAttributeValue) GetCeTimestamp 

func (x *CloudEvent_CloudEventAttributeValue) GetCeTimestamp() *timestamppb.Timestamp

func (*CloudEvent_CloudEventAttributeValue) GetCeUri 

func (x *CloudEvent_CloudEventAttributeValue) GetCeUri() string

func (*CloudEvent_CloudEventAttributeValue) GetCeUriRef 

func (x *CloudEvent_CloudEventAttributeValue) GetCeUriRef() string

func (*CloudEvent_CloudEventAttributeValue) ProtoMessage 

func (*CloudEvent_CloudEventAttributeValue) ProtoMessage()

func (*CloudEvent_CloudEventAttributeValue) ProtoReflect 

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

func (*CloudEvent_CloudEventAttributeValue) Reset 

func (x *CloudEvent_CloudEventAttributeValue) Reset()

func (*CloudEvent_CloudEventAttributeValue) String 

func (x *CloudEvent_CloudEventAttributeValue) String() string

type CloudEvent_CloudEventAttributeValue_CeBoolean 

type CloudEvent_CloudEventAttributeValue_CeBoolean struct {
	CeBoolean bool `protobuf:"varint,1,opt,name=ce_boolean,json=ceBoolean,proto3,oneof"`
}

type CloudEvent_CloudEventAttributeValue_CeBytes 

type CloudEvent_CloudEventAttributeValue_CeBytes struct {
	CeBytes []byte `protobuf:"bytes,4,opt,name=ce_bytes,json=ceBytes,proto3,oneof"`
}

type CloudEvent_CloudEventAttributeValue_CeInteger 

type CloudEvent_CloudEventAttributeValue_CeInteger struct {
	CeInteger int32 `protobuf:"varint,2,opt,name=ce_integer,json=ceInteger,proto3,oneof"`
}

type CloudEvent_CloudEventAttributeValue_CeString 

type CloudEvent_CloudEventAttributeValue_CeString struct {
	CeString string `protobuf:"bytes,3,opt,name=ce_string,json=ceString,proto3,oneof"`
}

type CloudEvent_CloudEventAttributeValue_CeTimestamp 

type CloudEvent_CloudEventAttributeValue_CeTimestamp struct {
	CeTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=ce_timestamp,json=ceTimestamp,proto3,oneof"`
}

type CloudEvent_CloudEventAttributeValue_CeUri 

type CloudEvent_CloudEventAttributeValue_CeUri struct {
	CeUri string `protobuf:"bytes,5,opt,name=ce_uri,json=ceUri,proto3,oneof"`
}

type CloudEvent_CloudEventAttributeValue_CeUriRef 

type CloudEvent_CloudEventAttributeValue_CeUriRef struct {
	CeUriRef string `protobuf:"bytes,6,opt,name=ce_uri_ref,json=ceUriRef,proto3,oneof"`
}

type CloudEvent_ProtoData 

type CloudEvent_ProtoData struct {
	ProtoData *anypb.Any `protobuf:"bytes,8,opt,name=proto_data,json=protoData,proto3,oneof"`
}

type CloudEvent_TextData 

type CloudEvent_TextData struct {
	TextData string `protobuf:"bytes,7,opt,name=text_data,json=textData,proto3,oneof"`
}

type EventGetRequest 

type EventGetRequest struct {
	Id     string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Source string  `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Slot   string  `protobuf:"bytes,3,opt,name=slot,proto3" json:"slot,omitempty"`
	Type   *string `protobuf:"bytes,4,opt,name=type,proto3,oneof" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*EventGetRequest) Descriptor deprecated 

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

Deprecated: Use EventGetRequest.ProtoReflect.Descriptor instead.

func (*EventGetRequest) GetId 

func (x *EventGetRequest) GetId() string

func (*EventGetRequest) GetSlot 

func (x *EventGetRequest) GetSlot() string

func (*EventGetRequest) GetSource 

func (x *EventGetRequest) GetSource() string

func (*EventGetRequest) GetType 

func (x *EventGetRequest) GetType() string

func (*EventGetRequest) ProtoMessage 

func (*EventGetRequest) ProtoMessage()

func (*EventGetRequest) ProtoReflect 

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

func (*EventGetRequest) Reset 

func (x *EventGetRequest) Reset()

func (*EventGetRequest) String 

func (x *EventGetRequest) String() string

type GetRequest 

type GetRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() []byte

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetValue 

func (x *GetResponse) GetValue() []byte

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type Partition 

type Partition struct {
	Begin        uint64   `protobuf:"varint,1,opt,name=begin,proto3" json:"begin,omitempty"`
	StoreAddress []string `protobuf:"bytes,2,rep,name=store_address,json=storeAddress,proto3" json:"store_address,omitempty"`
	CreateTime   uint64   `protobuf:"varint,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Partition) Descriptor deprecated 

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

Deprecated: Use Partition.ProtoReflect.Descriptor instead.

func (*Partition) GetBegin 

func (x *Partition) GetBegin() uint64

func (*Partition) GetCreateTime 

func (x *Partition) GetCreateTime() uint64

func (*Partition) GetStoreAddress 

func (x *Partition) GetStoreAddress() []string

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) ProtoReflect 

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

func (*Partition) Reset 

func (x *Partition) Reset()

func (*Partition) String 

func (x *Partition) String() string

type PrivateKeyValueServiceClient 

type PrivateKeyValueServiceClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
}

PrivateKeyValueServiceClient is the client API for PrivateKeyValueService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPrivateKeyValueServiceClient 

func NewPrivateKeyValueServiceClient(cc grpc.ClientConnInterface) PrivateKeyValueServiceClient

type PrivateKeyValueServiceServer 

type PrivateKeyValueServiceServer interface {
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Put(context.Context, *PutRequest) (*PutResponse, error)
}

PrivateKeyValueServiceServer is the server API for PrivateKeyValueService service.

type PublicEventServiceClient 

type PublicEventServiceClient interface {
	Store(ctx context.Context, in *CloudEventStoreRequest, opts ...grpc.CallOption) (*CloudEventStoreResult, error)
	ReStore(ctx context.Context, in *CloudEventStoreRequest, opts ...grpc.CallOption) (*CloudEventStoreResult, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (PublicEventService_SubscribeClient, error)
	Get(ctx context.Context, in *EventGetRequest, opts ...grpc.CallOption) (*CloudEventResponse, error)
}

PublicEventServiceClient is the client API for PublicEventService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPublicEventServiceClient 

func NewPublicEventServiceClient(cc grpc.ClientConnInterface) PublicEventServiceClient

type PublicEventServiceServer 

type PublicEventServiceServer interface {
	Store(context.Context, *CloudEventStoreRequest) (*CloudEventStoreResult, error)
	ReStore(context.Context, *CloudEventStoreRequest) (*CloudEventStoreResult, error)
	Subscribe(*SubscribeRequest, PublicEventService_SubscribeServer) error
	Get(context.Context, *EventGetRequest) (*CloudEventResponse, error)
}

PublicEventServiceServer is the server API for PublicEventService service.

type PublicEventService_SubscribeClient 

type PublicEventService_SubscribeClient interface {
	Recv() (*CloudEventResponse, error)
	grpc.ClientStream
}

type PublicEventService_SubscribeServer 

type PublicEventService_SubscribeServer interface {
	Send(*CloudEventResponse) error
	grpc.ServerStream
}

type PutRequest 

type PutRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() []byte

func (*PutRequest) GetValue 

func (x *PutRequest) GetValue() []byte

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

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

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type PutResponse 

type PutResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetOk 

func (x *PutResponse) GetOk() bool

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

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

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) String 

func (x *PutResponse) String() string

type SubscribeRequest 

type SubscribeRequest struct {
	Type         *string `protobuf:"bytes,1,opt,name=type,proto3,oneof" json:"type,omitempty"`
	EventTypeReg *string `protobuf:"bytes,2,opt,name=event_type_reg,json=eventTypeReg,proto3,oneof" json:"event_type_reg,omitempty"`
	Offset       *uint64 `protobuf:"varint,3,opt,name=offset,proto3,oneof" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetEventTypeReg 

func (x *SubscribeRequest) GetEventTypeReg() string

func (*SubscribeRequest) GetOffset 

func (x *SubscribeRequest) GetOffset() uint64

func (*SubscribeRequest) GetType 

func (x *SubscribeRequest) GetType() string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type UnimplementedPrivateKeyValueServiceServer 

type UnimplementedPrivateKeyValueServiceServer struct {
}

UnimplementedPrivateKeyValueServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPrivateKeyValueServiceServer) Get 

func (*UnimplementedPrivateKeyValueServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (*UnimplementedPrivateKeyValueServiceServer) Put 

func (*UnimplementedPrivateKeyValueServiceServer) Put(context.Context, *PutRequest) (*PutResponse, error)

type UnimplementedPublicEventServiceServer 

type UnimplementedPublicEventServiceServer struct {
}

UnimplementedPublicEventServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPublicEventServiceServer) Get 

func (*UnimplementedPublicEventServiceServer) Get(context.Context, *EventGetRequest) (*CloudEventResponse, error)

func (*UnimplementedPublicEventServiceServer) ReStore 

func (*UnimplementedPublicEventServiceServer) ReStore(context.Context, *CloudEventStoreRequest) (*CloudEventStoreResult, error)

func (*UnimplementedPublicEventServiceServer) Store 

func (*UnimplementedPublicEventServiceServer) Store(context.Context, *CloudEventStoreRequest) (*CloudEventStoreResult, error)

func (*UnimplementedPublicEventServiceServer) Subscribe 

func (*UnimplementedPublicEventServiceServer) Subscribe(*SubscribeRequest, PublicEventService_SubscribeServer) 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.