cloudeventpb

package
v2.0.0-alpha.19 Latest Latest
Warning

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

Go to latest
Published: Dec 6, 2025 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// optional lava.cloudevent.CloudEventServiceOptions job = 10010;
	E_Job = &file_cloudevent_options_proto_extTypes[0]
)

Extension fields to descriptorpb.ServiceOptions.

View Source
var (
	// optional lava.cloudevent.CloudEventMethodOptions subject = 10011;
	E_Subject = &file_cloudevent_options_proto_extTypes[1]
)

Extension fields to descriptorpb.MethodOptions.

View Source
var File_cloudevent_options_proto protoreflect.FileDescriptor
View Source
var File_cloudevent_types_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CloudEventMethodOptions

type CloudEventMethodOptions struct {

	// subject name is same with config jobs consumers
	// subject name sametime is topic name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// event or api operation
	Operation *string `protobuf:"bytes,4,opt,name=operation,proto3,oneof" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

cloud event subject or topic

func (*CloudEventMethodOptions) Descriptor deprecated

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

Deprecated: Use CloudEventMethodOptions.ProtoReflect.Descriptor instead.

func (*CloudEventMethodOptions) GetName

func (x *CloudEventMethodOptions) GetName() string

func (*CloudEventMethodOptions) GetOperation

func (x *CloudEventMethodOptions) GetOperation() string

func (*CloudEventMethodOptions) ProtoMessage

func (*CloudEventMethodOptions) ProtoMessage()

func (*CloudEventMethodOptions) ProtoReflect

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

func (*CloudEventMethodOptions) Reset

func (x *CloudEventMethodOptions) Reset()

func (*CloudEventMethodOptions) String

func (x *CloudEventMethodOptions) String() string

type CloudEventServiceOptions

type CloudEventServiceOptions struct {

	// job event name is same with config jobs consumers job name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CloudEventServiceOptions) Descriptor deprecated

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

Deprecated: Use CloudEventServiceOptions.ProtoReflect.Descriptor instead.

func (*CloudEventServiceOptions) GetName

func (x *CloudEventServiceOptions) GetName() string

func (*CloudEventServiceOptions) ProtoMessage

func (*CloudEventServiceOptions) ProtoMessage()

func (*CloudEventServiceOptions) ProtoReflect

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

func (*CloudEventServiceOptions) Reset

func (x *CloudEventServiceOptions) Reset()

func (*CloudEventServiceOptions) String

func (x *CloudEventServiceOptions) String() string

type PushEventOptions

type PushEventOptions struct {

	// The content type for the data (optional).
	ContentType *string `protobuf:"bytes,1,opt,name=content_type,json=contentType,proto3,oneof" json:"content_type,omitempty"`
	// metadata property:
	// - key : the key of the message.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The delay duration of the message.
	DelayDur *durationpb.Duration `protobuf:"bytes,3,opt,name=delay_dur,json=delayDur,proto3,oneof" json:"delay_dur,omitempty"`
	// The message id
	MsgId *string `protobuf:"bytes,4,opt,name=msg_id,json=msgId,proto3,oneof" json:"msg_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PushEventOptions) Descriptor deprecated

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

Deprecated: Use PushEventOptions.ProtoReflect.Descriptor instead.

func (*PushEventOptions) GetContentType

func (x *PushEventOptions) GetContentType() string

func (*PushEventOptions) GetDelayDur

func (x *PushEventOptions) GetDelayDur() *durationpb.Duration

func (*PushEventOptions) GetMetadata

func (x *PushEventOptions) GetMetadata() map[string]string

func (*PushEventOptions) GetMsgId

func (x *PushEventOptions) GetMsgId() string

func (*PushEventOptions) ProtoMessage

func (*PushEventOptions) ProtoMessage()

func (*PushEventOptions) ProtoReflect

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

func (*PushEventOptions) Reset

func (x *PushEventOptions) Reset()

func (*PushEventOptions) String

func (x *PushEventOptions) String() string

type RegisterJobOptions

type RegisterJobOptions struct {
	JobName *string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3,oneof" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterJobOptions) Descriptor deprecated

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

Deprecated: Use RegisterJobOptions.ProtoReflect.Descriptor instead.

func (*RegisterJobOptions) GetJobName

func (x *RegisterJobOptions) GetJobName() string

func (*RegisterJobOptions) ProtoMessage

func (*RegisterJobOptions) ProtoMessage()

func (*RegisterJobOptions) ProtoReflect

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

func (*RegisterJobOptions) Reset

func (x *RegisterJobOptions) Reset()

func (*RegisterJobOptions) String

func (x *RegisterJobOptions) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL