docpb

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

type CreateDocumentResponse struct {
	AlreadyExists bool `protobuf:"varint,1,opt,name=already_exists,json=alreadyExists,proto3" json:"already_exists,omitempty"`
	// contains filtered or unexported fields
}

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

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

type DocumentStoreClient interface {
	Create(ctx context.Context, in *CreateDocumentRequest, opts ...grpc.CallOption) (*CreateDocumentResponse, error)
	Set(ctx context.Context, in *SetDocumentRequest, opts ...grpc.CallOption) (*DocumentResponse, error)
	Update(ctx context.Context, in *UpdateDocumentRequest, opts ...grpc.CallOption) (*UpdateDocumentResponse, error)
	Get(ctx context.Context, in *GetDocumentRequest, opts ...grpc.CallOption) (*GetDocumentResponse, error)
	Delete(ctx context.Context, in *DeleteDocumentRequest, opts ...grpc.CallOption) (*DocumentResponse, error)
	List(ctx context.Context, in *ListDocumentRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ListDocumentResponse], error)
}

type DocumentStoreServer interface {
	Create(context.Context, *CreateDocumentRequest) (*CreateDocumentResponse, error)
	Set(context.Context, *SetDocumentRequest) (*DocumentResponse, error)
	Update(context.Context, *UpdateDocumentRequest) (*UpdateDocumentResponse, error)
	Get(context.Context, *GetDocumentRequest) (*GetDocumentResponse, error)
	Delete(context.Context, *DeleteDocumentRequest) (*DocumentResponse, error)
	List(*ListDocumentRequest, grpc.ServerStreamingServer[ListDocumentResponse]) error
	// contains filtered or unexported methods
}

type DocumentStore_ListClient = grpc.ServerStreamingClient[ListDocumentResponse]

type DocumentStore_ListServer = grpc.ServerStreamingServer[ListDocumentResponse]

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

type GetDocumentResponse struct {
	Data     []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	NotFound bool   `protobuf:"varint,2,opt,name=not_found,json=notFound,proto3" json:"not_found,omitempty"`
	// contains filtered or unexported fields
}

type ListDocumentRequest struct {
	Filters []*ListDocumentRequest_Filter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

type ListDocumentRequest_Filter struct {
	FieldPath []string `protobuf:"bytes,1,rep,name=field_path,json=fieldPath,proto3" json:"field_path,omitempty"`
	Data      []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Operation string   `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type ListDocumentResponse struct {
	Data  []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

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

type UnimplementedDocumentStoreServer struct{}

type UnsafeDocumentStoreServer interface {
	// contains filtered or unexported methods
}

type UpdateDocumentRequest struct {
	Id            string                         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Updates       []*UpdateDocumentRequest_Field `protobuf:"bytes,2,rep,name=updates,proto3" json:"updates,omitempty"`
	Preconditions []*UpdateDocumentRequest_Field `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions,omitempty"`
	// contains filtered or unexported fields
}

type UpdateDocumentRequest_Field struct {
	FieldPath []string `protobuf:"bytes,1,rep,name=field_path,json=fieldPath,proto3" json:"field_path,omitempty"`
	Data      []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type UpdateDocumentResponse struct {
	NotFound           bool `protobuf:"varint,1,opt,name=not_found,json=notFound,proto3" json:"not_found,omitempty"`
	PreconditionFailed bool `protobuf:"varint,2,opt,name=precondition_failed,json=preconditionFailed,proto3" json:"precondition_failed,omitempty"`
	// contains filtered or unexported fields
}