userv1

type Aggregate interface {
	AggregateID() string
	Initialize(snapshot *Snapshot)
	CurrentSequence() int64
	IncrementSequence()
	UncommittedEvents() []*Event
	Snapshot() *Snapshot
	// contains filtered or unexported methods
}

type BaseAggregate struct {
	ID       string
	Sequence int64
	State    *State
	// contains filtered or unexported fields
}

type Codec struct{}

type Command struct {
	Id   string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Data *Command_Data `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type CommandData interface {
	CommandType() string
	// contains filtered or unexported methods
}

type CommandDispatcher struct {
	Client     client.Client
	GenerateID IDGeneratorFunc
}

type CommandHandler struct {
	AggregateFactory func() UserAggregate
	EventStore       EventStore
	SnapshotRepo     SnapshotRepo
	SnapshotTrigger  func(*Snapshot) bool
	v1.UnimplementedAppCallbackServer
}

type Command_Data struct {

	// Types that are assignable to Data:
	//	*Command_Data_Register
	//	*Command_Data_Deactivate
	Data isCommand_Data_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

type Command_Data_Deactivate struct {
	Deactivate *DeactivateUser `protobuf:"bytes,2,opt,name=deactivate,proto3,oneof"`
}

type Command_Data_Register struct {
	Register *RegisterUser `protobuf:"bytes,1,opt,name=register,proto3,oneof"`
}

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

type DynamoEventstore struct {
	Client *dynamodb.Client
	Table  string
}

type DynamoUserRepository struct {
	Table  string
	Client *dynamodb.Client
}

type Error struct {
	Command *Command    `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Data    *Error_Data `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type ErrorData interface {
	Error() string
	ErrorType() string
	// contains filtered or unexported methods
}

type Error_Data struct {

	// Types that are assignable to Data:
	//	*Error_Data_AlreadyRegistered
	//	*Error_Data_Unregistered
	Data isError_Data_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

type Error_Data_AlreadyRegistered struct {
	AlreadyRegistered *UserAlreadyRegistered `protobuf:"bytes,1,opt,name=already_registered,json=alreadyRegistered,proto3,oneof"`
}

type Error_Data_Unregistered struct {
	Unregistered *UserUnregistered `protobuf:"bytes,2,opt,name=unregistered,proto3,oneof"`
}

type Event struct {
	Id        string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Sequence  int64       `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Timestamp int64       `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Type      string      `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Data      *Event_Data `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type EventData interface {
	EventType() string
	// contains filtered or unexported methods
}

type EventHandler interface {
	OnUserRegistered(ctx context.Context, aggregateID string, event *UserRegistered) error
	OnUserDeactivated(ctx context.Context, aggregateID string, event *UserDeactivated) error
}

type EventListener struct {
	Handler EventHandler
	v1.UnimplementedAppCallbackServer
}

type EventStore interface {
	Load(ctx context.Context, id string, seq int64) ([]*Event, error)
	Save(ctx context.Context, events []*Event) error
}

type Event_Data struct {

	// Types that are assignable to Data:
	//	*Event_Data_Registered
	//	*Event_Data_Deactivated
	Data isEvent_Data_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

type Event_Data_Deactivated struct {
	Deactivated *UserDeactivated `protobuf:"bytes,2,opt,name=deactivated,proto3,oneof"`
}

type Event_Data_Registered struct {
	Registered *UserRegistered `protobuf:"bytes,1,opt,name=registered,proto3,oneof"`
}

type IDGeneratorFunc func(*RegisterUser) string

type RegisterUser struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Age   int64  `protobuf:"varint,2,opt,name=age,proto3" json:"age,omitempty"`
	Email string `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
	// contains filtered or unexported fields
}

type Snapshot struct {
	AggregateID string
	Sequence    int64
	State       *State
}

type SnapshotRepo interface {
	Persist(ctx context.Context, snapshot *Snapshot) error
	Retrieve(ctx context.Context, aggregateID string) (*Snapshot, error)
}

type State 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"`
	Email    string `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
	IsActive bool   `protobuf:"varint,4,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedEventHandler struct{}

type User struct {
	Id      string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Age     int64             `protobuf:"varint,2,opt,name=age,proto3" json:"age,omitempty"`
	Email   string            `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
	Country _type.CountryCode `protobuf:"varint,4,opt,name=country,proto3,enum=type.CountryCode" json:"country,omitempty"`
	City    string            `protobuf:"bytes,5,opt,name=city,proto3" json:"city,omitempty"`
	Score   float64           `protobuf:"fixed64,6,opt,name=score,proto3" json:"score,omitempty"`
	// contains filtered or unexported fields
}

type UserAggregate interface {
	Aggregate
	HandleRegisterUser(cmd *RegisterUser) ErrorData
	HandleDeactivateUser(cmd *DeactivateUser) ErrorData
	OnUserRegistered(event *UserRegistered)
	OnUserDeactivated(event *UserDeactivated)
}

type UserAlreadyRegistered struct {
	Id               string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RegistrationTime int64  `protobuf:"varint,2,opt,name=registration_time,json=registrationTime,proto3" json:"registration_time,omitempty"`
	// contains filtered or unexported fields
}

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

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

type UserRepository interface {
	PutUser(ctx context.Context, user *User) error
	GetUser(ctx context.Context, id string, age int64) (*User, error)
	ListUsers(ctx context.Context) ([]*User, error)
	ListUsersByCountry(ctx context.Context, country _type.CountryCode) ([]*User, error)
	ListScoresByCountry(ctx context.Context, country _type.CountryCode, score float64) ([]*User, error)
}

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