530 lines
22 KiB
Go
530 lines
22 KiB
Go
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
|
// versions:
|
|
// - protoc-gen-go-grpc v1.6.2
|
|
// - protoc v7.34.1
|
|
// source: kv.proto
|
|
|
|
package waymaker_kv
|
|
|
|
import (
|
|
context "context"
|
|
grpc "google.golang.org/grpc"
|
|
codes "google.golang.org/grpc/codes"
|
|
status "google.golang.org/grpc/status"
|
|
)
|
|
|
|
// This is a compile-time assertion to ensure that this generated file
|
|
// is compatible with the grpc package it is being compiled against.
|
|
// Requires gRPC-Go v1.64.0 or later.
|
|
const _ = grpc.SupportPackageIsVersion9
|
|
|
|
const (
|
|
WaymakerKvService_CreateBucket_FullMethodName = "/waymaker.kv.WaymakerKvService/CreateBucket"
|
|
WaymakerKvService_DeleteBucket_FullMethodName = "/waymaker.kv.WaymakerKvService/DeleteBucket"
|
|
WaymakerKvService_Put_FullMethodName = "/waymaker.kv.WaymakerKvService/Put"
|
|
WaymakerKvService_Create_FullMethodName = "/waymaker.kv.WaymakerKvService/Create"
|
|
WaymakerKvService_Update_FullMethodName = "/waymaker.kv.WaymakerKvService/Update"
|
|
WaymakerKvService_Delete_FullMethodName = "/waymaker.kv.WaymakerKvService/Delete"
|
|
WaymakerKvService_Get_FullMethodName = "/waymaker.kv.WaymakerKvService/Get"
|
|
WaymakerKvService_Keys_FullMethodName = "/waymaker.kv.WaymakerKvService/Keys"
|
|
WaymakerKvService_History_FullMethodName = "/waymaker.kv.WaymakerKvService/History"
|
|
WaymakerKvService_Touch_FullMethodName = "/waymaker.kv.WaymakerKvService/Touch"
|
|
WaymakerKvService_Watch_FullMethodName = "/waymaker.kv.WaymakerKvService/Watch"
|
|
)
|
|
|
|
// WaymakerKvServiceClient is the client API for WaymakerKvService service.
|
|
//
|
|
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
|
|
type WaymakerKvServiceClient interface {
|
|
// ----- Bucket lifecycle -------------------------------------
|
|
CreateBucket(ctx context.Context, in *KvCreateBucketRequest, opts ...grpc.CallOption) (*KvCreateBucketResponse, error)
|
|
DeleteBucket(ctx context.Context, in *KvDeleteBucketRequest, opts ...grpc.CallOption) (*KvDeleteBucketResponse, error)
|
|
// ----- Mutations --------------------------------------------
|
|
Put(ctx context.Context, in *KvPutRequest, opts ...grpc.CallOption) (*KvPutResponse, error)
|
|
// CAS create — succeeds only when the key has never been
|
|
// written or its current value is a tombstone.
|
|
Create(ctx context.Context, in *KvCreateRequest, opts ...grpc.CallOption) (*KvPutResponse, error)
|
|
// CAS update — succeeds only when `expected_revision`
|
|
// matches the server-side revision.
|
|
Update(ctx context.Context, in *KvUpdateRequest, opts ...grpc.CallOption) (*KvPutResponse, error)
|
|
Delete(ctx context.Context, in *KvDeleteRequest, opts ...grpc.CallOption) (*KvDeleteResponse, error)
|
|
// ----- Reads ------------------------------------------------
|
|
Get(ctx context.Context, in *KvGetRequest, opts ...grpc.CallOption) (*KvGetResponse, error)
|
|
Keys(ctx context.Context, in *KvKeysRequest, opts ...grpc.CallOption) (*KvKeysResponse, error)
|
|
History(ctx context.Context, in *KvHistoryRequest, opts ...grpc.CallOption) (*KvHistoryResponse, error)
|
|
// ----- TTL refresh ------------------------------------------
|
|
Touch(ctx context.Context, in *KvTouchRequest, opts ...grpc.CallOption) (*KvPutResponse, error)
|
|
// ----- Watch ------------------------------------------------
|
|
// Server-streamed event flow for a single bucket. When `key`
|
|
// is empty, every put/delete in the bucket fans out; when
|
|
// `key` is set, only events at that key are emitted.
|
|
Watch(ctx context.Context, in *KvWatchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[KvWatchEvent], error)
|
|
}
|
|
|
|
type waymakerKvServiceClient struct {
|
|
cc grpc.ClientConnInterface
|
|
}
|
|
|
|
func NewWaymakerKvServiceClient(cc grpc.ClientConnInterface) WaymakerKvServiceClient {
|
|
return &waymakerKvServiceClient{cc}
|
|
}
|
|
|
|
func (c *waymakerKvServiceClient) CreateBucket(ctx context.Context, in *KvCreateBucketRequest, opts ...grpc.CallOption) (*KvCreateBucketResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(KvCreateBucketResponse)
|
|
err := c.cc.Invoke(ctx, WaymakerKvService_CreateBucket_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *waymakerKvServiceClient) DeleteBucket(ctx context.Context, in *KvDeleteBucketRequest, opts ...grpc.CallOption) (*KvDeleteBucketResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(KvDeleteBucketResponse)
|
|
err := c.cc.Invoke(ctx, WaymakerKvService_DeleteBucket_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *waymakerKvServiceClient) Put(ctx context.Context, in *KvPutRequest, opts ...grpc.CallOption) (*KvPutResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(KvPutResponse)
|
|
err := c.cc.Invoke(ctx, WaymakerKvService_Put_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *waymakerKvServiceClient) Create(ctx context.Context, in *KvCreateRequest, opts ...grpc.CallOption) (*KvPutResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(KvPutResponse)
|
|
err := c.cc.Invoke(ctx, WaymakerKvService_Create_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *waymakerKvServiceClient) Update(ctx context.Context, in *KvUpdateRequest, opts ...grpc.CallOption) (*KvPutResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(KvPutResponse)
|
|
err := c.cc.Invoke(ctx, WaymakerKvService_Update_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *waymakerKvServiceClient) Delete(ctx context.Context, in *KvDeleteRequest, opts ...grpc.CallOption) (*KvDeleteResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(KvDeleteResponse)
|
|
err := c.cc.Invoke(ctx, WaymakerKvService_Delete_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *waymakerKvServiceClient) Get(ctx context.Context, in *KvGetRequest, opts ...grpc.CallOption) (*KvGetResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(KvGetResponse)
|
|
err := c.cc.Invoke(ctx, WaymakerKvService_Get_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *waymakerKvServiceClient) Keys(ctx context.Context, in *KvKeysRequest, opts ...grpc.CallOption) (*KvKeysResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(KvKeysResponse)
|
|
err := c.cc.Invoke(ctx, WaymakerKvService_Keys_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *waymakerKvServiceClient) History(ctx context.Context, in *KvHistoryRequest, opts ...grpc.CallOption) (*KvHistoryResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(KvHistoryResponse)
|
|
err := c.cc.Invoke(ctx, WaymakerKvService_History_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *waymakerKvServiceClient) Touch(ctx context.Context, in *KvTouchRequest, opts ...grpc.CallOption) (*KvPutResponse, error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
out := new(KvPutResponse)
|
|
err := c.cc.Invoke(ctx, WaymakerKvService_Touch_FullMethodName, in, out, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *waymakerKvServiceClient) Watch(ctx context.Context, in *KvWatchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[KvWatchEvent], error) {
|
|
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
|
|
stream, err := c.cc.NewStream(ctx, &WaymakerKvService_ServiceDesc.Streams[0], WaymakerKvService_Watch_FullMethodName, cOpts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &grpc.GenericClientStream[KvWatchRequest, KvWatchEvent]{ClientStream: stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
|
type WaymakerKvService_WatchClient = grpc.ServerStreamingClient[KvWatchEvent]
|
|
|
|
// WaymakerKvServiceServer is the server API for WaymakerKvService service.
|
|
// All implementations must embed UnimplementedWaymakerKvServiceServer
|
|
// for forward compatibility.
|
|
type WaymakerKvServiceServer interface {
|
|
// ----- Bucket lifecycle -------------------------------------
|
|
CreateBucket(context.Context, *KvCreateBucketRequest) (*KvCreateBucketResponse, error)
|
|
DeleteBucket(context.Context, *KvDeleteBucketRequest) (*KvDeleteBucketResponse, error)
|
|
// ----- Mutations --------------------------------------------
|
|
Put(context.Context, *KvPutRequest) (*KvPutResponse, error)
|
|
// CAS create — succeeds only when the key has never been
|
|
// written or its current value is a tombstone.
|
|
Create(context.Context, *KvCreateRequest) (*KvPutResponse, error)
|
|
// CAS update — succeeds only when `expected_revision`
|
|
// matches the server-side revision.
|
|
Update(context.Context, *KvUpdateRequest) (*KvPutResponse, error)
|
|
Delete(context.Context, *KvDeleteRequest) (*KvDeleteResponse, error)
|
|
// ----- Reads ------------------------------------------------
|
|
Get(context.Context, *KvGetRequest) (*KvGetResponse, error)
|
|
Keys(context.Context, *KvKeysRequest) (*KvKeysResponse, error)
|
|
History(context.Context, *KvHistoryRequest) (*KvHistoryResponse, error)
|
|
// ----- TTL refresh ------------------------------------------
|
|
Touch(context.Context, *KvTouchRequest) (*KvPutResponse, error)
|
|
// ----- Watch ------------------------------------------------
|
|
// Server-streamed event flow for a single bucket. When `key`
|
|
// is empty, every put/delete in the bucket fans out; when
|
|
// `key` is set, only events at that key are emitted.
|
|
Watch(*KvWatchRequest, grpc.ServerStreamingServer[KvWatchEvent]) error
|
|
mustEmbedUnimplementedWaymakerKvServiceServer()
|
|
}
|
|
|
|
// UnimplementedWaymakerKvServiceServer must be embedded to have
|
|
// forward compatible implementations.
|
|
//
|
|
// NOTE: this should be embedded by value instead of pointer to avoid a nil
|
|
// pointer dereference when methods are called.
|
|
type UnimplementedWaymakerKvServiceServer struct{}
|
|
|
|
func (UnimplementedWaymakerKvServiceServer) CreateBucket(context.Context, *KvCreateBucketRequest) (*KvCreateBucketResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method CreateBucket not implemented")
|
|
}
|
|
func (UnimplementedWaymakerKvServiceServer) DeleteBucket(context.Context, *KvDeleteBucketRequest) (*KvDeleteBucketResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method DeleteBucket not implemented")
|
|
}
|
|
func (UnimplementedWaymakerKvServiceServer) Put(context.Context, *KvPutRequest) (*KvPutResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method Put not implemented")
|
|
}
|
|
func (UnimplementedWaymakerKvServiceServer) Create(context.Context, *KvCreateRequest) (*KvPutResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method Create not implemented")
|
|
}
|
|
func (UnimplementedWaymakerKvServiceServer) Update(context.Context, *KvUpdateRequest) (*KvPutResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method Update not implemented")
|
|
}
|
|
func (UnimplementedWaymakerKvServiceServer) Delete(context.Context, *KvDeleteRequest) (*KvDeleteResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method Delete not implemented")
|
|
}
|
|
func (UnimplementedWaymakerKvServiceServer) Get(context.Context, *KvGetRequest) (*KvGetResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method Get not implemented")
|
|
}
|
|
func (UnimplementedWaymakerKvServiceServer) Keys(context.Context, *KvKeysRequest) (*KvKeysResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method Keys not implemented")
|
|
}
|
|
func (UnimplementedWaymakerKvServiceServer) History(context.Context, *KvHistoryRequest) (*KvHistoryResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method History not implemented")
|
|
}
|
|
func (UnimplementedWaymakerKvServiceServer) Touch(context.Context, *KvTouchRequest) (*KvPutResponse, error) {
|
|
return nil, status.Error(codes.Unimplemented, "method Touch not implemented")
|
|
}
|
|
func (UnimplementedWaymakerKvServiceServer) Watch(*KvWatchRequest, grpc.ServerStreamingServer[KvWatchEvent]) error {
|
|
return status.Error(codes.Unimplemented, "method Watch not implemented")
|
|
}
|
|
func (UnimplementedWaymakerKvServiceServer) mustEmbedUnimplementedWaymakerKvServiceServer() {}
|
|
func (UnimplementedWaymakerKvServiceServer) testEmbeddedByValue() {}
|
|
|
|
// UnsafeWaymakerKvServiceServer may be embedded to opt out of forward compatibility for this service.
|
|
// Use of this interface is not recommended, as added methods to WaymakerKvServiceServer will
|
|
// result in compilation errors.
|
|
type UnsafeWaymakerKvServiceServer interface {
|
|
mustEmbedUnimplementedWaymakerKvServiceServer()
|
|
}
|
|
|
|
func RegisterWaymakerKvServiceServer(s grpc.ServiceRegistrar, srv WaymakerKvServiceServer) {
|
|
// If the following call panics, it indicates UnimplementedWaymakerKvServiceServer was
|
|
// embedded by pointer and is nil. This will cause panics if an
|
|
// unimplemented method is ever invoked, so we test this at initialization
|
|
// time to prevent it from happening at runtime later due to I/O.
|
|
if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
|
|
t.testEmbeddedByValue()
|
|
}
|
|
s.RegisterService(&WaymakerKvService_ServiceDesc, srv)
|
|
}
|
|
|
|
func _WaymakerKvService_CreateBucket_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(KvCreateBucketRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(WaymakerKvServiceServer).CreateBucket(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: WaymakerKvService_CreateBucket_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(WaymakerKvServiceServer).CreateBucket(ctx, req.(*KvCreateBucketRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _WaymakerKvService_DeleteBucket_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(KvDeleteBucketRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(WaymakerKvServiceServer).DeleteBucket(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: WaymakerKvService_DeleteBucket_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(WaymakerKvServiceServer).DeleteBucket(ctx, req.(*KvDeleteBucketRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _WaymakerKvService_Put_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(KvPutRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(WaymakerKvServiceServer).Put(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: WaymakerKvService_Put_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(WaymakerKvServiceServer).Put(ctx, req.(*KvPutRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _WaymakerKvService_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(KvCreateRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(WaymakerKvServiceServer).Create(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: WaymakerKvService_Create_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(WaymakerKvServiceServer).Create(ctx, req.(*KvCreateRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _WaymakerKvService_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(KvUpdateRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(WaymakerKvServiceServer).Update(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: WaymakerKvService_Update_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(WaymakerKvServiceServer).Update(ctx, req.(*KvUpdateRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _WaymakerKvService_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(KvDeleteRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(WaymakerKvServiceServer).Delete(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: WaymakerKvService_Delete_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(WaymakerKvServiceServer).Delete(ctx, req.(*KvDeleteRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _WaymakerKvService_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(KvGetRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(WaymakerKvServiceServer).Get(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: WaymakerKvService_Get_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(WaymakerKvServiceServer).Get(ctx, req.(*KvGetRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _WaymakerKvService_Keys_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(KvKeysRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(WaymakerKvServiceServer).Keys(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: WaymakerKvService_Keys_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(WaymakerKvServiceServer).Keys(ctx, req.(*KvKeysRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _WaymakerKvService_History_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(KvHistoryRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(WaymakerKvServiceServer).History(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: WaymakerKvService_History_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(WaymakerKvServiceServer).History(ctx, req.(*KvHistoryRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _WaymakerKvService_Touch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(KvTouchRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(WaymakerKvServiceServer).Touch(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: WaymakerKvService_Touch_FullMethodName,
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(WaymakerKvServiceServer).Touch(ctx, req.(*KvTouchRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _WaymakerKvService_Watch_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(KvWatchRequest)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(WaymakerKvServiceServer).Watch(m, &grpc.GenericServerStream[KvWatchRequest, KvWatchEvent]{ServerStream: stream})
|
|
}
|
|
|
|
// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
|
|
type WaymakerKvService_WatchServer = grpc.ServerStreamingServer[KvWatchEvent]
|
|
|
|
// WaymakerKvService_ServiceDesc is the grpc.ServiceDesc for WaymakerKvService service.
|
|
// It's only intended for direct use with grpc.RegisterService,
|
|
// and not to be introspected or modified (even as a copy)
|
|
var WaymakerKvService_ServiceDesc = grpc.ServiceDesc{
|
|
ServiceName: "waymaker.kv.WaymakerKvService",
|
|
HandlerType: (*WaymakerKvServiceServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "CreateBucket",
|
|
Handler: _WaymakerKvService_CreateBucket_Handler,
|
|
},
|
|
{
|
|
MethodName: "DeleteBucket",
|
|
Handler: _WaymakerKvService_DeleteBucket_Handler,
|
|
},
|
|
{
|
|
MethodName: "Put",
|
|
Handler: _WaymakerKvService_Put_Handler,
|
|
},
|
|
{
|
|
MethodName: "Create",
|
|
Handler: _WaymakerKvService_Create_Handler,
|
|
},
|
|
{
|
|
MethodName: "Update",
|
|
Handler: _WaymakerKvService_Update_Handler,
|
|
},
|
|
{
|
|
MethodName: "Delete",
|
|
Handler: _WaymakerKvService_Delete_Handler,
|
|
},
|
|
{
|
|
MethodName: "Get",
|
|
Handler: _WaymakerKvService_Get_Handler,
|
|
},
|
|
{
|
|
MethodName: "Keys",
|
|
Handler: _WaymakerKvService_Keys_Handler,
|
|
},
|
|
{
|
|
MethodName: "History",
|
|
Handler: _WaymakerKvService_History_Handler,
|
|
},
|
|
{
|
|
MethodName: "Touch",
|
|
Handler: _WaymakerKvService_Touch_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{
|
|
{
|
|
StreamName: "Watch",
|
|
Handler: _WaymakerKvService_Watch_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
},
|
|
Metadata: "kv.proto",
|
|
}
|