eventservice

package
v0.0.0-...-78c4d89 Latest Latest
Warning

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

 Go to latest Published: Oct 19, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EventService_PushEvent_FullMethodName = "/eventservice.EventService/PushEvent"
)

Variables

View Source 
var EventService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "eventservice.EventService",
	HandlerType: (*EventServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PushEvent",
			Handler:    _EventService_PushEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "grpc/event_service.proto",
}

EventService_ServiceDesc is the grpc.ServiceDesc for EventService 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_grpc_event_service_proto protoreflect.FileDescriptor

Functions

func RegisterEventServiceServer 

func RegisterEventServiceServer(s grpc.ServiceRegistrar, srv EventServiceServer)

Types

type EventServiceClient 

type EventServiceClient interface {
	PushEvent(ctx context.Context, in *PushEventRequest, opts ...grpc.CallOption) (*PushEventResponse, error)
}

EventServiceClient is the client API for EventService 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.

func NewEventServiceClient 

func NewEventServiceClient(cc grpc.ClientConnInterface) EventServiceClient

type EventServiceServer 

type EventServiceServer interface {
	PushEvent(context.Context, *PushEventRequest) (*PushEventResponse, error)
	// contains filtered or unexported methods
}

EventServiceServer is the server API for EventService service. All implementations must embed UnimplementedEventServiceServer for forward compatibility

type PushEventRequest 

type PushEventRequest 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]*PushEventRequest_CloudEventAttributeValue `` /* 161-byte string literal not displayed */
	// -- CloudEvent Data (Bytes, Text, or Proto)
	//
	// Types that are assignable to Data:
	//
	//	*PushEventRequest_BinaryData
	//	*PushEventRequest_TextData
	//	*PushEventRequest_ProtoData
	Data isPushEventRequest_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*PushEventRequest) Descriptor deprecated 

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

Deprecated: Use PushEventRequest.ProtoReflect.Descriptor instead.

func (*PushEventRequest) GetAttributes 

func (x *PushEventRequest) GetAttributes() map[string]*PushEventRequest_CloudEventAttributeValue

func (*PushEventRequest) GetBinaryData 

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

func (*PushEventRequest) GetData 

func (m *PushEventRequest) GetData() isPushEventRequest_Data

func (*PushEventRequest) GetId 

func (x *PushEventRequest) GetId() string

func (*PushEventRequest) GetProtoData 

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

func (*PushEventRequest) GetSource 

func (x *PushEventRequest) GetSource() string

func (*PushEventRequest) GetSpecVersion 

func (x *PushEventRequest) GetSpecVersion() string

func (*PushEventRequest) GetTextData 

func (x *PushEventRequest) GetTextData() string

func (*PushEventRequest) GetType 

func (x *PushEventRequest) GetType() string

func (*PushEventRequest) ProtoMessage 

func (*PushEventRequest) ProtoMessage()

func (*PushEventRequest) ProtoReflect 

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

func (*PushEventRequest) Reset 

func (x *PushEventRequest) Reset()

func (*PushEventRequest) String 

func (x *PushEventRequest) String() string

type PushEventRequest_BinaryData 

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

type PushEventRequest_CloudEventAttributeValue 

type PushEventRequest_CloudEventAttributeValue struct {

	// Types that are assignable to Attr:
	//
	//	*PushEventRequest_CloudEventAttributeValue_CeBoolean
	//	*PushEventRequest_CloudEventAttributeValue_CeInteger
	//	*PushEventRequest_CloudEventAttributeValue_CeString
	//	*PushEventRequest_CloudEventAttributeValue_CeBytes
	//	*PushEventRequest_CloudEventAttributeValue_CeUri
	//	*PushEventRequest_CloudEventAttributeValue_CeUriRef
	//	*PushEventRequest_CloudEventAttributeValue_CeTimestamp
	Attr isPushEventRequest_CloudEventAttributeValue_Attr `protobuf_oneof:"attr"`
	// contains filtered or unexported fields
}

func (*PushEventRequest_CloudEventAttributeValue) Descriptor deprecated 

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

Deprecated: Use PushEventRequest_CloudEventAttributeValue.ProtoReflect.Descriptor instead.

func (*PushEventRequest_CloudEventAttributeValue) GetAttr 

func (m *PushEventRequest_CloudEventAttributeValue) GetAttr() isPushEventRequest_CloudEventAttributeValue_Attr

func (*PushEventRequest_CloudEventAttributeValue) GetCeBoolean 

func (x *PushEventRequest_CloudEventAttributeValue) GetCeBoolean() bool

func (*PushEventRequest_CloudEventAttributeValue) GetCeBytes 

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

func (*PushEventRequest_CloudEventAttributeValue) GetCeInteger 

func (x *PushEventRequest_CloudEventAttributeValue) GetCeInteger() int32

func (*PushEventRequest_CloudEventAttributeValue) GetCeString 

func (x *PushEventRequest_CloudEventAttributeValue) GetCeString() string

func (*PushEventRequest_CloudEventAttributeValue) GetCeTimestamp 

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

func (*PushEventRequest_CloudEventAttributeValue) GetCeUri 

func (x *PushEventRequest_CloudEventAttributeValue) GetCeUri() string

func (*PushEventRequest_CloudEventAttributeValue) GetCeUriRef 

func (x *PushEventRequest_CloudEventAttributeValue) GetCeUriRef() string

func (*PushEventRequest_CloudEventAttributeValue) ProtoMessage 

func (*PushEventRequest_CloudEventAttributeValue) ProtoMessage()

func (*PushEventRequest_CloudEventAttributeValue) ProtoReflect 

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

func (*PushEventRequest_CloudEventAttributeValue) Reset 

func (x *PushEventRequest_CloudEventAttributeValue) Reset()

func (*PushEventRequest_CloudEventAttributeValue) String 

func (x *PushEventRequest_CloudEventAttributeValue) String() string

type PushEventRequest_CloudEventAttributeValue_CeBoolean 

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

type PushEventRequest_CloudEventAttributeValue_CeBytes 

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

type PushEventRequest_CloudEventAttributeValue_CeInteger 

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

type PushEventRequest_CloudEventAttributeValue_CeString 

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

type PushEventRequest_CloudEventAttributeValue_CeTimestamp 

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

type PushEventRequest_CloudEventAttributeValue_CeUri 

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

type PushEventRequest_CloudEventAttributeValue_CeUriRef 

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

type PushEventRequest_ProtoData 

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

type PushEventRequest_TextData 

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

type PushEventResponse 

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

func (*PushEventResponse) Descriptor deprecated 

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

Deprecated: Use PushEventResponse.ProtoReflect.Descriptor instead.

func (*PushEventResponse) GetMessage 

func (x *PushEventResponse) GetMessage() string

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

type UnimplementedEventServiceServer 

type UnimplementedEventServiceServer struct {
}

UnimplementedEventServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEventServiceServer) PushEvent 

func (UnimplementedEventServiceServer) PushEvent(context.Context, *PushEventRequest) (*PushEventResponse, error)

type UnsafeEventServiceServer 

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

UnsafeEventServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventServiceServer 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.