Documentation
¶
Index ¶
Constants ¶
View Source
const DemoCloudEventJobKey = "demo"
View Source
const HelloExecCloudEventSubjectKey = "demo.hello.exec"
HelloExecCloudEventSubjectKey /demo.cloudevent.v1.DemoInnerService/HelloExec
Variables ¶
View Source
var File_demo_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDemoInnerServiceCloudEvent ¶
func RegisterDemoInnerServiceCloudEvent(jobCli *cloudevent.Client, event DemoInnerServiceCloudEvent, opts ...cloudevent.RegisterOpt)
Types ¶
type DemoInnerServiceCloudEvent ¶
type DemoInnerServiceCloudEvent struct {
OnHelloExec func(ctx context.Context, req *HelloExecReq) error
}
type DemoInnerServiceCloudEventPublisher ¶
type DemoInnerServiceCloudEventPublisher struct {
Client *cloudevent.Client
Opt cloudevent.PubOpt
Interceptors []cloudevent.PubInterceptor
}
func (DemoInnerServiceCloudEventPublisher) PushHelloExecEvent ¶
func (a DemoInnerServiceCloudEventPublisher) PushHelloExecEvent(ctx context.Context, req *HelloExecReq, opts ...cloudevent.PubOpt) result.Result[*cloudevent.PubAckInfo]
type HelloExecReq ¶
type HelloExecReq struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*HelloExecReq) Descriptor
deprecated
func (*HelloExecReq) Descriptor() ([]byte, []int)
Deprecated: Use HelloExecReq.ProtoReflect.Descriptor instead.
func (*HelloExecReq) GetName ¶
func (x *HelloExecReq) GetName() string
func (*HelloExecReq) ProtoMessage ¶
func (*HelloExecReq) ProtoMessage()
func (*HelloExecReq) ProtoReflect ¶
func (x *HelloExecReq) ProtoReflect() protoreflect.Message
func (*HelloExecReq) Reset ¶
func (x *HelloExecReq) Reset()
func (*HelloExecReq) String ¶
func (x *HelloExecReq) String() string
Source Files
Click to show internal directories.
Click to hide internal directories.