riverpb

type BatchDelOption struct {
	Keys      [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	BatchSize int64    `protobuf:"varint,2,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	// contains filtered or unexported fields
}

type BatchPutOption struct {
	Records   []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	BatchSize int64     `protobuf:"varint,2,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	// contains filtered or unexported fields
}

type BatchResult struct {
	Ok       bool  `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Effected int64 `protobuf:"varint,2,opt,name=effected,proto3" json:"effected,omitempty"`
	// contains filtered or unexported fields
}

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

type ExpRecord struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Ttl int64  `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

type InfoResult struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

type RangeOption struct {
	MinKey  []byte `protobuf:"bytes,1,opt,name=minKey,proto3" json:"minKey,omitempty"`
	MaxKey  []byte `protobuf:"bytes,2,opt,name=maxKey,proto3" json:"maxKey,omitempty"`
	Pattern []byte `protobuf:"bytes,3,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Descend bool   `protobuf:"varint,4,opt,name=descend,proto3" json:"descend,omitempty"`
	// contains filtered or unexported fields
}

type RangeResult struct {
	Keys  [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Count int64    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

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

type Record struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Ttl   int64  `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

type RiverClient interface {
	Get(ctx context.Context, in *RawData, opts ...grpc.CallOption) (*DataResult, error)
	TTL(ctx context.Context, in *RawData, opts ...grpc.CallOption) (*TTLResult, error)
	Put(ctx context.Context, in *Record, opts ...grpc.CallOption) (*InfoResult, error)
	PutInBatch(ctx context.Context, in *BatchPutOption, opts ...grpc.CallOption) (*BatchResult, error)
	Exp(ctx context.Context, in *ExpRecord, opts ...grpc.CallOption) (*InfoResult, error)
	Del(ctx context.Context, in *RawData, opts ...grpc.CallOption) (*InfoResult, error)
	DelInBatch(ctx context.Context, in *BatchDelOption, opts ...grpc.CallOption) (*BatchResult, error)
	Stat(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Status, error)
	Range(ctx context.Context, in *RangeOption, opts ...grpc.CallOption) (*RangeResult, error)
}

type RiverServer interface {
	Get(context.Context, *RawData) (*DataResult, error)
	TTL(context.Context, *RawData) (*TTLResult, error)
	Put(context.Context, *Record) (*InfoResult, error)
	PutInBatch(context.Context, *BatchPutOption) (*BatchResult, error)
	Exp(context.Context, *ExpRecord) (*InfoResult, error)
	Del(context.Context, *RawData) (*InfoResult, error)
	DelInBatch(context.Context, *BatchDelOption) (*BatchResult, error)
	Stat(context.Context, *emptypb.Empty) (*Status, error)
	Range(context.Context, *RangeOption) (*RangeResult, error)
	// contains filtered or unexported methods
}

type Status struct {
	Keys     int64 `protobuf:"varint,1,opt,name=keys,proto3" json:"keys,omitempty"`
	Records  int64 `protobuf:"varint,2,opt,name=records,proto3" json:"records,omitempty"`
	Datasize int64 `protobuf:"varint,3,opt,name=datasize,proto3" json:"datasize,omitempty"`
	Hintsize int64 `protobuf:"varint,4,opt,name=hintsize,proto3" json:"hintsize,omitempty"`
	// contains filtered or unexported fields
}

type TTLResult struct {
	Ok  bool  `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Ttl int64 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedRiverServer struct {
}

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