brokerv1

type BrokerPublishConfig struct {

	// topic is the NATS subject to publish to.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// payload is the message body (string or JSON-encoded map).
	Payload string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type BrokerPublishInput struct {
	Data *structpb.Struct `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type BrokerPublishOutput struct {

	// topic is the NATS subject the message was published to.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// bytes is the number of bytes published.
	Bytes int32 `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// published is true when the message was successfully delivered to the broker.
	Published bool `protobuf:"varint,3,opt,name=published,proto3" json:"published,omitempty"`
	// contains filtered or unexported fields
}

type BrokerSubscribeConfig struct {

	// topic is the NATS subject filter (wildcards supported).
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// consumer_name is the durable consumer name for JetStream replay.
	ConsumerName string `protobuf:"bytes,2,opt,name=consumer_name,json=consumerName,proto3" json:"consumer_name,omitempty"`
	// contains filtered or unexported fields
}

type BrokerSubscribeInput struct {
	Data *structpb.Struct `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type BrokerSubscribeOutput struct {

	// topic is the NATS subject the message was received from.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// consumer is the durable consumer name used to fetch the message.
	Consumer string `protobuf:"bytes,2,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// payload is the message body received from the broker.
	Payload *structpb.Struct `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type NATSModuleConfig struct {

	// url is the NATS server URL (default: nats://localhost:4222).
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// stream is the JetStream stream name (default: GAME_EVENTS).
	Stream string `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}