Versions in this module Expand all Collapse all v0 v0.2.4 May 24, 2026 Changes in this version + var File_broker_proto protoreflect.FileDescriptor + type BrokerPublishConfig struct + Payload string + Topic string + func (*BrokerPublishConfig) Descriptor() ([]byte, []int) + func (*BrokerPublishConfig) ProtoMessage() + func (x *BrokerPublishConfig) GetPayload() string + func (x *BrokerPublishConfig) GetTopic() string + func (x *BrokerPublishConfig) ProtoReflect() protoreflect.Message + func (x *BrokerPublishConfig) Reset() + func (x *BrokerPublishConfig) String() string + type BrokerPublishInput struct + Data *structpb.Struct + func (*BrokerPublishInput) Descriptor() ([]byte, []int) + func (*BrokerPublishInput) ProtoMessage() + func (x *BrokerPublishInput) GetData() *structpb.Struct + func (x *BrokerPublishInput) ProtoReflect() protoreflect.Message + func (x *BrokerPublishInput) Reset() + func (x *BrokerPublishInput) String() string + type BrokerPublishOutput struct + Bytes int32 + Published bool + Topic string + func (*BrokerPublishOutput) Descriptor() ([]byte, []int) + func (*BrokerPublishOutput) ProtoMessage() + func (x *BrokerPublishOutput) GetBytes() int32 + func (x *BrokerPublishOutput) GetPublished() bool + func (x *BrokerPublishOutput) GetTopic() string + func (x *BrokerPublishOutput) ProtoReflect() protoreflect.Message + func (x *BrokerPublishOutput) Reset() + func (x *BrokerPublishOutput) String() string + type BrokerSubscribeConfig struct + ConsumerName string + Topic string + func (*BrokerSubscribeConfig) Descriptor() ([]byte, []int) + func (*BrokerSubscribeConfig) ProtoMessage() + func (x *BrokerSubscribeConfig) GetConsumerName() string + func (x *BrokerSubscribeConfig) GetTopic() string + func (x *BrokerSubscribeConfig) ProtoReflect() protoreflect.Message + func (x *BrokerSubscribeConfig) Reset() + func (x *BrokerSubscribeConfig) String() string + type BrokerSubscribeInput struct + Data *structpb.Struct + func (*BrokerSubscribeInput) Descriptor() ([]byte, []int) + func (*BrokerSubscribeInput) ProtoMessage() + func (x *BrokerSubscribeInput) GetData() *structpb.Struct + func (x *BrokerSubscribeInput) ProtoReflect() protoreflect.Message + func (x *BrokerSubscribeInput) Reset() + func (x *BrokerSubscribeInput) String() string + type BrokerSubscribeOutput struct + Consumer string + Payload *structpb.Struct + Topic string + func (*BrokerSubscribeOutput) Descriptor() ([]byte, []int) + func (*BrokerSubscribeOutput) ProtoMessage() + func (x *BrokerSubscribeOutput) GetConsumer() string + func (x *BrokerSubscribeOutput) GetPayload() *structpb.Struct + func (x *BrokerSubscribeOutput) GetTopic() string + func (x *BrokerSubscribeOutput) ProtoReflect() protoreflect.Message + func (x *BrokerSubscribeOutput) Reset() + func (x *BrokerSubscribeOutput) String() string + type NATSModuleConfig struct + Stream string + Url string + func (*NATSModuleConfig) Descriptor() ([]byte, []int) + func (*NATSModuleConfig) ProtoMessage() + func (x *NATSModuleConfig) GetStream() string + func (x *NATSModuleConfig) GetUrl() string + func (x *NATSModuleConfig) ProtoReflect() protoreflect.Message + func (x *NATSModuleConfig) Reset() + func (x *NATSModuleConfig) String() string
Go to main page