Documentation
¶
Index ¶
- Variables
- type CloudEventMethodOptions
- func (*CloudEventMethodOptions) Descriptor() ([]byte, []int)deprecated
- func (x *CloudEventMethodOptions) GetName() string
- func (x *CloudEventMethodOptions) GetOperation() string
- func (*CloudEventMethodOptions) ProtoMessage()
- func (x *CloudEventMethodOptions) ProtoReflect() protoreflect.Message
- func (x *CloudEventMethodOptions) Reset()
- func (x *CloudEventMethodOptions) String() string
- type CloudEventServiceOptions
- func (*CloudEventServiceOptions) Descriptor() ([]byte, []int)deprecated
- func (x *CloudEventServiceOptions) GetName() string
- func (*CloudEventServiceOptions) ProtoMessage()
- func (x *CloudEventServiceOptions) ProtoReflect() protoreflect.Message
- func (x *CloudEventServiceOptions) Reset()
- func (x *CloudEventServiceOptions) String() string
- type PushEventOptions
- func (*PushEventOptions) Descriptor() ([]byte, []int)deprecated
- func (x *PushEventOptions) GetContentType() string
- func (x *PushEventOptions) GetDelayDur() *durationpb.Duration
- func (x *PushEventOptions) GetMetadata() map[string]string
- func (x *PushEventOptions) GetMsgId() string
- func (*PushEventOptions) ProtoMessage()
- func (x *PushEventOptions) ProtoReflect() protoreflect.Message
- func (x *PushEventOptions) Reset()
- func (x *PushEventOptions) String() string
- type RegisterJobOptions
- func (*RegisterJobOptions) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterJobOptions) GetJobName() string
- func (*RegisterJobOptions) ProtoMessage()
- func (x *RegisterJobOptions) ProtoReflect() protoreflect.Message
- func (x *RegisterJobOptions) Reset()
- func (x *RegisterJobOptions) String() string
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
Click to show internal directories.
Click to hide internal directories.