store

type BlobDeleteRequest struct {
	Key     string       `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Options *BlobOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

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

type BlobListOptions struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Prefix    string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

type BlobListRequest struct {
	Options *BlobListOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type BlobListResponse struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

type BlobOptions struct {
	Namespace   string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Public      bool   `protobuf:"varint,2,opt,name=public,proto3" json:"public,omitempty"`
	ContentType string `protobuf:"bytes,3,opt,name=contentType,proto3" json:"contentType,omitempty"`
	// contains filtered or unexported fields
}

type BlobReadRequest struct {
	Key     string       `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Options *BlobOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type BlobReadResponse struct {
	Blob []byte `protobuf:"bytes,1,opt,name=blob,proto3" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

type BlobStoreClient interface {
	Read(ctx context.Context, in *BlobReadRequest, opts ...grpc.CallOption) (BlobStore_ReadClient, error)
	Write(ctx context.Context, opts ...grpc.CallOption) (BlobStore_WriteClient, error)
	Delete(ctx context.Context, in *BlobDeleteRequest, opts ...grpc.CallOption) (*BlobDeleteResponse, error)
	List(ctx context.Context, in *BlobListRequest, opts ...grpc.CallOption) (*BlobListResponse, error)
}

type BlobStoreHandler interface {
	Read(context.Context, *BlobReadRequest, BlobStore_ReadStream) error
	Write(context.Context, BlobStore_WriteStream) error
	Delete(context.Context, *BlobDeleteRequest, *BlobDeleteResponse) error
	List(context.Context, *BlobListRequest, *BlobListResponse) error
}

type BlobStoreServer interface {
	Read(*BlobReadRequest, BlobStore_ReadServer) error
	Write(BlobStore_WriteServer) error
	Delete(context.Context, *BlobDeleteRequest) (*BlobDeleteResponse, error)
	List(context.Context, *BlobListRequest) (*BlobListResponse, error)
	// contains filtered or unexported methods
}

type BlobStoreService interface {
	Read(ctx context.Context, in *BlobReadRequest, opts ...client.CallOption) (BlobStore_ReadService, error)
	Write(ctx context.Context, opts ...client.CallOption) (BlobStore_WriteService, error)
	Delete(ctx context.Context, in *BlobDeleteRequest, opts ...client.CallOption) (*BlobDeleteResponse, error)
	List(ctx context.Context, in *BlobListRequest, opts ...client.CallOption) (*BlobListResponse, error)
}

type BlobStore_ReadClient interface {
	Recv() (*BlobReadResponse, error)
	grpc.ClientStream
}

type BlobStore_ReadServer interface {
	Send(*BlobReadResponse) error
	grpc.ServerStream
}

type BlobStore_ReadService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*BlobReadResponse, error)
}

type BlobStore_ReadStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*BlobReadResponse) error
}

type BlobStore_WriteClient interface {
	Send(*BlobWriteRequest) error
	CloseAndRecv() (*BlobWriteResponse, error)
	grpc.ClientStream
}

type BlobStore_WriteServer interface {
	SendAndClose(*BlobWriteResponse) error
	Recv() (*BlobWriteRequest, error)
	grpc.ServerStream
}

type BlobStore_WriteService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	CloseAndRecv() (*BlobWriteResponse, error)
	Send(*BlobWriteRequest) error
}

type BlobStore_WriteStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	SendAndClose(*BlobWriteResponse) error
	Recv() (*BlobWriteRequest, error)
}

type BlobWriteRequest struct {
	Key     string       `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Options *BlobOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	Blob    []byte       `protobuf:"bytes,3,opt,name=blob,proto3" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

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

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

type DatabasesResponse struct {
	Databases []string `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases,omitempty"`
	// contains filtered or unexported fields
}

type DeleteOptions struct {
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table    string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

type DeleteRequest struct {
	Key     string         `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Options *DeleteOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

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

type Field struct {

	// type of value e.g string, int, int64, bool, float64
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// the actual value
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ListOptions struct {
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table    string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Prefix   string `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Suffix   string `protobuf:"bytes,4,opt,name=suffix,proto3" json:"suffix,omitempty"`
	Limit    uint64 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset   uint64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	Order    string `protobuf:"bytes,7,opt,name=order,proto3" json:"order,omitempty"`
	// contains filtered or unexported fields
}

type ListRequest struct {
	Options *ListOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type ListResponse struct {
	Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

type ReadOptions struct {
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table    string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Prefix   bool   `protobuf:"varint,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Suffix   bool   `protobuf:"varint,4,opt,name=suffix,proto3" json:"suffix,omitempty"`
	Limit    uint64 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset   uint64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	Order    string `protobuf:"bytes,7,opt,name=order,proto3" json:"order,omitempty"`
	// contains filtered or unexported fields
}

type ReadRequest struct {
	Key     string       `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Options *ReadOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type ReadResponse struct {
	Records []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

type Record struct {

	// key of the record
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// value in the record
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// time.Duration (signed int64 nanoseconds)
	Expiry int64 `protobuf:"varint,3,opt,name=expiry,proto3" json:"expiry,omitempty"`
	// the associated metadata
	Metadata map[string]*Field `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

type StoreClient interface {
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (Store_ListClient, error)
	Databases(ctx context.Context, in *DatabasesRequest, opts ...grpc.CallOption) (*DatabasesResponse, error)
	Tables(ctx context.Context, in *TablesRequest, opts ...grpc.CallOption) (*TablesResponse, error)
}

type StoreHandler interface {
	Read(context.Context, *ReadRequest, *ReadResponse) error
	Write(context.Context, *WriteRequest, *WriteResponse) error
	Delete(context.Context, *DeleteRequest, *DeleteResponse) error
	List(context.Context, *ListRequest, Store_ListStream) error
	Databases(context.Context, *DatabasesRequest, *DatabasesResponse) error
	Tables(context.Context, *TablesRequest, *TablesResponse) error
}

type StoreServer interface {
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	List(*ListRequest, Store_ListServer) error
	Databases(context.Context, *DatabasesRequest) (*DatabasesResponse, error)
	Tables(context.Context, *TablesRequest) (*TablesResponse, error)
	// contains filtered or unexported methods
}

type StoreService interface {
	Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)
	Write(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*WriteResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...client.CallOption) (*DeleteResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...client.CallOption) (Store_ListService, error)
	Databases(ctx context.Context, in *DatabasesRequest, opts ...client.CallOption) (*DatabasesResponse, error)
	Tables(ctx context.Context, in *TablesRequest, opts ...client.CallOption) (*TablesResponse, error)
}

type Store_ListClient interface {
	Recv() (*ListResponse, error)
	grpc.ClientStream
}

type Store_ListServer interface {
	Send(*ListResponse) error
	grpc.ServerStream
}

type Store_ListService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*ListResponse, error)
}

type Store_ListStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*ListResponse) error
}

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

type TablesResponse struct {
	Tables []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedBlobStoreServer struct {
}

type UnimplementedStoreServer struct {
}

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

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

type WriteOptions struct {
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table    string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

type WriteRequest struct {
	Record  *Record       `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	Options *WriteOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

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