crudstore

type CreateRequest struct {
	// entity type of the object, could be User, Project and etc
	EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"`
	// originator of the object, if not supplied it'll be auto generated
	Originator *common.Originator `protobuf:"bytes,2,opt,name=originator,proto3" json:"originator,omitempty"`
	// payload is a json valid string that has the body of the object
	Payload              string   `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type CreateResponse struct {
	Originator           *common.Originator `protobuf:"bytes,1,opt,name=originator,proto3" json:"originator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

type CrudEntitySpec struct {
	// the entity type we're registering like Project, User and etc
	// if have same entity on different bounded contexes can use packages
	// like com.makkalot.User, this field is required
	EntityType           string      `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"`
	SchemaSpec           *SchemaSpec `protobuf:"bytes,2,opt,name=schema_spec,json=schemaSpec,proto3" json:"schema_spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

type CrudStoreServiceClient interface {
	Healtz(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// List endpoint is a debug endpoint and could be very slow
	// for objects with lots of events, if want faster list access
	// use a proper read model and create a different service endpoint for it
	// also note that it can return duplicate results as well for different pages
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	RegisterType(ctx context.Context, in *RegisterTypeRequest, opts ...grpc.CallOption) (*RegisterTypeResponse, error)
	// The request is eventually consistent
	GetType(ctx context.Context, in *GetTypeRequest, opts ...grpc.CallOption) (*GetTypeResponse, error)
	// updates the type and the schema
	UpdateType(ctx context.Context, in *UpdateTypeRequest, opts ...grpc.CallOption) (*UpdateTypeResponse, error)
	// it's for debugging purposes might be a bit slow, for better results
	// use a different index
	ListTypes(ctx context.Context, in *ListTypesRequest, opts ...grpc.CallOption) (*ListTypesResponse, error)
}

type CrudStoreServiceServer interface {
	Healtz(context.Context, *HealthRequest) (*HealthResponse, error)
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// List endpoint is a debug endpoint and could be very slow
	// for objects with lots of events, if want faster list access
	// use a proper read model and create a different service endpoint for it
	// also note that it can return duplicate results as well for different pages
	List(context.Context, *ListRequest) (*ListResponse, error)
	RegisterType(context.Context, *RegisterTypeRequest) (*RegisterTypeResponse, error)
	// The request is eventually consistent
	GetType(context.Context, *GetTypeRequest) (*GetTypeResponse, error)
	// updates the type and the schema
	UpdateType(context.Context, *UpdateTypeRequest) (*UpdateTypeResponse, error)
	// it's for debugging purposes might be a bit slow, for better results
	// use a different index
	ListTypes(context.Context, *ListTypesRequest) (*ListTypesResponse, error)
}

type DeleteRequest struct {
	EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"`
	// originator is the id of the object
	Originator           *common.Originator `protobuf:"bytes,2,opt,name=originator,proto3" json:"originator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

type DeleteResponse struct {
	// originator is the id of the object
	Originator           *common.Originator `protobuf:"bytes,1,opt,name=originator,proto3" json:"originator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

type GetRequest struct {
	// something like User, Project and etc
	EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"`
	// originator is the id of the object
	Originator *common.Originator `protobuf:"bytes,2,opt,name=originator,proto3" json:"originator,omitempty"`
	// fetch deleted
	Deleted              bool     `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type GetResponse struct {
	Originator *common.Originator `protobuf:"bytes,1,opt,name=originator,proto3" json:"originator,omitempty"`
	// json representation of the body
	Payload              string   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type GetTypeRequest struct {
	EntityType           string   `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type GetTypeResponse struct {
	Spec                 *CrudEntitySpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

type HealthRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type HealthResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ListRequest struct {
	// entity type is required parameter
	EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"`
	// pagination id is optional if not supplied starts scanning from the beginning
	PaginationId string `protobuf:"bytes,2,opt,name=pagination_id,json=paginationId,proto3" json:"pagination_id,omitempty"`
	// optional, if not supplied it's 10
	Limit                uint32   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	SkipPayload          bool     `protobuf:"varint,4,opt,name=skip_payload,json=skipPayload,proto3" json:"skip_payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ListResponse struct {
	Results              []*ListResponseItem `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	NextPageId           string              `protobuf:"bytes,2,opt,name=next_page_id,json=nextPageId,proto3" json:"next_page_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

type ListResponseItem struct {
	EntityType           string             `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"`
	Originator           *common.Originator `protobuf:"bytes,2,opt,name=originator,proto3" json:"originator,omitempty"`
	Payload              string             `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

type ListTypesRequest struct {
	// optional, if not supplied it's 20
	Limit                uint32   `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ListTypesResponse struct {
	Results              []*CrudEntitySpec `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

type RegisterTypeRequest struct {
	Spec *CrudEntitySpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// if the record already exists it doesn't error
	SkipDuplicate        bool     `protobuf:"varint,2,opt,name=skip_duplicate,json=skipDuplicate,proto3" json:"skip_duplicate,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type RegisterTypeResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type SchemaSpec struct {
	// optional field that keeps the version of the schema for that object
	// field can be used to make sure the client are sending objects against
	// the latest version of the schema registered in the system
	SchemaVersion uint64 `protobuf:"varint,1,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	// optional field that is used for validating the entity for certain
	// schema version. If empty no validation is done, if supplied the submitted
	// object is validated against the schema
	JsonSchema           string   `protobuf:"bytes,2,opt,name=json_schema,json=jsonSchema,proto3" json:"json_schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type UpdateRequest struct {
	// entity type of the object, could be User, Project and etc
	EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"`
	// originator of the object
	Originator *common.Originator `protobuf:"bytes,2,opt,name=originator,proto3" json:"originator,omitempty"`
	// payload is a json valid string that has the body of the object
	Payload              string   `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type UpdateResponse struct {
	Originator           *common.Originator `protobuf:"bytes,1,opt,name=originator,proto3" json:"originator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

type UpdateTypeRequest struct {
	Spec                 *CrudEntitySpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

type UpdateTypeResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}