Documentation ¶
Index ¶
- Variables
- func GetEventDataContentType(ctx context.Context) string
- func GetEventDataSchema(ctx context.Context) string
- func GetEventID(ctx context.Context) string
- func GetEventSource(ctx context.Context) string
- func GetEventSpecVersion(ctx context.Context) string
- func GetEventSubject(ctx context.Context) string
- func GetEventTime(ctx context.Context) time.Time
- func GetEventType(ctx context.Context) string
- type Event
- func (x *Event) Default()
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetAttributes() map[string]*EventAttributeValue
- func (x *Event) GetBinaryData() []byte
- func (m *Event) GetData() isEvent_Data
- func (x *Event) GetDataAs(value interface{}) error
- func (x *Event) GetDataContentType() string
- func (x *Event) GetDataSchema() string
- func (x *Event) GetId() string
- func (x *Event) GetProtoData() *anypb.Any
- func (x *Event) GetSource() string
- func (x *Event) GetSpecVersion() string
- func (x *Event) GetSubject() string
- func (x *Event) GetTextData() string
- func (x *Event) GetTime() time.Time
- func (x *Event) GetType() string
- func (msg *Event) MarshalJSON() ([]byte, error)
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) SetData(value interface{}) error
- func (x *Event) SetDataContentType(value string)
- func (x *Event) SetDataSchema(value string)
- func (x *Event) SetExtension(name string, value interface{})
- func (x *Event) SetId(value string)
- func (x *Event) SetSource(value string)
- func (x *Event) SetSpecVersion(value string)
- func (x *Event) SetSubject(value string)
- func (x *Event) SetTime(value time.Time)
- func (x *Event) SetType(value string)
- func (x *Event) String() string
- func (msg *Event) UnmarshalJSON(b []byte) error
- func (m *Event) Validate() error
- func (m *Event) ValidateAll() error
- type EventAttributeValue
- func (x *EventAttributeValue) Default()
- func (*EventAttributeValue) Descriptor() ([]byte, []int)deprecated
- func (m *EventAttributeValue) GetAttr() isEventAttributeValue_Attr
- func (x *EventAttributeValue) GetCeBoolean() bool
- func (x *EventAttributeValue) GetCeBytes() []byte
- func (x *EventAttributeValue) GetCeInteger() int32
- func (x *EventAttributeValue) GetCeString() string
- func (x *EventAttributeValue) GetCeTimestamp() *timestamppb.Timestamp
- func (x *EventAttributeValue) GetCeUri() string
- func (x *EventAttributeValue) GetCeUriRef() string
- func (msg *EventAttributeValue) MarshalJSON() ([]byte, error)
- func (*EventAttributeValue) ProtoMessage()
- func (x *EventAttributeValue) ProtoReflect() protoreflect.Message
- func (x *EventAttributeValue) Reset()
- func (x *EventAttributeValue) String() string
- func (msg *EventAttributeValue) UnmarshalJSON(b []byte) error
- func (m *EventAttributeValue) Validate() error
- func (m *EventAttributeValue) ValidateAll() error
- type EventAttributeValueMultiError
- type EventAttributeValueValidationError
- func (e EventAttributeValueValidationError) Cause() error
- func (e EventAttributeValueValidationError) Error() string
- func (e EventAttributeValueValidationError) ErrorName() string
- func (e EventAttributeValueValidationError) Field() string
- func (e EventAttributeValueValidationError) Key() bool
- func (e EventAttributeValueValidationError) Reason() string
- type EventAttributeValue_CeBoolean
- type EventAttributeValue_CeBytes
- type EventAttributeValue_CeInteger
- type EventAttributeValue_CeString
- type EventAttributeValue_CeTimestamp
- type EventAttributeValue_CeUri
- type EventAttributeValue_CeUriRef
- type EventBatch
- func (x *EventBatch) Default()
- func (*EventBatch) Descriptor() ([]byte, []int)deprecated
- func (x *EventBatch) GetEvents() []*Event
- func (msg *EventBatch) MarshalJSON() ([]byte, error)
- func (*EventBatch) ProtoMessage()
- func (x *EventBatch) ProtoReflect() protoreflect.Message
- func (x *EventBatch) Reset()
- func (x *EventBatch) String() string
- func (msg *EventBatch) UnmarshalJSON(b []byte) error
- func (m *EventBatch) Validate() error
- func (m *EventBatch) ValidateAll() error
- type EventBatchMultiError
- type EventBatchValidationError
- type EventHandler
- type EventMultiError
- type EventService
- type EventServiceClient
- type EventValidationError
- type Event_BinaryData
- type Event_ProtoData
- type Event_TextData
- type NopEventServiceClient
- type PushEventRequest
- func (x *PushEventRequest) Default()
- func (*PushEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PushEventRequest) GetAttributes() map[string]string
- func (x *PushEventRequest) GetData() []byte
- func (x *PushEventRequest) GetEvent() *Event
- func (x *PushEventRequest) GetOrderingKey() string
- func (msg *PushEventRequest) MarshalJSON() ([]byte, error)
- func (*PushEventRequest) ProtoMessage()
- func (x *PushEventRequest) ProtoReflect() protoreflect.Message
- func (x *PushEventRequest) Reset()
- func (x *PushEventRequest) SetAttributes(attributes map[string]string) error
- func (x *PushEventRequest) SetData(data []byte) error
- func (x *PushEventRequest) String() string
- func (msg *PushEventRequest) UnmarshalJSON(b []byte) error
- func (m *PushEventRequest) Validate() error
- func (m *PushEventRequest) ValidateAll() error
- type PushEventRequestMultiError
- type PushEventRequestValidationError
- func (e PushEventRequestValidationError) Cause() error
- func (e PushEventRequestValidationError) Error() string
- func (e PushEventRequestValidationError) ErrorName() string
- func (e PushEventRequestValidationError) Field() string
- func (e PushEventRequestValidationError) Key() bool
- func (e PushEventRequestValidationError) Reason() string
- type PushEventResponse
- func (x *PushEventResponse) Default()
- func (*PushEventResponse) Descriptor() ([]byte, []int)deprecated
- func (msg *PushEventResponse) MarshalJSON() ([]byte, error)
- func (*PushEventResponse) ProtoMessage()
- func (x *PushEventResponse) ProtoReflect() protoreflect.Message
- func (x *PushEventResponse) Reset()
- func (x *PushEventResponse) String() string
- func (msg *PushEventResponse) UnmarshalJSON(b []byte) error
- func (m *PushEventResponse) Validate() error
- func (m *PushEventResponse) ValidateAll() error
- type PushEventResponseMultiError
- type PushEventResponseValidationError
- func (e PushEventResponseValidationError) Cause() error
- func (e PushEventResponseValidationError) Error() string
- func (e PushEventResponseValidationError) ErrorName() string
- func (e PushEventResponseValidationError) Field() string
- func (e PushEventResponseValidationError) Key() bool
- func (e PushEventResponseValidationError) Reason() string
Constants ¶
This section is empty.
Variables ¶
var File_connect_event_v1_event_proto protoreflect.FileDescriptor
Functions ¶
func GetEventDataContentType ¶
GetEventDataContentType returns the event data schema from the incoming context.
func GetEventDataSchema ¶
GetEventDataSchema returns the event data schema from the incoming context.
func GetEventID ¶
GetEventID returns the event id from the incoming context.
func GetEventSource ¶
GetEventSource returns the event source from the incoming context.
func GetEventSpecVersion ¶
GetEventSpecVersion returns the event spec version from the incoming context.
func GetEventSubject ¶
GetEventSubject returns the event subject from the incoming context.
func GetEventTime ¶
GetEventTime returns the event time from the incoming context.
func GetEventType ¶
GetEventType returns the event type from the incoming context.
Types ¶
type Event ¶
type Event struct { // Required. Id contains the event's identifier. Producers MUST ensure that // source + id is unique for each distinct event. If a duplicate event is // re-sent (e.g. due to a network error) it MAY have the same id. Consumers // MAY assume that Events with identical source and id are duplicates. // Example: 5cc0996e-facd-11ed-9c22-325096b39f47 Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Required. Source contains the context in which an event happened. Often // this will include information such as the type of the event source, the // organization publishing the event or the process that produced the event. // The exact syntax and semantics behind the data encoded in the URI is // defined by the event producer. Producers MUST ensure that source + id is // unique for each distinct event. // // Example: https://github.com/cloudevents, urn:uuid:6e8bc430-9c3a-11d9-9669-0800200c9a66, /cloudevents/spec/pull/123 Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // Required. SpecVerion is the version of the CloudEvents specification which // the event uses. This enables the interpretation of the context. Compliant // event producers MUST use a value of 1.0 when referring to this version of // the specification. Currently, this attribute will only have the 'major' and // 'minor' version numbers included in it. This allows for 'patch' changes to // the specification to be made without changing this property's value in the // serialization. Note: for 'release candidate' releases a suffix might be // used for testing purposes. SpecVersion string `protobuf:"bytes,3,opt,name=spec_version,json=specVersion,proto3" json:"spec_version,omitempty"` // Required. Type attribute contains a value describing the type of event // related to the originating occurrence. Often this attribute is used for // routing, observability, policy enforcement, etc. // // Example: com.github.pull_request.opened, com.example.object.deleted Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` // Optional. Extra attributes. Attributes map[string]*EventAttributeValue `` /* 161-byte string literal not displayed */ // Optional. Contains the event's data. // // Types that are assignable to Data: // // *Event_BinaryData // *Event_TextData // *Event_ProtoData Data isEvent_Data `protobuf_oneof:"data"` // contains filtered or unexported fields }
Event represents an event.
func NewEvent ¶
func NewEvent() *Event
NewEvent returns a new instance of cloud.event.v1.Event message.
func (*Event) Descriptor
deprecated
func (*Event) GetAttributes ¶
func (x *Event) GetAttributes() map[string]*EventAttributeValue
func (*Event) GetBinaryData ¶
func (*Event) GetDataAs ¶
GetDataAs attempts to populate the provided data object with the event payload. The object should be a pointer type.
func (*Event) GetDataContentType ¶
GetDataContentType returns the DataContentType attribute.
func (*Event) GetDataSchema ¶
GetDataSchema returns the DataSchema attribute. It contains the schema that data adheres to. Incompatible changes to the schema SHOULD be reflected by a different URI.
func (*Event) GetProtoData ¶
func (*Event) GetSpecVersion ¶
func (*Event) GetSubject ¶
GetSubject returns the Subject attribute. It describes the subject of the event in the context of the event producer (identified by source). In publish-subscribe scenarios, a subscriber will typically subscribe to events emitted by a source, but the source identifier alone might not be sufficient as a qualifier for any specific event if the source context has internal sub-structure.
func (*Event) GetTextData ¶
func (*Event) GetTime ¶
GetTime returns the Time attribute. Timestamp of when the occurrence happened. If the time of the occurrence cannot be determined then this attribute MAY be set to some other time (such as the current time) by the CloudEvents producer, however all producers for the same source MUST be consistent in this respect. In other words, either they all use the actual time of the occurrence or they all use the same algorithm to determine the value used.
func (*Event) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
func (*Event) SetData ¶
SetData encodes the given payload with the given content type. If the provided payload is a byte array, when marshalled to json it will be encoded as base64. If the provided payload is different from byte array, datacodec.Encode is invoked to attempt a marshalling to byte array.
func (*Event) SetDataContentType ¶
SetDataContentType sets the DataContentType attribute.
func (*Event) SetDataSchema ¶
SetDataSchema sets the DataSchema attribute.
func (*Event) SetExtension ¶
SetExtension sets the Extension attribute.
func (*Event) SetSpecVersion ¶
SetSpecVersion sets the SpecVersion attribute.
func (*Event) SetSubject ¶
SetSubject sets the Subject attribute.
func (*Event) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
func (*Event) Validate ¶
Validate checks the field values on Event with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Event) ValidateAll ¶
ValidateAll checks the field values on Event with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EventMultiError, or nil if none found.
type EventAttributeValue ¶
type EventAttributeValue struct { // Types that are assignable to Attr: // // *EventAttributeValue_CeBoolean // *EventAttributeValue_CeInteger // *EventAttributeValue_CeString // *EventAttributeValue_CeBytes // *EventAttributeValue_CeUri // *EventAttributeValue_CeUriRef // *EventAttributeValue_CeTimestamp Attr isEventAttributeValue_Attr `protobuf_oneof:"attr"` // contains filtered or unexported fields }
EventAttributeValue represents an event attributes.
func (*EventAttributeValue) Default ¶
func (x *EventAttributeValue) Default()
func (*EventAttributeValue) Descriptor
deprecated
func (*EventAttributeValue) Descriptor() ([]byte, []int)
Deprecated: Use EventAttributeValue.ProtoReflect.Descriptor instead.
func (*EventAttributeValue) GetAttr ¶
func (m *EventAttributeValue) GetAttr() isEventAttributeValue_Attr
func (*EventAttributeValue) GetCeBoolean ¶
func (x *EventAttributeValue) GetCeBoolean() bool
func (*EventAttributeValue) GetCeBytes ¶
func (x *EventAttributeValue) GetCeBytes() []byte
func (*EventAttributeValue) GetCeInteger ¶
func (x *EventAttributeValue) GetCeInteger() int32
func (*EventAttributeValue) GetCeString ¶
func (x *EventAttributeValue) GetCeString() string
func (*EventAttributeValue) GetCeTimestamp ¶
func (x *EventAttributeValue) GetCeTimestamp() *timestamppb.Timestamp
func (*EventAttributeValue) GetCeUri ¶
func (x *EventAttributeValue) GetCeUri() string
func (*EventAttributeValue) GetCeUriRef ¶
func (x *EventAttributeValue) GetCeUriRef() string
func (*EventAttributeValue) MarshalJSON ¶
func (msg *EventAttributeValue) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*EventAttributeValue) ProtoMessage ¶
func (*EventAttributeValue) ProtoMessage()
func (*EventAttributeValue) ProtoReflect ¶
func (x *EventAttributeValue) ProtoReflect() protoreflect.Message
func (*EventAttributeValue) Reset ¶
func (x *EventAttributeValue) Reset()
func (*EventAttributeValue) String ¶
func (x *EventAttributeValue) String() string
func (*EventAttributeValue) UnmarshalJSON ¶
func (msg *EventAttributeValue) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
func (*EventAttributeValue) Validate ¶
func (m *EventAttributeValue) Validate() error
Validate checks the field values on EventAttributeValue with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*EventAttributeValue) ValidateAll ¶
func (m *EventAttributeValue) ValidateAll() error
ValidateAll checks the field values on EventAttributeValue with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EventAttributeValueMultiError, or nil if none found.
type EventAttributeValueMultiError ¶
type EventAttributeValueMultiError []error
EventAttributeValueMultiError is an error wrapping multiple validation errors returned by EventAttributeValue.ValidateAll() if the designated constraints aren't met.
func (EventAttributeValueMultiError) AllErrors ¶
func (m EventAttributeValueMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (EventAttributeValueMultiError) Error ¶
func (m EventAttributeValueMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type EventAttributeValueValidationError ¶
type EventAttributeValueValidationError struct {
// contains filtered or unexported fields
}
EventAttributeValueValidationError is the validation error returned by EventAttributeValue.Validate if the designated constraints aren't met.
func (EventAttributeValueValidationError) Cause ¶
func (e EventAttributeValueValidationError) Cause() error
Cause function returns cause value.
func (EventAttributeValueValidationError) Error ¶
func (e EventAttributeValueValidationError) Error() string
Error satisfies the builtin error interface
func (EventAttributeValueValidationError) ErrorName ¶
func (e EventAttributeValueValidationError) ErrorName() string
ErrorName returns error name.
func (EventAttributeValueValidationError) Field ¶
func (e EventAttributeValueValidationError) Field() string
Field function returns field value.
func (EventAttributeValueValidationError) Key ¶
func (e EventAttributeValueValidationError) Key() bool
Key function returns key value.
func (EventAttributeValueValidationError) Reason ¶
func (e EventAttributeValueValidationError) Reason() string
Reason function returns reason value.
type EventAttributeValue_CeBoolean ¶
type EventAttributeValue_CeBoolean struct { // CeBoolean is a boolean value. CeBoolean bool `protobuf:"varint,1,opt,name=ce_boolean,json=ceBoolean,proto3,oneof"` }
type EventAttributeValue_CeBytes ¶
type EventAttributeValue_CeBytes struct { // CeBytes is a bytes value. CeBytes []byte `protobuf:"bytes,4,opt,name=ce_bytes,json=ceBytes,proto3,oneof"` }
type EventAttributeValue_CeInteger ¶
type EventAttributeValue_CeInteger struct { // CeInteager is an integer value. CeInteger int32 `protobuf:"varint,2,opt,name=ce_integer,json=ceInteger,proto3,oneof"` }
type EventAttributeValue_CeString ¶
type EventAttributeValue_CeString struct { // CeString is a string value. CeString string `protobuf:"bytes,3,opt,name=ce_string,json=ceString,proto3,oneof"` }
type EventAttributeValue_CeTimestamp ¶
type EventAttributeValue_CeTimestamp struct { // CeTimestamp ia a timestamp value. CeTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=ce_timestamp,json=ceTimestamp,proto3,oneof"` }
type EventAttributeValue_CeUri ¶
type EventAttributeValue_CeUri struct { // CeUri is a uri value. CeUri string `protobuf:"bytes,5,opt,name=ce_uri,json=ceUri,proto3,oneof"` }
type EventAttributeValue_CeUriRef ¶
type EventAttributeValue_CeUriRef struct { // CeUriRef is a uri ref value. CeUriRef string `protobuf:"bytes,6,opt,name=ce_uri_ref,json=ceUriRef,proto3,oneof"` }
type EventBatch ¶
type EventBatch struct { // Events collection. Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
EventBatch is a batch format.
func (*EventBatch) Default ¶
func (x *EventBatch) Default()
func (*EventBatch) Descriptor
deprecated
func (*EventBatch) Descriptor() ([]byte, []int)
Deprecated: Use EventBatch.ProtoReflect.Descriptor instead.
func (*EventBatch) GetEvents ¶
func (x *EventBatch) GetEvents() []*Event
func (*EventBatch) MarshalJSON ¶
func (msg *EventBatch) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*EventBatch) ProtoMessage ¶
func (*EventBatch) ProtoMessage()
func (*EventBatch) ProtoReflect ¶
func (x *EventBatch) ProtoReflect() protoreflect.Message
func (*EventBatch) Reset ¶
func (x *EventBatch) Reset()
func (*EventBatch) String ¶
func (x *EventBatch) String() string
func (*EventBatch) UnmarshalJSON ¶
func (msg *EventBatch) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
func (*EventBatch) Validate ¶
func (m *EventBatch) Validate() error
Validate checks the field values on EventBatch with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*EventBatch) ValidateAll ¶
func (m *EventBatch) ValidateAll() error
ValidateAll checks the field values on EventBatch with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EventBatchMultiError, or nil if none found.
type EventBatchMultiError ¶
type EventBatchMultiError []error
EventBatchMultiError is an error wrapping multiple validation errors returned by EventBatch.ValidateAll() if the designated constraints aren't met.
func (EventBatchMultiError) AllErrors ¶
func (m EventBatchMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (EventBatchMultiError) Error ¶
func (m EventBatchMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type EventBatchValidationError ¶
type EventBatchValidationError struct {
// contains filtered or unexported fields
}
EventBatchValidationError is the validation error returned by EventBatch.Validate if the designated constraints aren't met.
func (EventBatchValidationError) Cause ¶
func (e EventBatchValidationError) Cause() error
Cause function returns cause value.
func (EventBatchValidationError) Error ¶
func (e EventBatchValidationError) Error() string
Error satisfies the builtin error interface
func (EventBatchValidationError) ErrorName ¶
func (e EventBatchValidationError) ErrorName() string
ErrorName returns error name.
func (EventBatchValidationError) Field ¶
func (e EventBatchValidationError) Field() string
Field function returns field value.
func (EventBatchValidationError) Key ¶
func (e EventBatchValidationError) Key() bool
Key function returns key value.
func (EventBatchValidationError) Reason ¶
func (e EventBatchValidationError) Reason() string
Reason function returns reason value.
type EventHandler ¶
type EventHandler interface { // HandleEvent handles the given event. HandleEvent(context.Context, *Event) error }
EventHandler is the interface that wraps the HandleEvent method.
type EventMultiError ¶
type EventMultiError []error
EventMultiError is an error wrapping multiple validation errors returned by Event.ValidateAll() if the designated constraints aren't met.
func (EventMultiError) AllErrors ¶
func (m EventMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (EventMultiError) Error ¶
func (m EventMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type EventService ¶
type EventService interface { // PushEvent pushes a given event to connect.runtime.v1.EventService service. PushEvent(context.Context, *PushEventRequest) (*PushEventResponse, error) }
The service that an application uses to consume events from a subscription via the Push method.
type EventServiceClient ¶
type EventServiceClient interface { // PushEvent pushes a given event to connect.runtime.v1.EventService service. PushEvent(context.Context, *PushEventRequest) (*PushEventResponse, error) }
The service client that an application uses to consume events from a subscription via the Push method.
type EventValidationError ¶
type EventValidationError struct {
// contains filtered or unexported fields
}
EventValidationError is the validation error returned by Event.Validate if the designated constraints aren't met.
func (EventValidationError) Cause ¶
func (e EventValidationError) Cause() error
Cause function returns cause value.
func (EventValidationError) Error ¶
func (e EventValidationError) Error() string
Error satisfies the builtin error interface
func (EventValidationError) ErrorName ¶
func (e EventValidationError) ErrorName() string
ErrorName returns error name.
func (EventValidationError) Field ¶
func (e EventValidationError) Field() string
Field function returns field value.
func (EventValidationError) Key ¶
func (e EventValidationError) Key() bool
Key function returns key value.
func (EventValidationError) Reason ¶
func (e EventValidationError) Reason() string
Reason function returns reason value.
type Event_BinaryData ¶
type Event_BinaryData struct { // BinaryData contains the data in binary format. BinaryData []byte `protobuf:"bytes,6,opt,name=binary_data,json=binaryData,proto3,oneof"` }
type Event_ProtoData ¶
type Event_TextData ¶
type Event_TextData struct { // TextData contains the data in string format. TextData string `protobuf:"bytes,7,opt,name=text_data,json=textData,proto3,oneof"` }
type NopEventServiceClient ¶
type NopEventServiceClient struct{}
NopEventServiceClient represents a no-op EventServiceClient.
func (*NopEventServiceClient) PushEvent ¶
func (*NopEventServiceClient) PushEvent(context.Context, *PushEventRequest) (*PushEventResponse, error)
PushEvent implements runtimev1.EventServiceClient.
type PushEventRequest ¶
type PushEventRequest struct { // The event. Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` // contains filtered or unexported fields }
PushEventRequest represents a request for cloud.event.v1.EventService.PushEvent method.
func (*PushEventRequest) Default ¶
func (x *PushEventRequest) Default()
func (*PushEventRequest) Descriptor
deprecated
func (*PushEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use PushEventRequest.ProtoReflect.Descriptor instead.
func (*PushEventRequest) GetAttributes ¶
func (x *PushEventRequest) GetAttributes() map[string]string
GetAttributes returns the attributes.
func (*PushEventRequest) GetData ¶
func (x *PushEventRequest) GetData() []byte
GetData returns the data.
func (*PushEventRequest) GetEvent ¶
func (x *PushEventRequest) GetEvent() *Event
func (*PushEventRequest) GetOrderingKey ¶
func (x *PushEventRequest) GetOrderingKey() string
GetOrderingKey returns the ordering key.
func (*PushEventRequest) MarshalJSON ¶
func (msg *PushEventRequest) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*PushEventRequest) ProtoMessage ¶
func (*PushEventRequest) ProtoMessage()
func (*PushEventRequest) ProtoReflect ¶
func (x *PushEventRequest) ProtoReflect() protoreflect.Message
func (*PushEventRequest) Reset ¶
func (x *PushEventRequest) Reset()
func (*PushEventRequest) SetAttributes ¶
func (x *PushEventRequest) SetAttributes(attributes map[string]string) error
SetAttributes sets the attributes.
func (*PushEventRequest) SetData ¶
func (x *PushEventRequest) SetData(data []byte) error
SetData sets the data.
func (*PushEventRequest) String ¶
func (x *PushEventRequest) String() string
func (*PushEventRequest) UnmarshalJSON ¶
func (msg *PushEventRequest) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
func (*PushEventRequest) Validate ¶
func (m *PushEventRequest) Validate() error
Validate checks the field values on PushEventRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*PushEventRequest) ValidateAll ¶
func (m *PushEventRequest) ValidateAll() error
ValidateAll checks the field values on PushEventRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PushEventRequestMultiError, or nil if none found.
type PushEventRequestMultiError ¶
type PushEventRequestMultiError []error
PushEventRequestMultiError is an error wrapping multiple validation errors returned by PushEventRequest.ValidateAll() if the designated constraints aren't met.
func (PushEventRequestMultiError) AllErrors ¶
func (m PushEventRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PushEventRequestMultiError) Error ¶
func (m PushEventRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PushEventRequestValidationError ¶
type PushEventRequestValidationError struct {
// contains filtered or unexported fields
}
PushEventRequestValidationError is the validation error returned by PushEventRequest.Validate if the designated constraints aren't met.
func (PushEventRequestValidationError) Cause ¶
func (e PushEventRequestValidationError) Cause() error
Cause function returns cause value.
func (PushEventRequestValidationError) Error ¶
func (e PushEventRequestValidationError) Error() string
Error satisfies the builtin error interface
func (PushEventRequestValidationError) ErrorName ¶
func (e PushEventRequestValidationError) ErrorName() string
ErrorName returns error name.
func (PushEventRequestValidationError) Field ¶
func (e PushEventRequestValidationError) Field() string
Field function returns field value.
func (PushEventRequestValidationError) Key ¶
func (e PushEventRequestValidationError) Key() bool
Key function returns key value.
func (PushEventRequestValidationError) Reason ¶
func (e PushEventRequestValidationError) Reason() string
Reason function returns reason value.
type PushEventResponse ¶
type PushEventResponse struct {
// contains filtered or unexported fields
}
PushEventResponse represents a response for cloud.event.v1.EventService.PushEvent method.
func (*PushEventResponse) Default ¶
func (x *PushEventResponse) Default()
func (*PushEventResponse) Descriptor
deprecated
func (*PushEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use PushEventResponse.ProtoReflect.Descriptor instead.
func (*PushEventResponse) MarshalJSON ¶
func (msg *PushEventResponse) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*PushEventResponse) ProtoMessage ¶
func (*PushEventResponse) ProtoMessage()
func (*PushEventResponse) ProtoReflect ¶
func (x *PushEventResponse) ProtoReflect() protoreflect.Message
func (*PushEventResponse) Reset ¶
func (x *PushEventResponse) Reset()
func (*PushEventResponse) String ¶
func (x *PushEventResponse) String() string
func (*PushEventResponse) UnmarshalJSON ¶
func (msg *PushEventResponse) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
func (*PushEventResponse) Validate ¶
func (m *PushEventResponse) Validate() error
Validate checks the field values on PushEventResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*PushEventResponse) ValidateAll ¶
func (m *PushEventResponse) ValidateAll() error
ValidateAll checks the field values on PushEventResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PushEventResponseMultiError, or nil if none found.
type PushEventResponseMultiError ¶
type PushEventResponseMultiError []error
PushEventResponseMultiError is an error wrapping multiple validation errors returned by PushEventResponse.ValidateAll() if the designated constraints aren't met.
func (PushEventResponseMultiError) AllErrors ¶
func (m PushEventResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PushEventResponseMultiError) Error ¶
func (m PushEventResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PushEventResponseValidationError ¶
type PushEventResponseValidationError struct {
// contains filtered or unexported fields
}
PushEventResponseValidationError is the validation error returned by PushEventResponse.Validate if the designated constraints aren't met.
func (PushEventResponseValidationError) Cause ¶
func (e PushEventResponseValidationError) Cause() error
Cause function returns cause value.
func (PushEventResponseValidationError) Error ¶
func (e PushEventResponseValidationError) Error() string
Error satisfies the builtin error interface
func (PushEventResponseValidationError) ErrorName ¶
func (e PushEventResponseValidationError) ErrorName() string
ErrorName returns error name.
func (PushEventResponseValidationError) Field ¶
func (e PushEventResponseValidationError) Field() string
Field function returns field value.
func (PushEventResponseValidationError) Key ¶
func (e PushEventResponseValidationError) Key() bool
Key function returns key value.
func (PushEventResponseValidationError) Reason ¶
func (e PushEventResponseValidationError) Reason() string
Reason function returns reason value.