publishpb

Documentation

Index

• Variables
• type PublishEventRequest
  • func (*PublishEventRequest) Descriptor() ([]byte, []int)
  • func (x *PublishEventRequest) GetBody() []byte
  • func (x *PublishEventRequest) GetCaller() string
  • func (x *PublishEventRequest) GetKey() string
  • func (x *PublishEventRequest) GetTopic() *v1.Ref
  • func (*PublishEventRequest) ProtoMessage()
  • func (x *PublishEventRequest) ProtoReflect() protoreflect.Message
  • func (x *PublishEventRequest) Reset()
  • func (x *PublishEventRequest) String() string
• type PublishEventResponse
  • func (*PublishEventResponse) Descriptor() ([]byte, []int)
  • func (*PublishEventResponse) ProtoMessage()
  • func (x *PublishEventResponse) ProtoReflect() protoreflect.Message
  • func (x *PublishEventResponse) Reset()
  • func (x *PublishEventResponse) String() string

Variables

var File_xyz_block_ftl_publish_v1_publish_proto protoreflect.FileDescriptor

Types

type PublishEventRequest

type PublishEventRequest struct {
	Topic *v1.Ref `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Body  []byte  `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	Key   string  `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Only verb name is included because this verb will be in the same module as topic
	Caller string `protobuf:"bytes,4,opt,name=caller,proto3" json:"caller,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishEventRequest) Descriptor

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

Deprecated: Use PublishEventRequest.ProtoReflect.Descriptor instead.

func (*PublishEventRequest) GetBody

func (x *PublishEventRequest) GetBody() []byte

func (*PublishEventRequest) GetCaller

func (x *PublishEventRequest) GetCaller() string

func (*PublishEventRequest) GetKey

func (x *PublishEventRequest) GetKey() string

func (*PublishEventRequest) GetTopic

func (x *PublishEventRequest) GetTopic() *v1.Ref

func (*PublishEventRequest) ProtoMessage

func (*PublishEventRequest) ProtoMessage()

func (*PublishEventRequest) ProtoReflect

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

func (*PublishEventRequest) Reset

func (x *PublishEventRequest) Reset()

func (*PublishEventRequest) String

func (x *PublishEventRequest) String() string

type PublishEventResponse

type PublishEventResponse struct {
	// contains filtered or unexported fields
}

func (*PublishEventResponse) Descriptor

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

Deprecated: Use PublishEventResponse.ProtoReflect.Descriptor instead.

func (*PublishEventResponse) ProtoMessage

func (*PublishEventResponse) ProtoMessage()

func (*PublishEventResponse) ProtoReflect

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

func (*PublishEventResponse) Reset

func (x *PublishEventResponse) Reset()

func (*PublishEventResponse) String

func (x *PublishEventResponse) String() string