core

type Aggregate struct {
	Name       string
	Store      badger.DB
	EventStore store.Blocks
	Consumers  sync.Map
}

type Consumer struct {
	Name string
	// contains filtered or unexported fields
}

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

type ConsumerConn interface {
	io.Reader
	io.Writer
	io.Closer
}

type Event struct {
	Id          uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Aggregate   string `protobuf:"bytes,2,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
	AggregateId string `protobuf:"bytes,3,opt,name=aggregateId,proto3" json:"aggregateId,omitempty"`
	Name        string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Content     []byte `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

type Events struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}