messagingv1

type BroadcastConfig struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type Config struct {

	// Types that are assignable to Type:
	//
	//	*Config_Broadcast
	//	*Config_Unicast
	//	*Config_Request
	//	*Config_Reply
	Type isConfig_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type Config_Broadcast struct {
	Broadcast *BroadcastConfig `protobuf:"bytes,1,opt,name=broadcast,proto3,oneof"`
}

type Config_Reply struct {
	Reply *ReplyConfig `protobuf:"bytes,4,opt,name=reply,proto3,oneof"`
}

type Config_Request struct {
	Request *RequestConfig `protobuf:"bytes,3,opt,name=request,proto3,oneof"`
}

type Config_Unicast struct {
	Unicast *UnicastConfig `protobuf:"bytes,2,opt,name=unicast,proto3,oneof"`
}

type ReplyConfig struct {

	// name of the queue group (i.e. prefix), should match RequestConfig.name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type RequestConfig struct {

	// name of the queue group (i.e. prefix), should match ReplyConfig.name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type RequestMetadata struct {
	ReplyTo string `protobuf:"bytes,1,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"`
	// Context is the responsibility of the requester, it can be whatever the
	// caller likes, e.g. an encoded proto message
	Context []byte `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

type UnicastConfig struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type UpsertMetadata struct {

	// The key of the object being updated by this message
	EntityId string `protobuf:"bytes,1,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"`
	// A unique ID for the event triggering this update
	EventId string `protobuf:"bytes,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// Safe ordered timestamp of the event. The event with the
	// newest timestamp is current and superseeds all events.
	// Upsert processors should ignore old events.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}