Browse Source
upgrade protoc to 3.17.3
upgrade protoc to 3.17.3
$brew install protobuf $ protoc --version libprotoc 3.17.3 $ go install google.golang.org/protobuf/cmd/protoc-gen-go@v1.26 $ go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@v1.1pull/2500/head
chrislu
3 years ago
16 changed files with 3817 additions and 3754 deletions
-
2weed/messaging/broker/broker_server.go
-
12weed/pb/Makefile
-
954weed/pb/filer_pb/filer.pb.go
-
962weed/pb/filer_pb/filer_grpc.pb.go
-
53weed/pb/iam_pb/iam.pb.go
-
62weed/pb/iam_pb/iam_grpc.pb.go
-
626weed/pb/master_pb/master.pb.go
-
634weed/pb/master_pb/master_grpc.pb.go
-
338weed/pb/messaging_pb/messaging.pb.go
-
346weed/pb/messaging_pb/messaging_grpc.pb.go
-
9weed/pb/remote_pb/remote.pb.go
-
1780weed/pb/volume_server_pb/volume_server.pb.go
-
1788weed/pb/volume_server_pb/volume_server_grpc.pb.go
-
2weed/server/filer_server.go
-
1weed/server/master_server.go
-
2weed/server/volume_server.go
@ -0,0 +1,962 @@ |
|||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
|||
|
|||
package filer_pb |
|||
|
|||
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.32.0 or later.
|
|||
const _ = grpc.SupportPackageIsVersion7 |
|||
|
|||
// SeaweedFilerClient is the client API for SeaweedFiler 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 SeaweedFilerClient interface { |
|||
LookupDirectoryEntry(ctx context.Context, in *LookupDirectoryEntryRequest, opts ...grpc.CallOption) (*LookupDirectoryEntryResponse, error) |
|||
ListEntries(ctx context.Context, in *ListEntriesRequest, opts ...grpc.CallOption) (SeaweedFiler_ListEntriesClient, error) |
|||
CreateEntry(ctx context.Context, in *CreateEntryRequest, opts ...grpc.CallOption) (*CreateEntryResponse, error) |
|||
UpdateEntry(ctx context.Context, in *UpdateEntryRequest, opts ...grpc.CallOption) (*UpdateEntryResponse, error) |
|||
AppendToEntry(ctx context.Context, in *AppendToEntryRequest, opts ...grpc.CallOption) (*AppendToEntryResponse, error) |
|||
DeleteEntry(ctx context.Context, in *DeleteEntryRequest, opts ...grpc.CallOption) (*DeleteEntryResponse, error) |
|||
AtomicRenameEntry(ctx context.Context, in *AtomicRenameEntryRequest, opts ...grpc.CallOption) (*AtomicRenameEntryResponse, error) |
|||
StreamRenameEntry(ctx context.Context, in *StreamRenameEntryRequest, opts ...grpc.CallOption) (SeaweedFiler_StreamRenameEntryClient, error) |
|||
AssignVolume(ctx context.Context, in *AssignVolumeRequest, opts ...grpc.CallOption) (*AssignVolumeResponse, error) |
|||
LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error) |
|||
CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error) |
|||
DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error) |
|||
Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error) |
|||
GetFilerConfiguration(ctx context.Context, in *GetFilerConfigurationRequest, opts ...grpc.CallOption) (*GetFilerConfigurationResponse, error) |
|||
SubscribeMetadata(ctx context.Context, in *SubscribeMetadataRequest, opts ...grpc.CallOption) (SeaweedFiler_SubscribeMetadataClient, error) |
|||
SubscribeLocalMetadata(ctx context.Context, in *SubscribeMetadataRequest, opts ...grpc.CallOption) (SeaweedFiler_SubscribeLocalMetadataClient, error) |
|||
KeepConnected(ctx context.Context, opts ...grpc.CallOption) (SeaweedFiler_KeepConnectedClient, error) |
|||
LocateBroker(ctx context.Context, in *LocateBrokerRequest, opts ...grpc.CallOption) (*LocateBrokerResponse, error) |
|||
KvGet(ctx context.Context, in *KvGetRequest, opts ...grpc.CallOption) (*KvGetResponse, error) |
|||
KvPut(ctx context.Context, in *KvPutRequest, opts ...grpc.CallOption) (*KvPutResponse, error) |
|||
CacheRemoteObjectToLocalCluster(ctx context.Context, in *CacheRemoteObjectToLocalClusterRequest, opts ...grpc.CallOption) (*CacheRemoteObjectToLocalClusterResponse, error) |
|||
} |
|||
|
|||
type seaweedFilerClient struct { |
|||
cc grpc.ClientConnInterface |
|||
} |
|||
|
|||
func NewSeaweedFilerClient(cc grpc.ClientConnInterface) SeaweedFilerClient { |
|||
return &seaweedFilerClient{cc} |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) LookupDirectoryEntry(ctx context.Context, in *LookupDirectoryEntryRequest, opts ...grpc.CallOption) (*LookupDirectoryEntryResponse, error) { |
|||
out := new(LookupDirectoryEntryResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/LookupDirectoryEntry", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) ListEntries(ctx context.Context, in *ListEntriesRequest, opts ...grpc.CallOption) (SeaweedFiler_ListEntriesClient, error) { |
|||
stream, err := c.cc.NewStream(ctx, &SeaweedFiler_ServiceDesc.Streams[0], "/filer_pb.SeaweedFiler/ListEntries", opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
x := &seaweedFilerListEntriesClient{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 |
|||
} |
|||
|
|||
type SeaweedFiler_ListEntriesClient interface { |
|||
Recv() (*ListEntriesResponse, error) |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
type seaweedFilerListEntriesClient struct { |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
func (x *seaweedFilerListEntriesClient) Recv() (*ListEntriesResponse, error) { |
|||
m := new(ListEntriesResponse) |
|||
if err := x.ClientStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) CreateEntry(ctx context.Context, in *CreateEntryRequest, opts ...grpc.CallOption) (*CreateEntryResponse, error) { |
|||
out := new(CreateEntryResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/CreateEntry", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) UpdateEntry(ctx context.Context, in *UpdateEntryRequest, opts ...grpc.CallOption) (*UpdateEntryResponse, error) { |
|||
out := new(UpdateEntryResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/UpdateEntry", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) AppendToEntry(ctx context.Context, in *AppendToEntryRequest, opts ...grpc.CallOption) (*AppendToEntryResponse, error) { |
|||
out := new(AppendToEntryResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/AppendToEntry", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) DeleteEntry(ctx context.Context, in *DeleteEntryRequest, opts ...grpc.CallOption) (*DeleteEntryResponse, error) { |
|||
out := new(DeleteEntryResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/DeleteEntry", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) AtomicRenameEntry(ctx context.Context, in *AtomicRenameEntryRequest, opts ...grpc.CallOption) (*AtomicRenameEntryResponse, error) { |
|||
out := new(AtomicRenameEntryResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/AtomicRenameEntry", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) StreamRenameEntry(ctx context.Context, in *StreamRenameEntryRequest, opts ...grpc.CallOption) (SeaweedFiler_StreamRenameEntryClient, error) { |
|||
stream, err := c.cc.NewStream(ctx, &SeaweedFiler_ServiceDesc.Streams[1], "/filer_pb.SeaweedFiler/StreamRenameEntry", opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
x := &seaweedFilerStreamRenameEntryClient{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 |
|||
} |
|||
|
|||
type SeaweedFiler_StreamRenameEntryClient interface { |
|||
Recv() (*StreamRenameEntryResponse, error) |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
type seaweedFilerStreamRenameEntryClient struct { |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
func (x *seaweedFilerStreamRenameEntryClient) Recv() (*StreamRenameEntryResponse, error) { |
|||
m := new(StreamRenameEntryResponse) |
|||
if err := x.ClientStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) AssignVolume(ctx context.Context, in *AssignVolumeRequest, opts ...grpc.CallOption) (*AssignVolumeResponse, error) { |
|||
out := new(AssignVolumeResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/AssignVolume", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error) { |
|||
out := new(LookupVolumeResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/LookupVolume", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error) { |
|||
out := new(CollectionListResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/CollectionList", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error) { |
|||
out := new(DeleteCollectionResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/DeleteCollection", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error) { |
|||
out := new(StatisticsResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/Statistics", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) GetFilerConfiguration(ctx context.Context, in *GetFilerConfigurationRequest, opts ...grpc.CallOption) (*GetFilerConfigurationResponse, error) { |
|||
out := new(GetFilerConfigurationResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/GetFilerConfiguration", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) SubscribeMetadata(ctx context.Context, in *SubscribeMetadataRequest, opts ...grpc.CallOption) (SeaweedFiler_SubscribeMetadataClient, error) { |
|||
stream, err := c.cc.NewStream(ctx, &SeaweedFiler_ServiceDesc.Streams[2], "/filer_pb.SeaweedFiler/SubscribeMetadata", opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
x := &seaweedFilerSubscribeMetadataClient{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 |
|||
} |
|||
|
|||
type SeaweedFiler_SubscribeMetadataClient interface { |
|||
Recv() (*SubscribeMetadataResponse, error) |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
type seaweedFilerSubscribeMetadataClient struct { |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
func (x *seaweedFilerSubscribeMetadataClient) Recv() (*SubscribeMetadataResponse, error) { |
|||
m := new(SubscribeMetadataResponse) |
|||
if err := x.ClientStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) SubscribeLocalMetadata(ctx context.Context, in *SubscribeMetadataRequest, opts ...grpc.CallOption) (SeaweedFiler_SubscribeLocalMetadataClient, error) { |
|||
stream, err := c.cc.NewStream(ctx, &SeaweedFiler_ServiceDesc.Streams[3], "/filer_pb.SeaweedFiler/SubscribeLocalMetadata", opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
x := &seaweedFilerSubscribeLocalMetadataClient{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 |
|||
} |
|||
|
|||
type SeaweedFiler_SubscribeLocalMetadataClient interface { |
|||
Recv() (*SubscribeMetadataResponse, error) |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
type seaweedFilerSubscribeLocalMetadataClient struct { |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
func (x *seaweedFilerSubscribeLocalMetadataClient) Recv() (*SubscribeMetadataResponse, error) { |
|||
m := new(SubscribeMetadataResponse) |
|||
if err := x.ClientStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) KeepConnected(ctx context.Context, opts ...grpc.CallOption) (SeaweedFiler_KeepConnectedClient, error) { |
|||
stream, err := c.cc.NewStream(ctx, &SeaweedFiler_ServiceDesc.Streams[4], "/filer_pb.SeaweedFiler/KeepConnected", opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
x := &seaweedFilerKeepConnectedClient{stream} |
|||
return x, nil |
|||
} |
|||
|
|||
type SeaweedFiler_KeepConnectedClient interface { |
|||
Send(*KeepConnectedRequest) error |
|||
Recv() (*KeepConnectedResponse, error) |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
type seaweedFilerKeepConnectedClient struct { |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
func (x *seaweedFilerKeepConnectedClient) Send(m *KeepConnectedRequest) error { |
|||
return x.ClientStream.SendMsg(m) |
|||
} |
|||
|
|||
func (x *seaweedFilerKeepConnectedClient) Recv() (*KeepConnectedResponse, error) { |
|||
m := new(KeepConnectedResponse) |
|||
if err := x.ClientStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) LocateBroker(ctx context.Context, in *LocateBrokerRequest, opts ...grpc.CallOption) (*LocateBrokerResponse, error) { |
|||
out := new(LocateBrokerResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/LocateBroker", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) KvGet(ctx context.Context, in *KvGetRequest, opts ...grpc.CallOption) (*KvGetResponse, error) { |
|||
out := new(KvGetResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/KvGet", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) KvPut(ctx context.Context, in *KvPutRequest, opts ...grpc.CallOption) (*KvPutResponse, error) { |
|||
out := new(KvPutResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/KvPut", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedFilerClient) CacheRemoteObjectToLocalCluster(ctx context.Context, in *CacheRemoteObjectToLocalClusterRequest, opts ...grpc.CallOption) (*CacheRemoteObjectToLocalClusterResponse, error) { |
|||
out := new(CacheRemoteObjectToLocalClusterResponse) |
|||
err := c.cc.Invoke(ctx, "/filer_pb.SeaweedFiler/CacheRemoteObjectToLocalCluster", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
// SeaweedFilerServer is the server API for SeaweedFiler service.
|
|||
// All implementations must embed UnimplementedSeaweedFilerServer
|
|||
// for forward compatibility
|
|||
type SeaweedFilerServer interface { |
|||
LookupDirectoryEntry(context.Context, *LookupDirectoryEntryRequest) (*LookupDirectoryEntryResponse, error) |
|||
ListEntries(*ListEntriesRequest, SeaweedFiler_ListEntriesServer) error |
|||
CreateEntry(context.Context, *CreateEntryRequest) (*CreateEntryResponse, error) |
|||
UpdateEntry(context.Context, *UpdateEntryRequest) (*UpdateEntryResponse, error) |
|||
AppendToEntry(context.Context, *AppendToEntryRequest) (*AppendToEntryResponse, error) |
|||
DeleteEntry(context.Context, *DeleteEntryRequest) (*DeleteEntryResponse, error) |
|||
AtomicRenameEntry(context.Context, *AtomicRenameEntryRequest) (*AtomicRenameEntryResponse, error) |
|||
StreamRenameEntry(*StreamRenameEntryRequest, SeaweedFiler_StreamRenameEntryServer) error |
|||
AssignVolume(context.Context, *AssignVolumeRequest) (*AssignVolumeResponse, error) |
|||
LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error) |
|||
CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error) |
|||
DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error) |
|||
Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error) |
|||
GetFilerConfiguration(context.Context, *GetFilerConfigurationRequest) (*GetFilerConfigurationResponse, error) |
|||
SubscribeMetadata(*SubscribeMetadataRequest, SeaweedFiler_SubscribeMetadataServer) error |
|||
SubscribeLocalMetadata(*SubscribeMetadataRequest, SeaweedFiler_SubscribeLocalMetadataServer) error |
|||
KeepConnected(SeaweedFiler_KeepConnectedServer) error |
|||
LocateBroker(context.Context, *LocateBrokerRequest) (*LocateBrokerResponse, error) |
|||
KvGet(context.Context, *KvGetRequest) (*KvGetResponse, error) |
|||
KvPut(context.Context, *KvPutRequest) (*KvPutResponse, error) |
|||
CacheRemoteObjectToLocalCluster(context.Context, *CacheRemoteObjectToLocalClusterRequest) (*CacheRemoteObjectToLocalClusterResponse, error) |
|||
mustEmbedUnimplementedSeaweedFilerServer() |
|||
} |
|||
|
|||
// UnimplementedSeaweedFilerServer must be embedded to have forward compatible implementations.
|
|||
type UnimplementedSeaweedFilerServer struct { |
|||
} |
|||
|
|||
func (UnimplementedSeaweedFilerServer) LookupDirectoryEntry(context.Context, *LookupDirectoryEntryRequest) (*LookupDirectoryEntryResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method LookupDirectoryEntry not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) ListEntries(*ListEntriesRequest, SeaweedFiler_ListEntriesServer) error { |
|||
return status.Errorf(codes.Unimplemented, "method ListEntries not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) CreateEntry(context.Context, *CreateEntryRequest) (*CreateEntryResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method CreateEntry not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) UpdateEntry(context.Context, *UpdateEntryRequest) (*UpdateEntryResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method UpdateEntry not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) AppendToEntry(context.Context, *AppendToEntryRequest) (*AppendToEntryResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method AppendToEntry not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) DeleteEntry(context.Context, *DeleteEntryRequest) (*DeleteEntryResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method DeleteEntry not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) AtomicRenameEntry(context.Context, *AtomicRenameEntryRequest) (*AtomicRenameEntryResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method AtomicRenameEntry not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) StreamRenameEntry(*StreamRenameEntryRequest, SeaweedFiler_StreamRenameEntryServer) error { |
|||
return status.Errorf(codes.Unimplemented, "method StreamRenameEntry not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) AssignVolume(context.Context, *AssignVolumeRequest) (*AssignVolumeResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method AssignVolume not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method LookupVolume not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method CollectionList not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method DeleteCollection not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method Statistics not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) GetFilerConfiguration(context.Context, *GetFilerConfigurationRequest) (*GetFilerConfigurationResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method GetFilerConfiguration not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) SubscribeMetadata(*SubscribeMetadataRequest, SeaweedFiler_SubscribeMetadataServer) error { |
|||
return status.Errorf(codes.Unimplemented, "method SubscribeMetadata not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) SubscribeLocalMetadata(*SubscribeMetadataRequest, SeaweedFiler_SubscribeLocalMetadataServer) error { |
|||
return status.Errorf(codes.Unimplemented, "method SubscribeLocalMetadata not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) KeepConnected(SeaweedFiler_KeepConnectedServer) error { |
|||
return status.Errorf(codes.Unimplemented, "method KeepConnected not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) LocateBroker(context.Context, *LocateBrokerRequest) (*LocateBrokerResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method LocateBroker not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) KvGet(context.Context, *KvGetRequest) (*KvGetResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method KvGet not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) KvPut(context.Context, *KvPutRequest) (*KvPutResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method KvPut not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) CacheRemoteObjectToLocalCluster(context.Context, *CacheRemoteObjectToLocalClusterRequest) (*CacheRemoteObjectToLocalClusterResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method CacheRemoteObjectToLocalCluster not implemented") |
|||
} |
|||
func (UnimplementedSeaweedFilerServer) mustEmbedUnimplementedSeaweedFilerServer() {} |
|||
|
|||
// UnsafeSeaweedFilerServer may be embedded to opt out of forward compatibility for this service.
|
|||
// Use of this interface is not recommended, as added methods to SeaweedFilerServer will
|
|||
// result in compilation errors.
|
|||
type UnsafeSeaweedFilerServer interface { |
|||
mustEmbedUnimplementedSeaweedFilerServer() |
|||
} |
|||
|
|||
func RegisterSeaweedFilerServer(s grpc.ServiceRegistrar, srv SeaweedFilerServer) { |
|||
s.RegisterService(&SeaweedFiler_ServiceDesc, srv) |
|||
} |
|||
|
|||
func _SeaweedFiler_LookupDirectoryEntry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(LookupDirectoryEntryRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).LookupDirectoryEntry(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/LookupDirectoryEntry", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).LookupDirectoryEntry(ctx, req.(*LookupDirectoryEntryRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_ListEntries_Handler(srv interface{}, stream grpc.ServerStream) error { |
|||
m := new(ListEntriesRequest) |
|||
if err := stream.RecvMsg(m); err != nil { |
|||
return err |
|||
} |
|||
return srv.(SeaweedFilerServer).ListEntries(m, &seaweedFilerListEntriesServer{stream}) |
|||
} |
|||
|
|||
type SeaweedFiler_ListEntriesServer interface { |
|||
Send(*ListEntriesResponse) error |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
type seaweedFilerListEntriesServer struct { |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
func (x *seaweedFilerListEntriesServer) Send(m *ListEntriesResponse) error { |
|||
return x.ServerStream.SendMsg(m) |
|||
} |
|||
|
|||
func _SeaweedFiler_CreateEntry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(CreateEntryRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).CreateEntry(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/CreateEntry", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).CreateEntry(ctx, req.(*CreateEntryRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_UpdateEntry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(UpdateEntryRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).UpdateEntry(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/UpdateEntry", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).UpdateEntry(ctx, req.(*UpdateEntryRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_AppendToEntry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(AppendToEntryRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).AppendToEntry(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/AppendToEntry", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).AppendToEntry(ctx, req.(*AppendToEntryRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_DeleteEntry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(DeleteEntryRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).DeleteEntry(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/DeleteEntry", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).DeleteEntry(ctx, req.(*DeleteEntryRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_AtomicRenameEntry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(AtomicRenameEntryRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).AtomicRenameEntry(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/AtomicRenameEntry", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).AtomicRenameEntry(ctx, req.(*AtomicRenameEntryRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_StreamRenameEntry_Handler(srv interface{}, stream grpc.ServerStream) error { |
|||
m := new(StreamRenameEntryRequest) |
|||
if err := stream.RecvMsg(m); err != nil { |
|||
return err |
|||
} |
|||
return srv.(SeaweedFilerServer).StreamRenameEntry(m, &seaweedFilerStreamRenameEntryServer{stream}) |
|||
} |
|||
|
|||
type SeaweedFiler_StreamRenameEntryServer interface { |
|||
Send(*StreamRenameEntryResponse) error |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
type seaweedFilerStreamRenameEntryServer struct { |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
func (x *seaweedFilerStreamRenameEntryServer) Send(m *StreamRenameEntryResponse) error { |
|||
return x.ServerStream.SendMsg(m) |
|||
} |
|||
|
|||
func _SeaweedFiler_AssignVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(AssignVolumeRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).AssignVolume(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/AssignVolume", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).AssignVolume(ctx, req.(*AssignVolumeRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_LookupVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(LookupVolumeRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).LookupVolume(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/LookupVolume", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).LookupVolume(ctx, req.(*LookupVolumeRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_CollectionList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(CollectionListRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).CollectionList(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/CollectionList", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).CollectionList(ctx, req.(*CollectionListRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_DeleteCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(DeleteCollectionRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).DeleteCollection(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/DeleteCollection", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).DeleteCollection(ctx, req.(*DeleteCollectionRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_Statistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(StatisticsRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).Statistics(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/Statistics", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).Statistics(ctx, req.(*StatisticsRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_GetFilerConfiguration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(GetFilerConfigurationRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).GetFilerConfiguration(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/GetFilerConfiguration", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).GetFilerConfiguration(ctx, req.(*GetFilerConfigurationRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_SubscribeMetadata_Handler(srv interface{}, stream grpc.ServerStream) error { |
|||
m := new(SubscribeMetadataRequest) |
|||
if err := stream.RecvMsg(m); err != nil { |
|||
return err |
|||
} |
|||
return srv.(SeaweedFilerServer).SubscribeMetadata(m, &seaweedFilerSubscribeMetadataServer{stream}) |
|||
} |
|||
|
|||
type SeaweedFiler_SubscribeMetadataServer interface { |
|||
Send(*SubscribeMetadataResponse) error |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
type seaweedFilerSubscribeMetadataServer struct { |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
func (x *seaweedFilerSubscribeMetadataServer) Send(m *SubscribeMetadataResponse) error { |
|||
return x.ServerStream.SendMsg(m) |
|||
} |
|||
|
|||
func _SeaweedFiler_SubscribeLocalMetadata_Handler(srv interface{}, stream grpc.ServerStream) error { |
|||
m := new(SubscribeMetadataRequest) |
|||
if err := stream.RecvMsg(m); err != nil { |
|||
return err |
|||
} |
|||
return srv.(SeaweedFilerServer).SubscribeLocalMetadata(m, &seaweedFilerSubscribeLocalMetadataServer{stream}) |
|||
} |
|||
|
|||
type SeaweedFiler_SubscribeLocalMetadataServer interface { |
|||
Send(*SubscribeMetadataResponse) error |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
type seaweedFilerSubscribeLocalMetadataServer struct { |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
func (x *seaweedFilerSubscribeLocalMetadataServer) Send(m *SubscribeMetadataResponse) error { |
|||
return x.ServerStream.SendMsg(m) |
|||
} |
|||
|
|||
func _SeaweedFiler_KeepConnected_Handler(srv interface{}, stream grpc.ServerStream) error { |
|||
return srv.(SeaweedFilerServer).KeepConnected(&seaweedFilerKeepConnectedServer{stream}) |
|||
} |
|||
|
|||
type SeaweedFiler_KeepConnectedServer interface { |
|||
Send(*KeepConnectedResponse) error |
|||
Recv() (*KeepConnectedRequest, error) |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
type seaweedFilerKeepConnectedServer struct { |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
func (x *seaweedFilerKeepConnectedServer) Send(m *KeepConnectedResponse) error { |
|||
return x.ServerStream.SendMsg(m) |
|||
} |
|||
|
|||
func (x *seaweedFilerKeepConnectedServer) Recv() (*KeepConnectedRequest, error) { |
|||
m := new(KeepConnectedRequest) |
|||
if err := x.ServerStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func _SeaweedFiler_LocateBroker_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(LocateBrokerRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).LocateBroker(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/LocateBroker", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).LocateBroker(ctx, req.(*LocateBrokerRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_KvGet_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.(SeaweedFilerServer).KvGet(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/KvGet", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).KvGet(ctx, req.(*KvGetRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_KvPut_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.(SeaweedFilerServer).KvPut(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/KvPut", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).KvPut(ctx, req.(*KvPutRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedFiler_CacheRemoteObjectToLocalCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(CacheRemoteObjectToLocalClusterRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedFilerServer).CacheRemoteObjectToLocalCluster(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/filer_pb.SeaweedFiler/CacheRemoteObjectToLocalCluster", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedFilerServer).CacheRemoteObjectToLocalCluster(ctx, req.(*CacheRemoteObjectToLocalClusterRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
// SeaweedFiler_ServiceDesc is the grpc.ServiceDesc for SeaweedFiler service.
|
|||
// It's only intended for direct use with grpc.RegisterService,
|
|||
// and not to be introspected or modified (even as a copy)
|
|||
var SeaweedFiler_ServiceDesc = grpc.ServiceDesc{ |
|||
ServiceName: "filer_pb.SeaweedFiler", |
|||
HandlerType: (*SeaweedFilerServer)(nil), |
|||
Methods: []grpc.MethodDesc{ |
|||
{ |
|||
MethodName: "LookupDirectoryEntry", |
|||
Handler: _SeaweedFiler_LookupDirectoryEntry_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "CreateEntry", |
|||
Handler: _SeaweedFiler_CreateEntry_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "UpdateEntry", |
|||
Handler: _SeaweedFiler_UpdateEntry_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "AppendToEntry", |
|||
Handler: _SeaweedFiler_AppendToEntry_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "DeleteEntry", |
|||
Handler: _SeaweedFiler_DeleteEntry_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "AtomicRenameEntry", |
|||
Handler: _SeaweedFiler_AtomicRenameEntry_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "AssignVolume", |
|||
Handler: _SeaweedFiler_AssignVolume_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "LookupVolume", |
|||
Handler: _SeaweedFiler_LookupVolume_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "CollectionList", |
|||
Handler: _SeaweedFiler_CollectionList_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "DeleteCollection", |
|||
Handler: _SeaweedFiler_DeleteCollection_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "Statistics", |
|||
Handler: _SeaweedFiler_Statistics_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "GetFilerConfiguration", |
|||
Handler: _SeaweedFiler_GetFilerConfiguration_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "LocateBroker", |
|||
Handler: _SeaweedFiler_LocateBroker_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "KvGet", |
|||
Handler: _SeaweedFiler_KvGet_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "KvPut", |
|||
Handler: _SeaweedFiler_KvPut_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "CacheRemoteObjectToLocalCluster", |
|||
Handler: _SeaweedFiler_CacheRemoteObjectToLocalCluster_Handler, |
|||
}, |
|||
}, |
|||
Streams: []grpc.StreamDesc{ |
|||
{ |
|||
StreamName: "ListEntries", |
|||
Handler: _SeaweedFiler_ListEntries_Handler, |
|||
ServerStreams: true, |
|||
}, |
|||
{ |
|||
StreamName: "StreamRenameEntry", |
|||
Handler: _SeaweedFiler_StreamRenameEntry_Handler, |
|||
ServerStreams: true, |
|||
}, |
|||
{ |
|||
StreamName: "SubscribeMetadata", |
|||
Handler: _SeaweedFiler_SubscribeMetadata_Handler, |
|||
ServerStreams: true, |
|||
}, |
|||
{ |
|||
StreamName: "SubscribeLocalMetadata", |
|||
Handler: _SeaweedFiler_SubscribeLocalMetadata_Handler, |
|||
ServerStreams: true, |
|||
}, |
|||
{ |
|||
StreamName: "KeepConnected", |
|||
Handler: _SeaweedFiler_KeepConnected_Handler, |
|||
ServerStreams: true, |
|||
ClientStreams: true, |
|||
}, |
|||
}, |
|||
Metadata: "filer.proto", |
|||
} |
|||
@ -0,0 +1,62 @@ |
|||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
|||
|
|||
package iam_pb |
|||
|
|||
import ( |
|||
grpc "google.golang.org/grpc" |
|||
) |
|||
|
|||
// 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.32.0 or later.
|
|||
const _ = grpc.SupportPackageIsVersion7 |
|||
|
|||
// SeaweedIdentityAccessManagementClient is the client API for SeaweedIdentityAccessManagement 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 SeaweedIdentityAccessManagementClient interface { |
|||
} |
|||
|
|||
type seaweedIdentityAccessManagementClient struct { |
|||
cc grpc.ClientConnInterface |
|||
} |
|||
|
|||
func NewSeaweedIdentityAccessManagementClient(cc grpc.ClientConnInterface) SeaweedIdentityAccessManagementClient { |
|||
return &seaweedIdentityAccessManagementClient{cc} |
|||
} |
|||
|
|||
// SeaweedIdentityAccessManagementServer is the server API for SeaweedIdentityAccessManagement service.
|
|||
// All implementations must embed UnimplementedSeaweedIdentityAccessManagementServer
|
|||
// for forward compatibility
|
|||
type SeaweedIdentityAccessManagementServer interface { |
|||
mustEmbedUnimplementedSeaweedIdentityAccessManagementServer() |
|||
} |
|||
|
|||
// UnimplementedSeaweedIdentityAccessManagementServer must be embedded to have forward compatible implementations.
|
|||
type UnimplementedSeaweedIdentityAccessManagementServer struct { |
|||
} |
|||
|
|||
func (UnimplementedSeaweedIdentityAccessManagementServer) mustEmbedUnimplementedSeaweedIdentityAccessManagementServer() { |
|||
} |
|||
|
|||
// UnsafeSeaweedIdentityAccessManagementServer may be embedded to opt out of forward compatibility for this service.
|
|||
// Use of this interface is not recommended, as added methods to SeaweedIdentityAccessManagementServer will
|
|||
// result in compilation errors.
|
|||
type UnsafeSeaweedIdentityAccessManagementServer interface { |
|||
mustEmbedUnimplementedSeaweedIdentityAccessManagementServer() |
|||
} |
|||
|
|||
func RegisterSeaweedIdentityAccessManagementServer(s grpc.ServiceRegistrar, srv SeaweedIdentityAccessManagementServer) { |
|||
s.RegisterService(&SeaweedIdentityAccessManagement_ServiceDesc, srv) |
|||
} |
|||
|
|||
// SeaweedIdentityAccessManagement_ServiceDesc is the grpc.ServiceDesc for SeaweedIdentityAccessManagement service.
|
|||
// It's only intended for direct use with grpc.RegisterService,
|
|||
// and not to be introspected or modified (even as a copy)
|
|||
var SeaweedIdentityAccessManagement_ServiceDesc = grpc.ServiceDesc{ |
|||
ServiceName: "iam_pb.SeaweedIdentityAccessManagement", |
|||
HandlerType: (*SeaweedIdentityAccessManagementServer)(nil), |
|||
Methods: []grpc.MethodDesc{}, |
|||
Streams: []grpc.StreamDesc{}, |
|||
Metadata: "iam.proto", |
|||
} |
|||
@ -0,0 +1,634 @@ |
|||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
|||
|
|||
package master_pb |
|||
|
|||
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.32.0 or later.
|
|||
const _ = grpc.SupportPackageIsVersion7 |
|||
|
|||
// SeaweedClient is the client API for Seaweed 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 SeaweedClient interface { |
|||
SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, error) |
|||
KeepConnected(ctx context.Context, opts ...grpc.CallOption) (Seaweed_KeepConnectedClient, error) |
|||
LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error) |
|||
Assign(ctx context.Context, in *AssignRequest, opts ...grpc.CallOption) (*AssignResponse, error) |
|||
Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error) |
|||
CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error) |
|||
CollectionDelete(ctx context.Context, in *CollectionDeleteRequest, opts ...grpc.CallOption) (*CollectionDeleteResponse, error) |
|||
VolumeList(ctx context.Context, in *VolumeListRequest, opts ...grpc.CallOption) (*VolumeListResponse, error) |
|||
LookupEcVolume(ctx context.Context, in *LookupEcVolumeRequest, opts ...grpc.CallOption) (*LookupEcVolumeResponse, error) |
|||
VacuumVolume(ctx context.Context, in *VacuumVolumeRequest, opts ...grpc.CallOption) (*VacuumVolumeResponse, error) |
|||
GetMasterConfiguration(ctx context.Context, in *GetMasterConfigurationRequest, opts ...grpc.CallOption) (*GetMasterConfigurationResponse, error) |
|||
ListClusterNodes(ctx context.Context, in *ListClusterNodesRequest, opts ...grpc.CallOption) (*ListClusterNodesResponse, error) |
|||
LeaseAdminToken(ctx context.Context, in *LeaseAdminTokenRequest, opts ...grpc.CallOption) (*LeaseAdminTokenResponse, error) |
|||
ReleaseAdminToken(ctx context.Context, in *ReleaseAdminTokenRequest, opts ...grpc.CallOption) (*ReleaseAdminTokenResponse, error) |
|||
} |
|||
|
|||
type seaweedClient struct { |
|||
cc grpc.ClientConnInterface |
|||
} |
|||
|
|||
func NewSeaweedClient(cc grpc.ClientConnInterface) SeaweedClient { |
|||
return &seaweedClient{cc} |
|||
} |
|||
|
|||
func (c *seaweedClient) SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, error) { |
|||
stream, err := c.cc.NewStream(ctx, &Seaweed_ServiceDesc.Streams[0], "/master_pb.Seaweed/SendHeartbeat", opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
x := &seaweedSendHeartbeatClient{stream} |
|||
return x, nil |
|||
} |
|||
|
|||
type Seaweed_SendHeartbeatClient interface { |
|||
Send(*Heartbeat) error |
|||
Recv() (*HeartbeatResponse, error) |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
type seaweedSendHeartbeatClient struct { |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
func (x *seaweedSendHeartbeatClient) Send(m *Heartbeat) error { |
|||
return x.ClientStream.SendMsg(m) |
|||
} |
|||
|
|||
func (x *seaweedSendHeartbeatClient) Recv() (*HeartbeatResponse, error) { |
|||
m := new(HeartbeatResponse) |
|||
if err := x.ClientStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) KeepConnected(ctx context.Context, opts ...grpc.CallOption) (Seaweed_KeepConnectedClient, error) { |
|||
stream, err := c.cc.NewStream(ctx, &Seaweed_ServiceDesc.Streams[1], "/master_pb.Seaweed/KeepConnected", opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
x := &seaweedKeepConnectedClient{stream} |
|||
return x, nil |
|||
} |
|||
|
|||
type Seaweed_KeepConnectedClient interface { |
|||
Send(*KeepConnectedRequest) error |
|||
Recv() (*KeepConnectedResponse, error) |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
type seaweedKeepConnectedClient struct { |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
func (x *seaweedKeepConnectedClient) Send(m *KeepConnectedRequest) error { |
|||
return x.ClientStream.SendMsg(m) |
|||
} |
|||
|
|||
func (x *seaweedKeepConnectedClient) Recv() (*KeepConnectedResponse, error) { |
|||
m := new(KeepConnectedResponse) |
|||
if err := x.ClientStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error) { |
|||
out := new(LookupVolumeResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/LookupVolume", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) Assign(ctx context.Context, in *AssignRequest, opts ...grpc.CallOption) (*AssignResponse, error) { |
|||
out := new(AssignResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/Assign", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error) { |
|||
out := new(StatisticsResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/Statistics", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error) { |
|||
out := new(CollectionListResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/CollectionList", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) CollectionDelete(ctx context.Context, in *CollectionDeleteRequest, opts ...grpc.CallOption) (*CollectionDeleteResponse, error) { |
|||
out := new(CollectionDeleteResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/CollectionDelete", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) VolumeList(ctx context.Context, in *VolumeListRequest, opts ...grpc.CallOption) (*VolumeListResponse, error) { |
|||
out := new(VolumeListResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/VolumeList", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) LookupEcVolume(ctx context.Context, in *LookupEcVolumeRequest, opts ...grpc.CallOption) (*LookupEcVolumeResponse, error) { |
|||
out := new(LookupEcVolumeResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/LookupEcVolume", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) VacuumVolume(ctx context.Context, in *VacuumVolumeRequest, opts ...grpc.CallOption) (*VacuumVolumeResponse, error) { |
|||
out := new(VacuumVolumeResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/VacuumVolume", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) GetMasterConfiguration(ctx context.Context, in *GetMasterConfigurationRequest, opts ...grpc.CallOption) (*GetMasterConfigurationResponse, error) { |
|||
out := new(GetMasterConfigurationResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/GetMasterConfiguration", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) ListClusterNodes(ctx context.Context, in *ListClusterNodesRequest, opts ...grpc.CallOption) (*ListClusterNodesResponse, error) { |
|||
out := new(ListClusterNodesResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/ListClusterNodes", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) LeaseAdminToken(ctx context.Context, in *LeaseAdminTokenRequest, opts ...grpc.CallOption) (*LeaseAdminTokenResponse, error) { |
|||
out := new(LeaseAdminTokenResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/LeaseAdminToken", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedClient) ReleaseAdminToken(ctx context.Context, in *ReleaseAdminTokenRequest, opts ...grpc.CallOption) (*ReleaseAdminTokenResponse, error) { |
|||
out := new(ReleaseAdminTokenResponse) |
|||
err := c.cc.Invoke(ctx, "/master_pb.Seaweed/ReleaseAdminToken", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
// SeaweedServer is the server API for Seaweed service.
|
|||
// All implementations must embed UnimplementedSeaweedServer
|
|||
// for forward compatibility
|
|||
type SeaweedServer interface { |
|||
SendHeartbeat(Seaweed_SendHeartbeatServer) error |
|||
KeepConnected(Seaweed_KeepConnectedServer) error |
|||
LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error) |
|||
Assign(context.Context, *AssignRequest) (*AssignResponse, error) |
|||
Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error) |
|||
CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error) |
|||
CollectionDelete(context.Context, *CollectionDeleteRequest) (*CollectionDeleteResponse, error) |
|||
VolumeList(context.Context, *VolumeListRequest) (*VolumeListResponse, error) |
|||
LookupEcVolume(context.Context, *LookupEcVolumeRequest) (*LookupEcVolumeResponse, error) |
|||
VacuumVolume(context.Context, *VacuumVolumeRequest) (*VacuumVolumeResponse, error) |
|||
GetMasterConfiguration(context.Context, *GetMasterConfigurationRequest) (*GetMasterConfigurationResponse, error) |
|||
ListClusterNodes(context.Context, *ListClusterNodesRequest) (*ListClusterNodesResponse, error) |
|||
LeaseAdminToken(context.Context, *LeaseAdminTokenRequest) (*LeaseAdminTokenResponse, error) |
|||
ReleaseAdminToken(context.Context, *ReleaseAdminTokenRequest) (*ReleaseAdminTokenResponse, error) |
|||
mustEmbedUnimplementedSeaweedServer() |
|||
} |
|||
|
|||
// UnimplementedSeaweedServer must be embedded to have forward compatible implementations.
|
|||
type UnimplementedSeaweedServer struct { |
|||
} |
|||
|
|||
func (UnimplementedSeaweedServer) SendHeartbeat(Seaweed_SendHeartbeatServer) error { |
|||
return status.Errorf(codes.Unimplemented, "method SendHeartbeat not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) KeepConnected(Seaweed_KeepConnectedServer) error { |
|||
return status.Errorf(codes.Unimplemented, "method KeepConnected not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method LookupVolume not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) Assign(context.Context, *AssignRequest) (*AssignResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method Assign not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method Statistics not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method CollectionList not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) CollectionDelete(context.Context, *CollectionDeleteRequest) (*CollectionDeleteResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method CollectionDelete not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) VolumeList(context.Context, *VolumeListRequest) (*VolumeListResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method VolumeList not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) LookupEcVolume(context.Context, *LookupEcVolumeRequest) (*LookupEcVolumeResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method LookupEcVolume not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) VacuumVolume(context.Context, *VacuumVolumeRequest) (*VacuumVolumeResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method VacuumVolume not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) GetMasterConfiguration(context.Context, *GetMasterConfigurationRequest) (*GetMasterConfigurationResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method GetMasterConfiguration not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) ListClusterNodes(context.Context, *ListClusterNodesRequest) (*ListClusterNodesResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method ListClusterNodes not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) LeaseAdminToken(context.Context, *LeaseAdminTokenRequest) (*LeaseAdminTokenResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method LeaseAdminToken not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) ReleaseAdminToken(context.Context, *ReleaseAdminTokenRequest) (*ReleaseAdminTokenResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method ReleaseAdminToken not implemented") |
|||
} |
|||
func (UnimplementedSeaweedServer) mustEmbedUnimplementedSeaweedServer() {} |
|||
|
|||
// UnsafeSeaweedServer may be embedded to opt out of forward compatibility for this service.
|
|||
// Use of this interface is not recommended, as added methods to SeaweedServer will
|
|||
// result in compilation errors.
|
|||
type UnsafeSeaweedServer interface { |
|||
mustEmbedUnimplementedSeaweedServer() |
|||
} |
|||
|
|||
func RegisterSeaweedServer(s grpc.ServiceRegistrar, srv SeaweedServer) { |
|||
s.RegisterService(&Seaweed_ServiceDesc, srv) |
|||
} |
|||
|
|||
func _Seaweed_SendHeartbeat_Handler(srv interface{}, stream grpc.ServerStream) error { |
|||
return srv.(SeaweedServer).SendHeartbeat(&seaweedSendHeartbeatServer{stream}) |
|||
} |
|||
|
|||
type Seaweed_SendHeartbeatServer interface { |
|||
Send(*HeartbeatResponse) error |
|||
Recv() (*Heartbeat, error) |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
type seaweedSendHeartbeatServer struct { |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
func (x *seaweedSendHeartbeatServer) Send(m *HeartbeatResponse) error { |
|||
return x.ServerStream.SendMsg(m) |
|||
} |
|||
|
|||
func (x *seaweedSendHeartbeatServer) Recv() (*Heartbeat, error) { |
|||
m := new(Heartbeat) |
|||
if err := x.ServerStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func _Seaweed_KeepConnected_Handler(srv interface{}, stream grpc.ServerStream) error { |
|||
return srv.(SeaweedServer).KeepConnected(&seaweedKeepConnectedServer{stream}) |
|||
} |
|||
|
|||
type Seaweed_KeepConnectedServer interface { |
|||
Send(*KeepConnectedResponse) error |
|||
Recv() (*KeepConnectedRequest, error) |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
type seaweedKeepConnectedServer struct { |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
func (x *seaweedKeepConnectedServer) Send(m *KeepConnectedResponse) error { |
|||
return x.ServerStream.SendMsg(m) |
|||
} |
|||
|
|||
func (x *seaweedKeepConnectedServer) Recv() (*KeepConnectedRequest, error) { |
|||
m := new(KeepConnectedRequest) |
|||
if err := x.ServerStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func _Seaweed_LookupVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(LookupVolumeRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).LookupVolume(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/LookupVolume", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).LookupVolume(ctx, req.(*LookupVolumeRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _Seaweed_Assign_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(AssignRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).Assign(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/Assign", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).Assign(ctx, req.(*AssignRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _Seaweed_Statistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(StatisticsRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).Statistics(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/Statistics", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).Statistics(ctx, req.(*StatisticsRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _Seaweed_CollectionList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(CollectionListRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).CollectionList(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/CollectionList", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).CollectionList(ctx, req.(*CollectionListRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _Seaweed_CollectionDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(CollectionDeleteRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).CollectionDelete(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/CollectionDelete", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).CollectionDelete(ctx, req.(*CollectionDeleteRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _Seaweed_VolumeList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(VolumeListRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).VolumeList(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/VolumeList", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).VolumeList(ctx, req.(*VolumeListRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _Seaweed_LookupEcVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(LookupEcVolumeRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).LookupEcVolume(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/LookupEcVolume", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).LookupEcVolume(ctx, req.(*LookupEcVolumeRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _Seaweed_VacuumVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(VacuumVolumeRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).VacuumVolume(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/VacuumVolume", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).VacuumVolume(ctx, req.(*VacuumVolumeRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _Seaweed_GetMasterConfiguration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(GetMasterConfigurationRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).GetMasterConfiguration(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/GetMasterConfiguration", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).GetMasterConfiguration(ctx, req.(*GetMasterConfigurationRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _Seaweed_ListClusterNodes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(ListClusterNodesRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).ListClusterNodes(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/ListClusterNodes", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).ListClusterNodes(ctx, req.(*ListClusterNodesRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _Seaweed_LeaseAdminToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(LeaseAdminTokenRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).LeaseAdminToken(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/LeaseAdminToken", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).LeaseAdminToken(ctx, req.(*LeaseAdminTokenRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _Seaweed_ReleaseAdminToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(ReleaseAdminTokenRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedServer).ReleaseAdminToken(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/master_pb.Seaweed/ReleaseAdminToken", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedServer).ReleaseAdminToken(ctx, req.(*ReleaseAdminTokenRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
// Seaweed_ServiceDesc is the grpc.ServiceDesc for Seaweed service.
|
|||
// It's only intended for direct use with grpc.RegisterService,
|
|||
// and not to be introspected or modified (even as a copy)
|
|||
var Seaweed_ServiceDesc = grpc.ServiceDesc{ |
|||
ServiceName: "master_pb.Seaweed", |
|||
HandlerType: (*SeaweedServer)(nil), |
|||
Methods: []grpc.MethodDesc{ |
|||
{ |
|||
MethodName: "LookupVolume", |
|||
Handler: _Seaweed_LookupVolume_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "Assign", |
|||
Handler: _Seaweed_Assign_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "Statistics", |
|||
Handler: _Seaweed_Statistics_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "CollectionList", |
|||
Handler: _Seaweed_CollectionList_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "CollectionDelete", |
|||
Handler: _Seaweed_CollectionDelete_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "VolumeList", |
|||
Handler: _Seaweed_VolumeList_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "LookupEcVolume", |
|||
Handler: _Seaweed_LookupEcVolume_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "VacuumVolume", |
|||
Handler: _Seaweed_VacuumVolume_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "GetMasterConfiguration", |
|||
Handler: _Seaweed_GetMasterConfiguration_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "ListClusterNodes", |
|||
Handler: _Seaweed_ListClusterNodes_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "LeaseAdminToken", |
|||
Handler: _Seaweed_LeaseAdminToken_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "ReleaseAdminToken", |
|||
Handler: _Seaweed_ReleaseAdminToken_Handler, |
|||
}, |
|||
}, |
|||
Streams: []grpc.StreamDesc{ |
|||
{ |
|||
StreamName: "SendHeartbeat", |
|||
Handler: _Seaweed_SendHeartbeat_Handler, |
|||
ServerStreams: true, |
|||
ClientStreams: true, |
|||
}, |
|||
{ |
|||
StreamName: "KeepConnected", |
|||
Handler: _Seaweed_KeepConnected_Handler, |
|||
ServerStreams: true, |
|||
ClientStreams: true, |
|||
}, |
|||
}, |
|||
Metadata: "master.proto", |
|||
} |
|||
@ -0,0 +1,346 @@ |
|||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
|||
|
|||
package messaging_pb |
|||
|
|||
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.32.0 or later.
|
|||
const _ = grpc.SupportPackageIsVersion7 |
|||
|
|||
// SeaweedMessagingClient is the client API for SeaweedMessaging 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 SeaweedMessagingClient interface { |
|||
Subscribe(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_SubscribeClient, error) |
|||
Publish(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublishClient, error) |
|||
DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*DeleteTopicResponse, error) |
|||
ConfigureTopic(ctx context.Context, in *ConfigureTopicRequest, opts ...grpc.CallOption) (*ConfigureTopicResponse, error) |
|||
GetTopicConfiguration(ctx context.Context, in *GetTopicConfigurationRequest, opts ...grpc.CallOption) (*GetTopicConfigurationResponse, error) |
|||
FindBroker(ctx context.Context, in *FindBrokerRequest, opts ...grpc.CallOption) (*FindBrokerResponse, error) |
|||
} |
|||
|
|||
type seaweedMessagingClient struct { |
|||
cc grpc.ClientConnInterface |
|||
} |
|||
|
|||
func NewSeaweedMessagingClient(cc grpc.ClientConnInterface) SeaweedMessagingClient { |
|||
return &seaweedMessagingClient{cc} |
|||
} |
|||
|
|||
func (c *seaweedMessagingClient) Subscribe(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_SubscribeClient, error) { |
|||
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[0], "/messaging_pb.SeaweedMessaging/Subscribe", opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
x := &seaweedMessagingSubscribeClient{stream} |
|||
return x, nil |
|||
} |
|||
|
|||
type SeaweedMessaging_SubscribeClient interface { |
|||
Send(*SubscriberMessage) error |
|||
Recv() (*BrokerMessage, error) |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
type seaweedMessagingSubscribeClient struct { |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
func (x *seaweedMessagingSubscribeClient) Send(m *SubscriberMessage) error { |
|||
return x.ClientStream.SendMsg(m) |
|||
} |
|||
|
|||
func (x *seaweedMessagingSubscribeClient) Recv() (*BrokerMessage, error) { |
|||
m := new(BrokerMessage) |
|||
if err := x.ClientStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func (c *seaweedMessagingClient) Publish(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublishClient, error) { |
|||
stream, err := c.cc.NewStream(ctx, &SeaweedMessaging_ServiceDesc.Streams[1], "/messaging_pb.SeaweedMessaging/Publish", opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
x := &seaweedMessagingPublishClient{stream} |
|||
return x, nil |
|||
} |
|||
|
|||
type SeaweedMessaging_PublishClient interface { |
|||
Send(*PublishRequest) error |
|||
Recv() (*PublishResponse, error) |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
type seaweedMessagingPublishClient struct { |
|||
grpc.ClientStream |
|||
} |
|||
|
|||
func (x *seaweedMessagingPublishClient) Send(m *PublishRequest) error { |
|||
return x.ClientStream.SendMsg(m) |
|||
} |
|||
|
|||
func (x *seaweedMessagingPublishClient) Recv() (*PublishResponse, error) { |
|||
m := new(PublishResponse) |
|||
if err := x.ClientStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func (c *seaweedMessagingClient) DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*DeleteTopicResponse, error) { |
|||
out := new(DeleteTopicResponse) |
|||
err := c.cc.Invoke(ctx, "/messaging_pb.SeaweedMessaging/DeleteTopic", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedMessagingClient) ConfigureTopic(ctx context.Context, in *ConfigureTopicRequest, opts ...grpc.CallOption) (*ConfigureTopicResponse, error) { |
|||
out := new(ConfigureTopicResponse) |
|||
err := c.cc.Invoke(ctx, "/messaging_pb.SeaweedMessaging/ConfigureTopic", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedMessagingClient) GetTopicConfiguration(ctx context.Context, in *GetTopicConfigurationRequest, opts ...grpc.CallOption) (*GetTopicConfigurationResponse, error) { |
|||
out := new(GetTopicConfigurationResponse) |
|||
err := c.cc.Invoke(ctx, "/messaging_pb.SeaweedMessaging/GetTopicConfiguration", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
func (c *seaweedMessagingClient) FindBroker(ctx context.Context, in *FindBrokerRequest, opts ...grpc.CallOption) (*FindBrokerResponse, error) { |
|||
out := new(FindBrokerResponse) |
|||
err := c.cc.Invoke(ctx, "/messaging_pb.SeaweedMessaging/FindBroker", in, out, opts...) |
|||
if err != nil { |
|||
return nil, err |
|||
} |
|||
return out, nil |
|||
} |
|||
|
|||
// SeaweedMessagingServer is the server API for SeaweedMessaging service.
|
|||
// All implementations must embed UnimplementedSeaweedMessagingServer
|
|||
// for forward compatibility
|
|||
type SeaweedMessagingServer interface { |
|||
Subscribe(SeaweedMessaging_SubscribeServer) error |
|||
Publish(SeaweedMessaging_PublishServer) error |
|||
DeleteTopic(context.Context, *DeleteTopicRequest) (*DeleteTopicResponse, error) |
|||
ConfigureTopic(context.Context, *ConfigureTopicRequest) (*ConfigureTopicResponse, error) |
|||
GetTopicConfiguration(context.Context, *GetTopicConfigurationRequest) (*GetTopicConfigurationResponse, error) |
|||
FindBroker(context.Context, *FindBrokerRequest) (*FindBrokerResponse, error) |
|||
mustEmbedUnimplementedSeaweedMessagingServer() |
|||
} |
|||
|
|||
// UnimplementedSeaweedMessagingServer must be embedded to have forward compatible implementations.
|
|||
type UnimplementedSeaweedMessagingServer struct { |
|||
} |
|||
|
|||
func (UnimplementedSeaweedMessagingServer) Subscribe(SeaweedMessaging_SubscribeServer) error { |
|||
return status.Errorf(codes.Unimplemented, "method Subscribe not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingServer) Publish(SeaweedMessaging_PublishServer) error { |
|||
return status.Errorf(codes.Unimplemented, "method Publish not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingServer) DeleteTopic(context.Context, *DeleteTopicRequest) (*DeleteTopicResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method DeleteTopic not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingServer) ConfigureTopic(context.Context, *ConfigureTopicRequest) (*ConfigureTopicResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method ConfigureTopic not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingServer) GetTopicConfiguration(context.Context, *GetTopicConfigurationRequest) (*GetTopicConfigurationResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method GetTopicConfiguration not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingServer) FindBroker(context.Context, *FindBrokerRequest) (*FindBrokerResponse, error) { |
|||
return nil, status.Errorf(codes.Unimplemented, "method FindBroker not implemented") |
|||
} |
|||
func (UnimplementedSeaweedMessagingServer) mustEmbedUnimplementedSeaweedMessagingServer() {} |
|||
|
|||
// UnsafeSeaweedMessagingServer may be embedded to opt out of forward compatibility for this service.
|
|||
// Use of this interface is not recommended, as added methods to SeaweedMessagingServer will
|
|||
// result in compilation errors.
|
|||
type UnsafeSeaweedMessagingServer interface { |
|||
mustEmbedUnimplementedSeaweedMessagingServer() |
|||
} |
|||
|
|||
func RegisterSeaweedMessagingServer(s grpc.ServiceRegistrar, srv SeaweedMessagingServer) { |
|||
s.RegisterService(&SeaweedMessaging_ServiceDesc, srv) |
|||
} |
|||
|
|||
func _SeaweedMessaging_Subscribe_Handler(srv interface{}, stream grpc.ServerStream) error { |
|||
return srv.(SeaweedMessagingServer).Subscribe(&seaweedMessagingSubscribeServer{stream}) |
|||
} |
|||
|
|||
type SeaweedMessaging_SubscribeServer interface { |
|||
Send(*BrokerMessage) error |
|||
Recv() (*SubscriberMessage, error) |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
type seaweedMessagingSubscribeServer struct { |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
func (x *seaweedMessagingSubscribeServer) Send(m *BrokerMessage) error { |
|||
return x.ServerStream.SendMsg(m) |
|||
} |
|||
|
|||
func (x *seaweedMessagingSubscribeServer) Recv() (*SubscriberMessage, error) { |
|||
m := new(SubscriberMessage) |
|||
if err := x.ServerStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func _SeaweedMessaging_Publish_Handler(srv interface{}, stream grpc.ServerStream) error { |
|||
return srv.(SeaweedMessagingServer).Publish(&seaweedMessagingPublishServer{stream}) |
|||
} |
|||
|
|||
type SeaweedMessaging_PublishServer interface { |
|||
Send(*PublishResponse) error |
|||
Recv() (*PublishRequest, error) |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
type seaweedMessagingPublishServer struct { |
|||
grpc.ServerStream |
|||
} |
|||
|
|||
func (x *seaweedMessagingPublishServer) Send(m *PublishResponse) error { |
|||
return x.ServerStream.SendMsg(m) |
|||
} |
|||
|
|||
func (x *seaweedMessagingPublishServer) Recv() (*PublishRequest, error) { |
|||
m := new(PublishRequest) |
|||
if err := x.ServerStream.RecvMsg(m); err != nil { |
|||
return nil, err |
|||
} |
|||
return m, nil |
|||
} |
|||
|
|||
func _SeaweedMessaging_DeleteTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(DeleteTopicRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedMessagingServer).DeleteTopic(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/messaging_pb.SeaweedMessaging/DeleteTopic", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedMessagingServer).DeleteTopic(ctx, req.(*DeleteTopicRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedMessaging_ConfigureTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(ConfigureTopicRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedMessagingServer).ConfigureTopic(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/messaging_pb.SeaweedMessaging/ConfigureTopic", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedMessagingServer).ConfigureTopic(ctx, req.(*ConfigureTopicRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedMessaging_GetTopicConfiguration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(GetTopicConfigurationRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedMessagingServer).GetTopicConfiguration(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/messaging_pb.SeaweedMessaging/GetTopicConfiguration", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedMessagingServer).GetTopicConfiguration(ctx, req.(*GetTopicConfigurationRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
func _SeaweedMessaging_FindBroker_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
|||
in := new(FindBrokerRequest) |
|||
if err := dec(in); err != nil { |
|||
return nil, err |
|||
} |
|||
if interceptor == nil { |
|||
return srv.(SeaweedMessagingServer).FindBroker(ctx, in) |
|||
} |
|||
info := &grpc.UnaryServerInfo{ |
|||
Server: srv, |
|||
FullMethod: "/messaging_pb.SeaweedMessaging/FindBroker", |
|||
} |
|||
handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
|||
return srv.(SeaweedMessagingServer).FindBroker(ctx, req.(*FindBrokerRequest)) |
|||
} |
|||
return interceptor(ctx, in, info, handler) |
|||
} |
|||
|
|||
// SeaweedMessaging_ServiceDesc is the grpc.ServiceDesc for SeaweedMessaging service.
|
|||
// It's only intended for direct use with grpc.RegisterService,
|
|||
// and not to be introspected or modified (even as a copy)
|
|||
var SeaweedMessaging_ServiceDesc = grpc.ServiceDesc{ |
|||
ServiceName: "messaging_pb.SeaweedMessaging", |
|||
HandlerType: (*SeaweedMessagingServer)(nil), |
|||
Methods: []grpc.MethodDesc{ |
|||
{ |
|||
MethodName: "DeleteTopic", |
|||
Handler: _SeaweedMessaging_DeleteTopic_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "ConfigureTopic", |
|||
Handler: _SeaweedMessaging_ConfigureTopic_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "GetTopicConfiguration", |
|||
Handler: _SeaweedMessaging_GetTopicConfiguration_Handler, |
|||
}, |
|||
{ |
|||
MethodName: "FindBroker", |
|||
Handler: _SeaweedMessaging_FindBroker_Handler, |
|||
}, |
|||
}, |
|||
Streams: []grpc.StreamDesc{ |
|||
{ |
|||
StreamName: "Subscribe", |
|||
Handler: _SeaweedMessaging_Subscribe_Handler, |
|||
ServerStreams: true, |
|||
ClientStreams: true, |
|||
}, |
|||
{ |
|||
StreamName: "Publish", |
|||
Handler: _SeaweedMessaging_Publish_Handler, |
|||
ServerStreams: true, |
|||
ClientStreams: true, |
|||
}, |
|||
}, |
|||
Metadata: "messaging.proto", |
|||
} |
|||
1780
weed/pb/volume_server_pb/volume_server.pb.go
File diff suppressed because it is too large
View File
File diff suppressed because it is too large
View File
1788
weed/pb/volume_server_pb/volume_server_grpc.pb.go
File diff suppressed because it is too large
View File
File diff suppressed because it is too large
View File
Write
Preview
Loading…
Cancel
Save
Reference in new issue