diff --git a/pb/destination/v0/destination_grpc.pb.go b/pb/destination/v0/destination_grpc.pb.go
index 59231e1..e631bc1 100644
--- a/pb/destination/v0/destination_grpc.pb.go
+++ b/pb/destination/v0/destination_grpc.pb.go
@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.3.0
+// - protoc-gen-go-grpc v1.4.0
 // - protoc             v4.23.4
 // source: plugin-pb/destination/v0/destination.proto
 
@@ -16,8 +16,8 @@ import (
 
 // 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
+// Requires gRPC-Go v1.62.0 or later.
+const _ = grpc.SupportPackageIsVersion8
 
 const (
 	Destination_GetProtocolVersion_FullMethodName = "/proto.Destination/GetProtocolVersion"
@@ -70,8 +70,9 @@ func NewDestinationClient(cc grpc.ClientConnInterface) DestinationClient {
 }
 
 func (c *destinationClient) GetProtocolVersion(ctx context.Context, in *v0.GetProtocolVersion_Request, opts ...grpc.CallOption) (*v0.GetProtocolVersion_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(v0.GetProtocolVersion_Response)
-	err := c.cc.Invoke(ctx, Destination_GetProtocolVersion_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_GetProtocolVersion_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -79,8 +80,9 @@ func (c *destinationClient) GetProtocolVersion(ctx context.Context, in *v0.GetPr
 }
 
 func (c *destinationClient) GetName(ctx context.Context, in *v0.GetName_Request, opts ...grpc.CallOption) (*v0.GetName_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(v0.GetName_Response)
-	err := c.cc.Invoke(ctx, Destination_GetName_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_GetName_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -88,8 +90,9 @@ func (c *destinationClient) GetName(ctx context.Context, in *v0.GetName_Request,
 }
 
 func (c *destinationClient) GetVersion(ctx context.Context, in *v0.GetVersion_Request, opts ...grpc.CallOption) (*v0.GetVersion_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(v0.GetVersion_Response)
-	err := c.cc.Invoke(ctx, Destination_GetVersion_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_GetVersion_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -97,8 +100,9 @@ func (c *destinationClient) GetVersion(ctx context.Context, in *v0.GetVersion_Re
 }
 
 func (c *destinationClient) Configure(ctx context.Context, in *v0.Configure_Request, opts ...grpc.CallOption) (*v0.Configure_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(v0.Configure_Response)
-	err := c.cc.Invoke(ctx, Destination_Configure_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_Configure_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -106,8 +110,9 @@ func (c *destinationClient) Configure(ctx context.Context, in *v0.Configure_Requ
 }
 
 func (c *destinationClient) Migrate(ctx context.Context, in *Migrate_Request, opts ...grpc.CallOption) (*Migrate_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(Migrate_Response)
-	err := c.cc.Invoke(ctx, Destination_Migrate_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_Migrate_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -115,11 +120,12 @@ func (c *destinationClient) Migrate(ctx context.Context, in *Migrate_Request, op
 }
 
 func (c *destinationClient) Write(ctx context.Context, opts ...grpc.CallOption) (Destination_WriteClient, error) {
-	stream, err := c.cc.NewStream(ctx, &Destination_ServiceDesc.Streams[0], Destination_Write_FullMethodName, opts...)
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	stream, err := c.cc.NewStream(ctx, &Destination_ServiceDesc.Streams[0], Destination_Write_FullMethodName, cOpts...)
 	if err != nil {
 		return nil, err
 	}
-	x := &destinationWriteClient{stream}
+	x := &destinationWriteClient{ClientStream: stream}
 	return x, nil
 }
 
@@ -149,11 +155,12 @@ func (x *destinationWriteClient) CloseAndRecv() (*Write_Response, error) {
 }
 
 func (c *destinationClient) Write2(ctx context.Context, opts ...grpc.CallOption) (Destination_Write2Client, error) {
-	stream, err := c.cc.NewStream(ctx, &Destination_ServiceDesc.Streams[1], Destination_Write2_FullMethodName, opts...)
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	stream, err := c.cc.NewStream(ctx, &Destination_ServiceDesc.Streams[1], Destination_Write2_FullMethodName, cOpts...)
 	if err != nil {
 		return nil, err
 	}
-	x := &destinationWrite2Client{stream}
+	x := &destinationWrite2Client{ClientStream: stream}
 	return x, nil
 }
 
@@ -183,8 +190,9 @@ func (x *destinationWrite2Client) CloseAndRecv() (*Write2_Response, error) {
 }
 
 func (c *destinationClient) Close(ctx context.Context, in *Close_Request, opts ...grpc.CallOption) (*Close_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(Close_Response)
-	err := c.cc.Invoke(ctx, Destination_Close_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_Close_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -192,8 +200,9 @@ func (c *destinationClient) Close(ctx context.Context, in *Close_Request, opts .
 }
 
 func (c *destinationClient) DeleteStale(ctx context.Context, in *DeleteStale_Request, opts ...grpc.CallOption) (*DeleteStale_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(DeleteStale_Response)
-	err := c.cc.Invoke(ctx, Destination_DeleteStale_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_DeleteStale_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -201,8 +210,9 @@ func (c *destinationClient) DeleteStale(ctx context.Context, in *DeleteStale_Req
 }
 
 func (c *destinationClient) GetMetrics(ctx context.Context, in *GetDestinationMetrics_Request, opts ...grpc.CallOption) (*GetDestinationMetrics_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetDestinationMetrics_Response)
-	err := c.cc.Invoke(ctx, Destination_GetMetrics_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_GetMetrics_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -377,7 +387,7 @@ func _Destination_Migrate_Handler(srv interface{}, ctx context.Context, dec func
 }
 
 func _Destination_Write_Handler(srv interface{}, stream grpc.ServerStream) error {
-	return srv.(DestinationServer).Write(&destinationWriteServer{stream})
+	return srv.(DestinationServer).Write(&destinationWriteServer{ServerStream: stream})
 }
 
 type Destination_WriteServer interface {
@@ -403,7 +413,7 @@ func (x *destinationWriteServer) Recv() (*Write_Request, error) {
 }
 
 func _Destination_Write2_Handler(srv interface{}, stream grpc.ServerStream) error {
-	return srv.(DestinationServer).Write2(&destinationWrite2Server{stream})
+	return srv.(DestinationServer).Write2(&destinationWrite2Server{ServerStream: stream})
 }
 
 type Destination_Write2Server interface {
diff --git a/pb/destination/v1/destination_grpc.pb.go b/pb/destination/v1/destination_grpc.pb.go
index 5b5751a..ea63a16 100644
--- a/pb/destination/v1/destination_grpc.pb.go
+++ b/pb/destination/v1/destination_grpc.pb.go
@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.3.0
+// - protoc-gen-go-grpc v1.4.0
 // - protoc             v4.23.4
 // source: plugin-pb/destination/v1/destination.proto
 
@@ -15,8 +15,8 @@ import (
 
 // 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
+// Requires gRPC-Go v1.62.0 or later.
+const _ = grpc.SupportPackageIsVersion8
 
 const (
 	Destination_GetName_FullMethodName     = "/cloudquery.destination.v1.Destination/GetName"
@@ -61,8 +61,9 @@ func NewDestinationClient(cc grpc.ClientConnInterface) DestinationClient {
 }
 
 func (c *destinationClient) GetName(ctx context.Context, in *GetName_Request, opts ...grpc.CallOption) (*GetName_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetName_Response)
-	err := c.cc.Invoke(ctx, Destination_GetName_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_GetName_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -70,8 +71,9 @@ func (c *destinationClient) GetName(ctx context.Context, in *GetName_Request, op
 }
 
 func (c *destinationClient) GetVersion(ctx context.Context, in *GetVersion_Request, opts ...grpc.CallOption) (*GetVersion_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetVersion_Response)
-	err := c.cc.Invoke(ctx, Destination_GetVersion_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_GetVersion_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -79,8 +81,9 @@ func (c *destinationClient) GetVersion(ctx context.Context, in *GetVersion_Reque
 }
 
 func (c *destinationClient) Configure(ctx context.Context, in *Configure_Request, opts ...grpc.CallOption) (*Configure_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(Configure_Response)
-	err := c.cc.Invoke(ctx, Destination_Configure_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_Configure_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -88,8 +91,9 @@ func (c *destinationClient) Configure(ctx context.Context, in *Configure_Request
 }
 
 func (c *destinationClient) Migrate(ctx context.Context, in *Migrate_Request, opts ...grpc.CallOption) (*Migrate_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(Migrate_Response)
-	err := c.cc.Invoke(ctx, Destination_Migrate_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_Migrate_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -97,11 +101,12 @@ func (c *destinationClient) Migrate(ctx context.Context, in *Migrate_Request, op
 }
 
 func (c *destinationClient) Write(ctx context.Context, opts ...grpc.CallOption) (Destination_WriteClient, error) {
-	stream, err := c.cc.NewStream(ctx, &Destination_ServiceDesc.Streams[0], Destination_Write_FullMethodName, opts...)
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	stream, err := c.cc.NewStream(ctx, &Destination_ServiceDesc.Streams[0], Destination_Write_FullMethodName, cOpts...)
 	if err != nil {
 		return nil, err
 	}
-	x := &destinationWriteClient{stream}
+	x := &destinationWriteClient{ClientStream: stream}
 	return x, nil
 }
 
@@ -131,8 +136,9 @@ func (x *destinationWriteClient) CloseAndRecv() (*Write_Response, error) {
 }
 
 func (c *destinationClient) Close(ctx context.Context, in *Close_Request, opts ...grpc.CallOption) (*Close_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(Close_Response)
-	err := c.cc.Invoke(ctx, Destination_Close_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_Close_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -140,8 +146,9 @@ func (c *destinationClient) Close(ctx context.Context, in *Close_Request, opts .
 }
 
 func (c *destinationClient) DeleteStale(ctx context.Context, in *DeleteStale_Request, opts ...grpc.CallOption) (*DeleteStale_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(DeleteStale_Response)
-	err := c.cc.Invoke(ctx, Destination_DeleteStale_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_DeleteStale_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -149,8 +156,9 @@ func (c *destinationClient) DeleteStale(ctx context.Context, in *DeleteStale_Req
 }
 
 func (c *destinationClient) GetMetrics(ctx context.Context, in *GetDestinationMetrics_Request, opts ...grpc.CallOption) (*GetDestinationMetrics_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetDestinationMetrics_Response)
-	err := c.cc.Invoke(ctx, Destination_GetMetrics_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Destination_GetMetrics_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -295,7 +303,7 @@ func _Destination_Migrate_Handler(srv interface{}, ctx context.Context, dec func
 }
 
 func _Destination_Write_Handler(srv interface{}, stream grpc.ServerStream) error {
-	return srv.(DestinationServer).Write(&destinationWriteServer{stream})
+	return srv.(DestinationServer).Write(&destinationWriteServer{ServerStream: stream})
 }
 
 type Destination_WriteServer interface {
diff --git a/pb/discovery/v0/discovery_grpc.pb.go b/pb/discovery/v0/discovery_grpc.pb.go
index bd68d64..b1c0c75 100644
--- a/pb/discovery/v0/discovery_grpc.pb.go
+++ b/pb/discovery/v0/discovery_grpc.pb.go
@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.3.0
+// - protoc-gen-go-grpc v1.4.0
 // - protoc             v4.23.4
 // source: plugin-pb/discovery/v0/discovery.proto
 
@@ -15,8 +15,8 @@ import (
 
 // 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
+// Requires gRPC-Go v1.62.0 or later.
+const _ = grpc.SupportPackageIsVersion8
 
 const (
 	Discovery_GetVersions_FullMethodName = "/cloudquery.discovery.v0.Discovery/GetVersions"
@@ -39,8 +39,9 @@ func NewDiscoveryClient(cc grpc.ClientConnInterface) DiscoveryClient {
 }
 
 func (c *discoveryClient) GetVersions(ctx context.Context, in *GetVersions_Request, opts ...grpc.CallOption) (*GetVersions_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetVersions_Response)
-	err := c.cc.Invoke(ctx, Discovery_GetVersions_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Discovery_GetVersions_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
diff --git a/pb/discovery/v1/discovery_grpc.pb.go b/pb/discovery/v1/discovery_grpc.pb.go
index 9fbe772..a75e632 100644
--- a/pb/discovery/v1/discovery_grpc.pb.go
+++ b/pb/discovery/v1/discovery_grpc.pb.go
@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.3.0
+// - protoc-gen-go-grpc v1.4.0
 // - protoc             v4.23.4
 // source: plugin-pb/discovery/v1/discovery.proto
 
@@ -15,8 +15,8 @@ import (
 
 // 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
+// Requires gRPC-Go v1.62.0 or later.
+const _ = grpc.SupportPackageIsVersion8
 
 const (
 	Discovery_GetVersions_FullMethodName = "/cloudquery.discovery.v1.Discovery/GetVersions"
@@ -39,8 +39,9 @@ func NewDiscoveryClient(cc grpc.ClientConnInterface) DiscoveryClient {
 }
 
 func (c *discoveryClient) GetVersions(ctx context.Context, in *GetVersions_Request, opts ...grpc.CallOption) (*GetVersions_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetVersions_Response)
-	err := c.cc.Invoke(ctx, Discovery_GetVersions_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Discovery_GetVersions_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
diff --git a/pb/plugin/v3/plugin_grpc.pb.go b/pb/plugin/v3/plugin_grpc.pb.go
index 77b1ac0..ec26347 100644
--- a/pb/plugin/v3/plugin_grpc.pb.go
+++ b/pb/plugin/v3/plugin_grpc.pb.go
@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.3.0
+// - protoc-gen-go-grpc v1.4.0
 // - protoc             v4.23.4
 // source: plugin-pb/plugin/v3/plugin.proto
 
@@ -15,8 +15,8 @@ import (
 
 // 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
+// Requires gRPC-Go v1.62.0 or later.
+const _ = grpc.SupportPackageIsVersion8
 
 const (
 	Plugin_GetName_FullMethodName        = "/cloudquery.plugin.v3.Plugin/GetName"
@@ -69,8 +69,9 @@ func NewPluginClient(cc grpc.ClientConnInterface) PluginClient {
 }
 
 func (c *pluginClient) GetName(ctx context.Context, in *GetName_Request, opts ...grpc.CallOption) (*GetName_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetName_Response)
-	err := c.cc.Invoke(ctx, Plugin_GetName_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Plugin_GetName_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -78,8 +79,9 @@ func (c *pluginClient) GetName(ctx context.Context, in *GetName_Request, opts ..
 }
 
 func (c *pluginClient) GetVersion(ctx context.Context, in *GetVersion_Request, opts ...grpc.CallOption) (*GetVersion_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetVersion_Response)
-	err := c.cc.Invoke(ctx, Plugin_GetVersion_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Plugin_GetVersion_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -87,8 +89,9 @@ func (c *pluginClient) GetVersion(ctx context.Context, in *GetVersion_Request, o
 }
 
 func (c *pluginClient) GetSpecSchema(ctx context.Context, in *GetSpecSchema_Request, opts ...grpc.CallOption) (*GetSpecSchema_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetSpecSchema_Response)
-	err := c.cc.Invoke(ctx, Plugin_GetSpecSchema_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Plugin_GetSpecSchema_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -96,8 +99,9 @@ func (c *pluginClient) GetSpecSchema(ctx context.Context, in *GetSpecSchema_Requ
 }
 
 func (c *pluginClient) Init(ctx context.Context, in *Init_Request, opts ...grpc.CallOption) (*Init_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(Init_Response)
-	err := c.cc.Invoke(ctx, Plugin_Init_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Plugin_Init_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -105,8 +109,9 @@ func (c *pluginClient) Init(ctx context.Context, in *Init_Request, opts ...grpc.
 }
 
 func (c *pluginClient) GetTables(ctx context.Context, in *GetTables_Request, opts ...grpc.CallOption) (*GetTables_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetTables_Response)
-	err := c.cc.Invoke(ctx, Plugin_GetTables_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Plugin_GetTables_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -114,11 +119,12 @@ func (c *pluginClient) GetTables(ctx context.Context, in *GetTables_Request, opt
 }
 
 func (c *pluginClient) Sync(ctx context.Context, in *Sync_Request, opts ...grpc.CallOption) (Plugin_SyncClient, error) {
-	stream, err := c.cc.NewStream(ctx, &Plugin_ServiceDesc.Streams[0], Plugin_Sync_FullMethodName, opts...)
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	stream, err := c.cc.NewStream(ctx, &Plugin_ServiceDesc.Streams[0], Plugin_Sync_FullMethodName, cOpts...)
 	if err != nil {
 		return nil, err
 	}
-	x := &pluginSyncClient{stream}
+	x := &pluginSyncClient{ClientStream: stream}
 	if err := x.ClientStream.SendMsg(in); err != nil {
 		return nil, err
 	}
@@ -146,11 +152,12 @@ func (x *pluginSyncClient) Recv() (*Sync_Response, error) {
 }
 
 func (c *pluginClient) Read(ctx context.Context, in *Read_Request, opts ...grpc.CallOption) (Plugin_ReadClient, error) {
-	stream, err := c.cc.NewStream(ctx, &Plugin_ServiceDesc.Streams[1], Plugin_Read_FullMethodName, opts...)
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	stream, err := c.cc.NewStream(ctx, &Plugin_ServiceDesc.Streams[1], Plugin_Read_FullMethodName, cOpts...)
 	if err != nil {
 		return nil, err
 	}
-	x := &pluginReadClient{stream}
+	x := &pluginReadClient{ClientStream: stream}
 	if err := x.ClientStream.SendMsg(in); err != nil {
 		return nil, err
 	}
@@ -178,11 +185,12 @@ func (x *pluginReadClient) Recv() (*Read_Response, error) {
 }
 
 func (c *pluginClient) Write(ctx context.Context, opts ...grpc.CallOption) (Plugin_WriteClient, error) {
-	stream, err := c.cc.NewStream(ctx, &Plugin_ServiceDesc.Streams[2], Plugin_Write_FullMethodName, opts...)
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	stream, err := c.cc.NewStream(ctx, &Plugin_ServiceDesc.Streams[2], Plugin_Write_FullMethodName, cOpts...)
 	if err != nil {
 		return nil, err
 	}
-	x := &pluginWriteClient{stream}
+	x := &pluginWriteClient{ClientStream: stream}
 	return x, nil
 }
 
@@ -212,8 +220,9 @@ func (x *pluginWriteClient) CloseAndRecv() (*Write_Response, error) {
 }
 
 func (c *pluginClient) Close(ctx context.Context, in *Close_Request, opts ...grpc.CallOption) (*Close_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(Close_Response)
-	err := c.cc.Invoke(ctx, Plugin_Close_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Plugin_Close_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -221,8 +230,9 @@ func (c *pluginClient) Close(ctx context.Context, in *Close_Request, opts ...grp
 }
 
 func (c *pluginClient) TestConnection(ctx context.Context, in *TestConnection_Request, opts ...grpc.CallOption) (*TestConnection_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(TestConnection_Response)
-	err := c.cc.Invoke(ctx, Plugin_TestConnection_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Plugin_TestConnection_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -401,7 +411,7 @@ func _Plugin_Sync_Handler(srv interface{}, stream grpc.ServerStream) error {
 	if err := stream.RecvMsg(m); err != nil {
 		return err
 	}
-	return srv.(PluginServer).Sync(m, &pluginSyncServer{stream})
+	return srv.(PluginServer).Sync(m, &pluginSyncServer{ServerStream: stream})
 }
 
 type Plugin_SyncServer interface {
@@ -422,7 +432,7 @@ func _Plugin_Read_Handler(srv interface{}, stream grpc.ServerStream) error {
 	if err := stream.RecvMsg(m); err != nil {
 		return err
 	}
-	return srv.(PluginServer).Read(m, &pluginReadServer{stream})
+	return srv.(PluginServer).Read(m, &pluginReadServer{ServerStream: stream})
 }
 
 type Plugin_ReadServer interface {
@@ -439,7 +449,7 @@ func (x *pluginReadServer) Send(m *Read_Response) error {
 }
 
 func _Plugin_Write_Handler(srv interface{}, stream grpc.ServerStream) error {
-	return srv.(PluginServer).Write(&pluginWriteServer{stream})
+	return srv.(PluginServer).Write(&pluginWriteServer{ServerStream: stream})
 }
 
 type Plugin_WriteServer interface {
diff --git a/pb/source/v0/source_grpc.pb.go b/pb/source/v0/source_grpc.pb.go
index ec7386b..504fcd6 100644
--- a/pb/source/v0/source_grpc.pb.go
+++ b/pb/source/v0/source_grpc.pb.go
@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.3.0
+// - protoc-gen-go-grpc v1.4.0
 // - protoc             v4.23.4
 // source: plugin-pb/source/v0/source.proto
 
@@ -16,8 +16,8 @@ import (
 
 // 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
+// Requires gRPC-Go v1.62.0 or later.
+const _ = grpc.SupportPackageIsVersion8
 
 const (
 	Source_GetProtocolVersion_FullMethodName = "/proto.Source/GetProtocolVersion"
@@ -69,8 +69,9 @@ func NewSourceClient(cc grpc.ClientConnInterface) SourceClient {
 }
 
 func (c *sourceClient) GetProtocolVersion(ctx context.Context, in *v0.GetProtocolVersion_Request, opts ...grpc.CallOption) (*v0.GetProtocolVersion_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(v0.GetProtocolVersion_Response)
-	err := c.cc.Invoke(ctx, Source_GetProtocolVersion_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetProtocolVersion_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -78,8 +79,9 @@ func (c *sourceClient) GetProtocolVersion(ctx context.Context, in *v0.GetProtoco
 }
 
 func (c *sourceClient) GetName(ctx context.Context, in *v0.GetName_Request, opts ...grpc.CallOption) (*v0.GetName_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(v0.GetName_Response)
-	err := c.cc.Invoke(ctx, Source_GetName_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetName_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -87,8 +89,9 @@ func (c *sourceClient) GetName(ctx context.Context, in *v0.GetName_Request, opts
 }
 
 func (c *sourceClient) GetVersion(ctx context.Context, in *v0.GetVersion_Request, opts ...grpc.CallOption) (*v0.GetVersion_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(v0.GetVersion_Response)
-	err := c.cc.Invoke(ctx, Source_GetVersion_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetVersion_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -96,8 +99,9 @@ func (c *sourceClient) GetVersion(ctx context.Context, in *v0.GetVersion_Request
 }
 
 func (c *sourceClient) GetTables(ctx context.Context, in *GetTables_Request, opts ...grpc.CallOption) (*GetTables_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetTables_Response)
-	err := c.cc.Invoke(ctx, Source_GetTables_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetTables_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -105,8 +109,9 @@ func (c *sourceClient) GetTables(ctx context.Context, in *GetTables_Request, opt
 }
 
 func (c *sourceClient) GetTablesForSpec(ctx context.Context, in *GetTablesForSpec_Request, opts ...grpc.CallOption) (*GetTablesForSpec_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetTablesForSpec_Response)
-	err := c.cc.Invoke(ctx, Source_GetTablesForSpec_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetTablesForSpec_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -114,8 +119,9 @@ func (c *sourceClient) GetTablesForSpec(ctx context.Context, in *GetTablesForSpe
 }
 
 func (c *sourceClient) GetSyncSummary(ctx context.Context, in *GetSyncSummary_Request, opts ...grpc.CallOption) (*GetSyncSummary_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetSyncSummary_Response)
-	err := c.cc.Invoke(ctx, Source_GetSyncSummary_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetSyncSummary_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -123,11 +129,12 @@ func (c *sourceClient) GetSyncSummary(ctx context.Context, in *GetSyncSummary_Re
 }
 
 func (c *sourceClient) Sync(ctx context.Context, in *Sync_Request, opts ...grpc.CallOption) (Source_SyncClient, error) {
-	stream, err := c.cc.NewStream(ctx, &Source_ServiceDesc.Streams[0], Source_Sync_FullMethodName, opts...)
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	stream, err := c.cc.NewStream(ctx, &Source_ServiceDesc.Streams[0], Source_Sync_FullMethodName, cOpts...)
 	if err != nil {
 		return nil, err
 	}
-	x := &sourceSyncClient{stream}
+	x := &sourceSyncClient{ClientStream: stream}
 	if err := x.ClientStream.SendMsg(in); err != nil {
 		return nil, err
 	}
@@ -155,11 +162,12 @@ func (x *sourceSyncClient) Recv() (*Sync_Response, error) {
 }
 
 func (c *sourceClient) Sync2(ctx context.Context, in *Sync2_Request, opts ...grpc.CallOption) (Source_Sync2Client, error) {
-	stream, err := c.cc.NewStream(ctx, &Source_ServiceDesc.Streams[1], Source_Sync2_FullMethodName, opts...)
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	stream, err := c.cc.NewStream(ctx, &Source_ServiceDesc.Streams[1], Source_Sync2_FullMethodName, cOpts...)
 	if err != nil {
 		return nil, err
 	}
-	x := &sourceSync2Client{stream}
+	x := &sourceSync2Client{ClientStream: stream}
 	if err := x.ClientStream.SendMsg(in); err != nil {
 		return nil, err
 	}
@@ -187,8 +195,9 @@ func (x *sourceSync2Client) Recv() (*Sync2_Response, error) {
 }
 
 func (c *sourceClient) GetMetrics(ctx context.Context, in *GetSourceMetrics_Request, opts ...grpc.CallOption) (*GetSourceMetrics_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetSourceMetrics_Response)
-	err := c.cc.Invoke(ctx, Source_GetMetrics_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetMetrics_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -382,7 +391,7 @@ func _Source_Sync_Handler(srv interface{}, stream grpc.ServerStream) error {
 	if err := stream.RecvMsg(m); err != nil {
 		return err
 	}
-	return srv.(SourceServer).Sync(m, &sourceSyncServer{stream})
+	return srv.(SourceServer).Sync(m, &sourceSyncServer{ServerStream: stream})
 }
 
 type Source_SyncServer interface {
@@ -403,7 +412,7 @@ func _Source_Sync2_Handler(srv interface{}, stream grpc.ServerStream) error {
 	if err := stream.RecvMsg(m); err != nil {
 		return err
 	}
-	return srv.(SourceServer).Sync2(m, &sourceSync2Server{stream})
+	return srv.(SourceServer).Sync2(m, &sourceSync2Server{ServerStream: stream})
 }
 
 type Source_Sync2Server interface {
diff --git a/pb/source/v1/source_grpc.pb.go b/pb/source/v1/source_grpc.pb.go
index d1bc583..8792d08 100644
--- a/pb/source/v1/source_grpc.pb.go
+++ b/pb/source/v1/source_grpc.pb.go
@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.3.0
+// - protoc-gen-go-grpc v1.4.0
 // - protoc             v4.23.4
 // source: plugin-pb/source/v1/source.proto
 
@@ -15,8 +15,8 @@ import (
 
 // 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
+// Requires gRPC-Go v1.62.0 or later.
+const _ = grpc.SupportPackageIsVersion8
 
 const (
 	Source_GetName_FullMethodName          = "/cloudquery.source.v1.Source/GetName"
@@ -60,8 +60,9 @@ func NewSourceClient(cc grpc.ClientConnInterface) SourceClient {
 }
 
 func (c *sourceClient) GetName(ctx context.Context, in *GetName_Request, opts ...grpc.CallOption) (*GetName_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetName_Response)
-	err := c.cc.Invoke(ctx, Source_GetName_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetName_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -69,8 +70,9 @@ func (c *sourceClient) GetName(ctx context.Context, in *GetName_Request, opts ..
 }
 
 func (c *sourceClient) GetVersion(ctx context.Context, in *GetVersion_Request, opts ...grpc.CallOption) (*GetVersion_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetVersion_Response)
-	err := c.cc.Invoke(ctx, Source_GetVersion_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetVersion_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -78,8 +80,9 @@ func (c *sourceClient) GetVersion(ctx context.Context, in *GetVersion_Request, o
 }
 
 func (c *sourceClient) GetTables(ctx context.Context, in *GetTables_Request, opts ...grpc.CallOption) (*GetTables_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetTables_Response)
-	err := c.cc.Invoke(ctx, Source_GetTables_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetTables_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -87,8 +90,9 @@ func (c *sourceClient) GetTables(ctx context.Context, in *GetTables_Request, opt
 }
 
 func (c *sourceClient) GetMetrics(ctx context.Context, in *GetMetrics_Request, opts ...grpc.CallOption) (*GetMetrics_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetMetrics_Response)
-	err := c.cc.Invoke(ctx, Source_GetMetrics_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetMetrics_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -96,8 +100,9 @@ func (c *sourceClient) GetMetrics(ctx context.Context, in *GetMetrics_Request, o
 }
 
 func (c *sourceClient) Init(ctx context.Context, in *Init_Request, opts ...grpc.CallOption) (*Init_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(Init_Response)
-	err := c.cc.Invoke(ctx, Source_Init_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_Init_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -105,8 +110,9 @@ func (c *sourceClient) Init(ctx context.Context, in *Init_Request, opts ...grpc.
 }
 
 func (c *sourceClient) GetDynamicTables(ctx context.Context, in *GetDynamicTables_Request, opts ...grpc.CallOption) (*GetDynamicTables_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetDynamicTables_Response)
-	err := c.cc.Invoke(ctx, Source_GetDynamicTables_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetDynamicTables_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -114,11 +120,12 @@ func (c *sourceClient) GetDynamicTables(ctx context.Context, in *GetDynamicTable
 }
 
 func (c *sourceClient) Sync(ctx context.Context, in *Sync_Request, opts ...grpc.CallOption) (Source_SyncClient, error) {
-	stream, err := c.cc.NewStream(ctx, &Source_ServiceDesc.Streams[0], Source_Sync_FullMethodName, opts...)
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	stream, err := c.cc.NewStream(ctx, &Source_ServiceDesc.Streams[0], Source_Sync_FullMethodName, cOpts...)
 	if err != nil {
 		return nil, err
 	}
-	x := &sourceSyncClient{stream}
+	x := &sourceSyncClient{ClientStream: stream}
 	if err := x.ClientStream.SendMsg(in); err != nil {
 		return nil, err
 	}
@@ -146,8 +153,9 @@ func (x *sourceSyncClient) Recv() (*Sync_Response, error) {
 }
 
 func (c *sourceClient) GenDocs(ctx context.Context, in *GenDocs_Request, opts ...grpc.CallOption) (*GenDocs_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GenDocs_Response)
-	err := c.cc.Invoke(ctx, Source_GenDocs_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GenDocs_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -331,7 +339,7 @@ func _Source_Sync_Handler(srv interface{}, stream grpc.ServerStream) error {
 	if err := stream.RecvMsg(m); err != nil {
 		return err
 	}
-	return srv.(SourceServer).Sync(m, &sourceSyncServer{stream})
+	return srv.(SourceServer).Sync(m, &sourceSyncServer{ServerStream: stream})
 }
 
 type Source_SyncServer interface {
diff --git a/pb/source/v2/source_grpc.pb.go b/pb/source/v2/source_grpc.pb.go
index 6cf1f71..1edfdfc 100644
--- a/pb/source/v2/source_grpc.pb.go
+++ b/pb/source/v2/source_grpc.pb.go
@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.3.0
+// - protoc-gen-go-grpc v1.4.0
 // - protoc             v4.23.4
 // source: plugin-pb/source/v2/source.proto
 
@@ -15,8 +15,8 @@ import (
 
 // 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
+// Requires gRPC-Go v1.62.0 or later.
+const _ = grpc.SupportPackageIsVersion8
 
 const (
 	Source_GetName_FullMethodName          = "/cloudquery.source.v2.Source/GetName"
@@ -60,8 +60,9 @@ func NewSourceClient(cc grpc.ClientConnInterface) SourceClient {
 }
 
 func (c *sourceClient) GetName(ctx context.Context, in *GetName_Request, opts ...grpc.CallOption) (*GetName_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetName_Response)
-	err := c.cc.Invoke(ctx, Source_GetName_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetName_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -69,8 +70,9 @@ func (c *sourceClient) GetName(ctx context.Context, in *GetName_Request, opts ..
 }
 
 func (c *sourceClient) GetVersion(ctx context.Context, in *GetVersion_Request, opts ...grpc.CallOption) (*GetVersion_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetVersion_Response)
-	err := c.cc.Invoke(ctx, Source_GetVersion_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetVersion_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -78,8 +80,9 @@ func (c *sourceClient) GetVersion(ctx context.Context, in *GetVersion_Request, o
 }
 
 func (c *sourceClient) GetTables(ctx context.Context, in *GetTables_Request, opts ...grpc.CallOption) (*GetTables_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetTables_Response)
-	err := c.cc.Invoke(ctx, Source_GetTables_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetTables_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -87,8 +90,9 @@ func (c *sourceClient) GetTables(ctx context.Context, in *GetTables_Request, opt
 }
 
 func (c *sourceClient) GetMetrics(ctx context.Context, in *GetMetrics_Request, opts ...grpc.CallOption) (*GetMetrics_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetMetrics_Response)
-	err := c.cc.Invoke(ctx, Source_GetMetrics_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetMetrics_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -96,8 +100,9 @@ func (c *sourceClient) GetMetrics(ctx context.Context, in *GetMetrics_Request, o
 }
 
 func (c *sourceClient) Init(ctx context.Context, in *Init_Request, opts ...grpc.CallOption) (*Init_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(Init_Response)
-	err := c.cc.Invoke(ctx, Source_Init_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_Init_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -105,8 +110,9 @@ func (c *sourceClient) Init(ctx context.Context, in *Init_Request, opts ...grpc.
 }
 
 func (c *sourceClient) GetDynamicTables(ctx context.Context, in *GetDynamicTables_Request, opts ...grpc.CallOption) (*GetDynamicTables_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GetDynamicTables_Response)
-	err := c.cc.Invoke(ctx, Source_GetDynamicTables_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GetDynamicTables_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -114,11 +120,12 @@ func (c *sourceClient) GetDynamicTables(ctx context.Context, in *GetDynamicTable
 }
 
 func (c *sourceClient) Sync(ctx context.Context, in *Sync_Request, opts ...grpc.CallOption) (Source_SyncClient, error) {
-	stream, err := c.cc.NewStream(ctx, &Source_ServiceDesc.Streams[0], Source_Sync_FullMethodName, opts...)
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	stream, err := c.cc.NewStream(ctx, &Source_ServiceDesc.Streams[0], Source_Sync_FullMethodName, cOpts...)
 	if err != nil {
 		return nil, err
 	}
-	x := &sourceSyncClient{stream}
+	x := &sourceSyncClient{ClientStream: stream}
 	if err := x.ClientStream.SendMsg(in); err != nil {
 		return nil, err
 	}
@@ -146,8 +153,9 @@ func (x *sourceSyncClient) Recv() (*Sync_Response, error) {
 }
 
 func (c *sourceClient) GenDocs(ctx context.Context, in *GenDocs_Request, opts ...grpc.CallOption) (*GenDocs_Response, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(GenDocs_Response)
-	err := c.cc.Invoke(ctx, Source_GenDocs_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Source_GenDocs_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@@ -331,7 +339,7 @@ func _Source_Sync_Handler(srv interface{}, stream grpc.ServerStream) error {
 	if err := stream.RecvMsg(m); err != nil {
 		return err
 	}
-	return srv.(SourceServer).Sync(m, &sourceSyncServer{stream})
+	return srv.(SourceServer).Sync(m, &sourceSyncServer{ServerStream: stream})
 }
 
 type Source_SyncServer interface {