serverv1

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

type Message struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Subject   string                 `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	EventTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	Header    map[string]string      `` /* 153-byte string literal not displayed */
	Message   *anypb.Any             `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// Types that are assignable to Action:
	//
	//	*Message_Event
	//	*Message_Cron
	Action isMessage_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

type Message_Cron struct {
	Cron *v1.Cron `protobuf:"bytes,7,opt,name=cron,proto3,oneof"`
}

type Message_Event struct {
	Event *v1.Event `protobuf:"bytes,6,opt,name=event,proto3,oneof"`
}

type Stream struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name       string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Subject    string                 `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"`
	Policy     v1.AckPolicy           `protobuf:"varint,4,opt,name=policy,proto3,enum=common.v1.AckPolicy" json:"policy,omitempty"`
	Replicas   string                 `protobuf:"bytes,5,opt,name=replicas,proto3" json:"replicas,omitempty"`
	MaxDeliver int32                  `protobuf:"varint,6,opt,name=max_deliver,json=maxDeliver,proto3" json:"max_deliver,omitempty"`
	AckWait    *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=ack_wait,json=ackWait,proto3" json:"ack_wait,omitempty"`
	// contains filtered or unexported fields
}