* Changed type of topic/topicoptions.AlterOption from func to inter… (#413)

* * Changed type of `topic/topicoptions.AlterOption` from func to interface
* Changed type of `topic/topicoptions.CreateOption` from func to interface
* Added implementations of `topic/topicoptions.AlterOption` and `topic/topicoptions.CreateOption`

* add sorting of slice entities

* * Changed type of `topic/topicoptions.DescribeOption` from func to interface
* Changed type of `topic/topicoptions.DropOption` from func to interface

* renames

* * Changed type of `table/options.{Create,Alter,Drop}TableOption` from func to interface
* Added implementations of `table/options.{Create,Alter,Drop}Option`

* revert topicoptions.DescribeOption type

Author: asmyasnikov

CHANGELOG.md

@@ -1,3 +1,7 @@
+* Changed type of `table/options.{Create,Alter,Drop}TableOption` from func to interface
+* Added implementations of `table/options.{Create,Alter,Drop}Option`
+* Changed type of `topic/topicoptions.{Create,Alter,Drop}Option` from func to interface
+* Added implementations of `topic/topicoptions.{Create,Alter}Option`
 * Fix internal race-condition bugs in internal background worker
 
 ## v3.38.3

internal/table/session.go

@@ -273,7 +273,7 @@ func (s *session) CreateTable(
 	)
 	defer a.Free()
 	for _, opt := range opts {
-		opt((*options.CreateTableDesc)(&request), a)
+		opt.ApplyCreateTableOption((*options.CreateTableDesc)(&request), a)
 	}
 	t := s.trailer()
 	defer t.processHints()
@@ -449,7 +449,7 @@ func (s *session) DropTable(
 		),
 	}
 	for _, opt := range opts {
-		opt((*options.DropTableDesc)(&request))
+		opt.ApplyDropTableOption((*options.DropTableDesc)(&request))
 	}
 	t := s.trailer()
 	defer t.processHints()
@@ -491,7 +491,7 @@ func (s *session) AlterTable(
 	)
 	defer a.Free()
 	for _, opt := range opts {
-		opt((*options.AlterTableDesc)(&request), a)
+		opt.ApplyAlterTableOption((*options.AlterTableDesc)(&request), a)
 	}
 	t := s.trailer()
 	defer t.processHints()

internal/topic/topicclientinternal/client.go

@@ -68,8 +68,8 @@ func (c *Client) Alter(ctx context.Context, path string, opts ...topicoptions.Al
 	req := rawtopic.AlterTopicRequest{}
 	req.OperationParams = c.defaultOperationParams
 	req.Path = path
-	for _, f := range opts {
-		f(&req)
+	for _, o := range opts {
+		o.ApplyAlterOption(&req)
 	}
 
 	call := func(ctx context.Context) error {
@@ -97,8 +97,8 @@ func (c *Client) Create(
 	req.OperationParams = c.defaultOperationParams
 	req.Path = path
 
-	for _, f := range opts {
-		f(&req)
+	for _, o := range opts {
+		o.ApplyCreateOption(&req)
 	}
 
 	call := func(ctx context.Context) error {
@@ -127,8 +127,8 @@ func (c *Client) Describe(
 		Path:            path,
 	}
 
-	for _, opt := range opts {
-		opt(&req)
+	for _, o := range opts {
+		o(&req)
 	}
 
 	var rawRes rawtopic.DescribeTopicResult
@@ -164,8 +164,8 @@ func (c *Client) Drop(ctx context.Context, path string, opts ...topicoptions.Dro
 	req.OperationParams = c.defaultOperationParams
 	req.Path = path
 
-	for _, f := range opts {
-		f(&req)
+	for _, o := range opts {
+		o.ApplyDropOption(&req)
 	}
 
 	call := func(ctx context.Context) error {