knocigrpc

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

type ClientSecurityOptions struct {
	TLSCACertFile  string
	TLSServerName  string
	ClientCertFile string
	ClientKeyFile  string
	EnableAuth     bool
	AuthToken      string
}

type KVServiceClient interface {
	Get(context.Context, *wrapperspb.BytesValue, ...grpc.CallOption) (*wrapperspb.BytesValue, error)
	Put(context.Context, *wrapperspb.BytesValue, ...grpc.CallOption) (*emptypb.Empty, error)
	Delete(context.Context, *wrapperspb.BytesValue, ...grpc.CallOption) (*emptypb.Empty, error)
	// Batch 客户端流：发送多条 Put/Delete 操作
	Batch(context.Context, ...grpc.CallOption) (KVService_BatchClient, error)
	// Scan 服务端流：按范围返回 KV
	Scan(context.Context, *wrapperspb.BytesValue, ...grpc.CallOption) (KVService_ScanClient, error)
}

type KVServiceServer interface {
	Get(context.Context, *wrapperspb.BytesValue) (*wrapperspb.BytesValue, error)
	Put(context.Context, *wrapperspb.BytesValue) (*emptypb.Empty, error)
	Delete(context.Context, *wrapperspb.BytesValue) (*emptypb.Empty, error)
	// Batch 客户端流：接收多条操作（Put/Delete），在服务端批量提交
	Batch(KVService_BatchServer) error
	// Scan 服务端流：在B+Tree模式下按范围扫描并流式返回KV
	Scan(*wrapperspb.BytesValue, KVService_ScanServer) error
}

type KVService_BatchClient interface {
	Send(*wrapperspb.BytesValue) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type KVService_BatchServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*wrapperspb.BytesValue, error)
	grpc.ServerStream
}

type KVService_ScanClient interface {
	Recv() (*wrapperspb.BytesValue, error)
	grpc.ClientStream
}

type KVService_ScanServer interface {
	Send(*wrapperspb.BytesValue) error
	grpc.ServerStream
}

type Server struct {

	// EnableAuth 指示是否启用基于 token 的鉴权
	EnableAuth bool
	// AuthToken 服务端校验的令牌（通过 metadata: authorization / x-api-key 传入）
	AuthToken string
	// contains filtered or unexported fields
}

type ServerSecurityOptions struct {
	TLSCertFile       string
	TLSKeyFile        string
	TLSClientCAFile   string
	RequireClientCert bool
	EnableAuth        bool
	AuthToken         string
}