rename Start to Open

cplugin/destination.go

@@ -22,7 +22,7 @@ import (
 
 type DestinationPlugin interface {
 	Configure(context.Context, DestinationConfigureRequest) (DestinationConfigureResponse, error)
-	Start(context.Context, DestinationStartRequest) (DestinationStartResponse, error)
+	Open(context.Context, DestinationOpenRequest) (DestinationOpenResponse, error)
 	Run(context.Context, DestinationRunStream) error
 	Stop(context.Context, DestinationStopRequest) (DestinationStopResponse, error)
 	Teardown(context.Context, DestinationTeardownRequest) (DestinationTeardownResponse, error)
@@ -60,8 +60,8 @@ type DestinationConfigureRequest struct {
 }
 type DestinationConfigureResponse struct{}
 
-type DestinationStartRequest struct{}
-type DestinationStartResponse struct{}
+type DestinationOpenRequest struct{}
+type DestinationOpenResponse struct{}
 
 type DestinationRunRequest struct {
 	Records []opencdc.Record

cplugin/source.go

@@ -22,7 +22,7 @@ import (
 
 type SourcePlugin interface {
 	Configure(context.Context, SourceConfigureRequest) (SourceConfigureResponse, error)
-	Start(context.Context, SourceStartRequest) (SourceStartResponse, error)
+	Open(context.Context, SourceOpenRequest) (SourceOpenResponse, error)
 	Run(context.Context, SourceRunStream) error
 	Stop(context.Context, SourceStopRequest) (SourceStopResponse, error)
 	Teardown(context.Context, SourceTeardownRequest) (SourceTeardownResponse, error)
@@ -60,10 +60,10 @@ type SourceConfigureRequest struct {
 }
 type SourceConfigureResponse struct{}
 
-type SourceStartRequest struct {
+type SourceOpenRequest struct {
 	Position opencdc.Position
 }
-type SourceStartResponse struct{}
+type SourceOpenResponse struct{}
 
 type SourceRunRequest struct {
 	AckPositions []opencdc.Position

cplugin/v1/client/destination.go

@@ -44,11 +44,11 @@ func (s *DestinationPluginClient) Configure(ctx context.Context, goReq cplugin.D
 	return fromproto.DestinationConfigureResponse(protoResp), nil
 }
 
-func (s *DestinationPluginClient) Start(ctx context.Context, goReq cplugin.DestinationStartRequest) (cplugin.DestinationStartResponse, error) {
+func (s *DestinationPluginClient) Open(ctx context.Context, goReq cplugin.DestinationOpenRequest) (cplugin.DestinationOpenResponse, error) {
 	protoReq := toproto.DestinationStartRequest(goReq)
 	protoResp, err := s.grpcClient.Start(ctx, protoReq)
 	if err != nil {
-		return cplugin.DestinationStartResponse{}, unwrapGRPCError(err)
+		return cplugin.DestinationOpenResponse{}, unwrapGRPCError(err)
 	}
 	return fromproto.DestinationStartResponse(protoResp), nil
 }

cplugin/v1/client/source.go

@@ -44,11 +44,11 @@ func (s *SourcePluginClient) Configure(ctx context.Context, goReq cplugin.Source
 	return fromproto.SourceConfigureResponse(protoResp), nil
 }
 
-func (s *SourcePluginClient) Start(ctx context.Context, goReq cplugin.SourceStartRequest) (cplugin.SourceStartResponse, error) {
+func (s *SourcePluginClient) Open(ctx context.Context, goReq cplugin.SourceOpenRequest) (cplugin.SourceOpenResponse, error) {
 	protoReq := toproto.SourceStartRequest(goReq)
 	protoResp, err := s.grpcClient.Start(ctx, protoReq)
 	if err != nil {
-		return cplugin.SourceStartResponse{}, unwrapGRPCError(err)
+		return cplugin.SourceOpenResponse{}, unwrapGRPCError(err)
 	}
 	return fromproto.SourceStartResponse(protoResp), nil
 }

cplugin/v1/fromproto/destination.go

@@ -28,8 +28,8 @@ func DestinationConfigureRequest(in *connectorv1.Destination_Configure_Request)
 	}
 }
 
-func DestinationStartRequest(_ *connectorv1.Destination_Start_Request) cplugin.DestinationStartRequest {
-	return cplugin.DestinationStartRequest{}
+func DestinationStartRequest(_ *connectorv1.Destination_Start_Request) cplugin.DestinationOpenRequest {
+	return cplugin.DestinationOpenRequest{}
 }
 
 func DestinationRunRequest(in *connectorv1.Destination_Run_Request) (cplugin.DestinationRunRequest, error) {
@@ -76,8 +76,8 @@ func DestinationConfigureResponse(_ *connectorv1.Destination_Configure_Response)
 	return cplugin.DestinationConfigureResponse{}
 }
 
-func DestinationStartResponse(_ *connectorv1.Destination_Start_Response) cplugin.DestinationStartResponse {
-	return cplugin.DestinationStartResponse{}
+func DestinationStartResponse(_ *connectorv1.Destination_Start_Response) cplugin.DestinationOpenResponse {
+	return cplugin.DestinationOpenResponse{}
 }
 
 func DestinationRunResponse(in *connectorv1.Destination_Run_Response) cplugin.DestinationRunResponse {

cplugin/v1/fromproto/source.go

@@ -28,8 +28,8 @@ func SourceConfigureRequest(in *connectorv1.Source_Configure_Request) cplugin.So
 	}
 }
 
-func SourceStartRequest(in *connectorv1.Source_Start_Request) cplugin.SourceStartRequest {
-	return cplugin.SourceStartRequest{
+func SourceStartRequest(in *connectorv1.Source_Start_Request) cplugin.SourceOpenRequest {
+	return cplugin.SourceOpenRequest{
 		Position: in.Position,
 	}
 }
@@ -71,8 +71,8 @@ func SourceConfigureResponse(_ *connectorv1.Source_Configure_Response) cplugin.S
 	return cplugin.SourceConfigureResponse{}
 }
 
-func SourceStartResponse(_ *connectorv1.Source_Start_Response) cplugin.SourceStartResponse {
-	return cplugin.SourceStartResponse{}
+func SourceStartResponse(_ *connectorv1.Source_Start_Response) cplugin.SourceOpenResponse {
+	return cplugin.SourceOpenResponse{}
 }
 
 func SourceRunResponse(in *connectorv1.Source_Run_Response) (cplugin.SourceRunResponse, error) {

cplugin/v1/fromproto/source_test.go

@@ -45,7 +45,7 @@ func TestSourceStartRequest(t *testing.T) {
 	have := &connectorv1.Source_Start_Request{
 		Position: []byte("test_position"),
 	}
-	want := cplugin.SourceStartRequest{
+	want := cplugin.SourceOpenRequest{
 		Position: []byte("test_position"),
 	}
 

cplugin/v1/server/destination.go

@@ -42,7 +42,7 @@ func (s *destinationPluginServer) Configure(ctx context.Context, protoReq *conne
 }
 func (s *destinationPluginServer) Start(ctx context.Context, protoReq *connectorv1.Destination_Start_Request) (*connectorv1.Destination_Start_Response, error) {
 	goReq := fromproto.DestinationStartRequest(protoReq)
-	goResp, err := s.impl.Start(ctx, goReq)
+	goResp, err := s.impl.Open(ctx, goReq)
 	if err != nil {
 		return nil, err
 	}

cplugin/v1/server/source.go

@@ -42,7 +42,7 @@ func (s *sourcePluginServer) Configure(ctx context.Context, protoReq *connectorv
 }
 func (s *sourcePluginServer) Start(ctx context.Context, protoReq *connectorv1.Source_Start_Request) (*connectorv1.Source_Start_Response, error) {
 	goReq := fromproto.SourceStartRequest(protoReq)
-	goResp, err := s.impl.Start(ctx, goReq)
+	goResp, err := s.impl.Open(ctx, goReq)
 	if err != nil {
 		return nil, err
 	}

cplugin/v1/toproto/destination.go

@@ -28,7 +28,7 @@ func DestinationConfigureRequest(in cplugin.DestinationConfigureRequest) *connec
 	}
 }
 
-func DestinationStartRequest(_ cplugin.DestinationStartRequest) *connectorv1.Destination_Start_Request {
+func DestinationStartRequest(_ cplugin.DestinationOpenRequest) *connectorv1.Destination_Start_Request {
 	return &connectorv1.Destination_Start_Request{}
 }
 
@@ -82,7 +82,7 @@ func DestinationConfigureResponse(_ cplugin.DestinationConfigureResponse) *conne
 	return &connectorv1.Destination_Configure_Response{}
 }
 
-func DestinationStartResponse(_ cplugin.DestinationStartResponse) *connectorv1.Destination_Start_Response {
+func DestinationStartResponse(_ cplugin.DestinationOpenResponse) *connectorv1.Destination_Start_Response {
 	return &connectorv1.Destination_Start_Response{}
 }
 

cplugin/v1/toproto/source.go

@@ -28,7 +28,7 @@ func SourceConfigureRequest(in cplugin.SourceConfigureRequest) *connectorv1.Sour
 	}
 }
 
-func SourceStartRequest(in cplugin.SourceStartRequest) *connectorv1.Source_Start_Request {
+func SourceStartRequest(in cplugin.SourceOpenRequest) *connectorv1.Source_Start_Request {
 	return &connectorv1.Source_Start_Request{
 		Position: in.Position,
 	}
@@ -77,7 +77,7 @@ func SourceConfigureResponse(_ cplugin.SourceConfigureResponse) *connectorv1.Sou
 	return &connectorv1.Source_Configure_Response{}
 }
 
-func SourceStartResponse(_ cplugin.SourceStartResponse) *connectorv1.Source_Start_Response {
+func SourceStartResponse(_ cplugin.SourceOpenResponse) *connectorv1.Source_Start_Response {
 	return &connectorv1.Source_Start_Response{}
 }
 

cplugin/v2/client/destination.go

@@ -44,13 +44,13 @@ func (s *DestinationPluginClient) Configure(ctx context.Context, goReq cplugin.D
 	return fromproto.DestinationConfigureResponse(protoResp), nil
 }
 
-func (s *DestinationPluginClient) Start(ctx context.Context, goReq cplugin.DestinationStartRequest) (cplugin.DestinationStartResponse, error) {
-	protoReq := toproto.DestinationStartRequest(goReq)
-	protoResp, err := s.grpcClient.Start(ctx, protoReq)
+func (s *DestinationPluginClient) Open(ctx context.Context, goReq cplugin.DestinationOpenRequest) (cplugin.DestinationOpenResponse, error) {
+	protoReq := toproto.DestinationOpenRequest(goReq)
+	protoResp, err := s.grpcClient.Open(ctx, protoReq)
 	if err != nil {
-		return cplugin.DestinationStartResponse{}, unwrapGRPCError(err)
+		return cplugin.DestinationOpenResponse{}, unwrapGRPCError(err)
 	}
-	return fromproto.DestinationStartResponse(protoResp), nil
+	return fromproto.DestinationOpenResponse(protoResp), nil
 }
 
 func (s *DestinationPluginClient) Run(ctx context.Context, stream cplugin.DestinationRunStream) error {

cplugin/v2/client/source.go

@@ -44,13 +44,13 @@ func (s *SourcePluginClient) Configure(ctx context.Context, goReq cplugin.Source
 	return fromproto.SourceConfigureResponse(protoResp), nil
 }
 
-func (s *SourcePluginClient) Start(ctx context.Context, goReq cplugin.SourceStartRequest) (cplugin.SourceStartResponse, error) {
-	protoReq := toproto.SourceStartRequest(goReq)
-	protoResp, err := s.grpcClient.Start(ctx, protoReq)
+func (s *SourcePluginClient) Open(ctx context.Context, goReq cplugin.SourceOpenRequest) (cplugin.SourceOpenResponse, error) {
+	protoReq := toproto.SourceOpenRequest(goReq)
+	protoResp, err := s.grpcClient.Open(ctx, protoReq)
 	if err != nil {
-		return cplugin.SourceStartResponse{}, unwrapGRPCError(err)
+		return cplugin.SourceOpenResponse{}, unwrapGRPCError(err)
 	}
-	return fromproto.SourceStartResponse(protoResp), nil
+	return fromproto.SourceOpenResponse(protoResp), nil
 }
 
 // Run initializes a stream for the source plugin to send and receive messages.

cplugin/v2/fromproto/destination.go

@@ -28,8 +28,8 @@ func DestinationConfigureRequest(in *connectorv2.Destination_Configure_Request)
 	}
 }
 
-func DestinationStartRequest(_ *connectorv2.Destination_Start_Request) cplugin.DestinationStartRequest {
-	return cplugin.DestinationStartRequest{}
+func DestinationOpenRequest(_ *connectorv2.Destination_Open_Request) cplugin.DestinationOpenRequest {
+	return cplugin.DestinationOpenRequest{}
 }
 
 func DestinationRunRequest(in *connectorv2.Destination_Run_Request) (cplugin.DestinationRunRequest, error) {
@@ -78,8 +78,8 @@ func DestinationConfigureResponse(_ *connectorv2.Destination_Configure_Response)
 	return cplugin.DestinationConfigureResponse{}
 }
 
-func DestinationStartResponse(_ *connectorv2.Destination_Start_Response) cplugin.DestinationStartResponse {
-	return cplugin.DestinationStartResponse{}
+func DestinationOpenResponse(_ *connectorv2.Destination_Open_Response) cplugin.DestinationOpenResponse {
+	return cplugin.DestinationOpenResponse{}
 }
 
 func DestinationRunResponse(in *connectorv2.Destination_Run_Response) cplugin.DestinationRunResponse {

cplugin/v2/fromproto/source.go

@@ -28,8 +28,8 @@ func SourceConfigureRequest(in *connectorv2.Source_Configure_Request) cplugin.So
 	}
 }
 
-func SourceStartRequest(in *connectorv2.Source_Start_Request) cplugin.SourceStartRequest {
-	return cplugin.SourceStartRequest{
+func SourceOpenRequest(in *connectorv2.Source_Open_Request) cplugin.SourceOpenRequest {
+	return cplugin.SourceOpenRequest{
 		Position: in.Position,
 	}
 }
@@ -76,8 +76,8 @@ func SourceConfigureResponse(_ *connectorv2.Source_Configure_Response) cplugin.S
 	return cplugin.SourceConfigureResponse{}
 }
 
-func SourceStartResponse(_ *connectorv2.Source_Start_Response) cplugin.SourceStartResponse {
-	return cplugin.SourceStartResponse{}
+func SourceOpenResponse(_ *connectorv2.Source_Open_Response) cplugin.SourceOpenResponse {
+	return cplugin.SourceOpenResponse{}
 }
 
 func SourceRunResponse(in *connectorv2.Source_Run_Response) (cplugin.SourceRunResponse, error) {

cplugin/v2/fromproto/source_test.go

@@ -41,16 +41,16 @@ func TestSourceConfigureRequest(t *testing.T) {
 	is.Equal("", cmp.Diff(want, got))
 }
 
-func TestSourceStartRequest(t *testing.T) {
-	have := &connectorv2.Source_Start_Request{
+func TestSourceOpenRequest(t *testing.T) {
+	have := &connectorv2.Source_Open_Request{
 		Position: []byte("test_position"),
 	}
-	want := cplugin.SourceStartRequest{
+	want := cplugin.SourceOpenRequest{
 		Position: []byte("test_position"),
 	}
 
 	is := is.New(t)
-	got := SourceStartRequest(have)
+	got := SourceOpenRequest(have)
 	is.Equal("", cmp.Diff(want, got))
 }
 

cplugin/v2/server/destination.go

@@ -40,13 +40,13 @@ func (s *DestinationPluginServer) Configure(ctx context.Context, protoReq *conne
 	}
 	return toproto.DestinationConfigureResponse(goResp), nil
 }
-func (s *DestinationPluginServer) Start(ctx context.Context, protoReq *connectorv2.Destination_Start_Request) (*connectorv2.Destination_Start_Response, error) {
-	goReq := fromproto.DestinationStartRequest(protoReq)
-	goResp, err := s.impl.Start(ctx, goReq)
+func (s *DestinationPluginServer) Open(ctx context.Context, protoReq *connectorv2.Destination_Open_Request) (*connectorv2.Destination_Open_Response, error) {
+	goReq := fromproto.DestinationOpenRequest(protoReq)
+	goResp, err := s.impl.Open(ctx, goReq)
 	if err != nil {
 		return nil, err
 	}
-	return toproto.DestinationStartResponse(goResp), nil
+	return toproto.DestinationOpenResponse(goResp), nil
 }
 func (s *DestinationPluginServer) Run(stream connectorv2.DestinationPlugin_RunServer) error {
 	return s.impl.Run(stream.Context(), &DestinationRunStream{stream: stream})

cplugin/v2/server/source.go

@@ -40,13 +40,13 @@ func (s *SourcePluginServer) Configure(ctx context.Context, protoReq *connectorv
 	}
 	return toproto.SourceConfigureResponse(goResp), nil
 }
-func (s *SourcePluginServer) Start(ctx context.Context, protoReq *connectorv2.Source_Start_Request) (*connectorv2.Source_Start_Response, error) {
-	goReq := fromproto.SourceStartRequest(protoReq)
-	goResp, err := s.impl.Start(ctx, goReq)
+func (s *SourcePluginServer) Open(ctx context.Context, protoReq *connectorv2.Source_Open_Request) (*connectorv2.Source_Open_Response, error) {
+	goReq := fromproto.SourceOpenRequest(protoReq)
+	goResp, err := s.impl.Open(ctx, goReq)
 	if err != nil {
 		return nil, err
 	}
-	return toproto.SourceStartResponse(goResp), nil
+	return toproto.SourceOpenResponse(goResp), nil
 }
 func (s *SourcePluginServer) Run(stream connectorv2.SourcePlugin_RunServer) error {
 	return s.impl.Run(stream.Context(), &SourceRunStream{stream: stream})

cplugin/v2/toproto/destination.go

@@ -28,8 +28,8 @@ func DestinationConfigureRequest(in cplugin.DestinationConfigureRequest) *connec
 	}
 }
 
-func DestinationStartRequest(_ cplugin.DestinationStartRequest) *connectorv2.Destination_Start_Request {
-	return &connectorv2.Destination_Start_Request{}
+func DestinationOpenRequest(_ cplugin.DestinationOpenRequest) *connectorv2.Destination_Open_Request {
+	return &connectorv2.Destination_Open_Request{}
 }
 
 func DestinationRunRequest(in cplugin.DestinationRunRequest) (*connectorv2.Destination_Run_Request, error) {
@@ -84,8 +84,8 @@ func DestinationConfigureResponse(_ cplugin.DestinationConfigureResponse) *conne
 	return &connectorv2.Destination_Configure_Response{}
 }
 
-func DestinationStartResponse(_ cplugin.DestinationStartResponse) *connectorv2.Destination_Start_Response {
-	return &connectorv2.Destination_Start_Response{}
+func DestinationOpenResponse(_ cplugin.DestinationOpenResponse) *connectorv2.Destination_Open_Response {
+	return &connectorv2.Destination_Open_Response{}
 }
 
 func DestinationRunResponse(in cplugin.DestinationRunResponse) *connectorv2.Destination_Run_Response {

cplugin/v2/toproto/source.go

@@ -28,8 +28,8 @@ func SourceConfigureRequest(in cplugin.SourceConfigureRequest) *connectorv2.Sour
 	}
 }
 
-func SourceStartRequest(in cplugin.SourceStartRequest) *connectorv2.Source_Start_Request {
-	return &connectorv2.Source_Start_Request{
+func SourceOpenRequest(in cplugin.SourceOpenRequest) *connectorv2.Source_Open_Request {
+	return &connectorv2.Source_Open_Request{
 		Position: in.Position,
 	}
 }
@@ -78,8 +78,8 @@ func SourceConfigureResponse(_ cplugin.SourceConfigureResponse) *connectorv2.Sou
 	return &connectorv2.Source_Configure_Response{}
 }
 
-func SourceStartResponse(_ cplugin.SourceStartResponse) *connectorv2.Source_Start_Response {
-	return &connectorv2.Source_Start_Response{}
+func SourceOpenResponse(_ cplugin.SourceOpenResponse) *connectorv2.Source_Open_Response {
+	return &connectorv2.Source_Open_Response{}
 }
 
 func SourceRunResponse(in cplugin.SourceRunResponse) (*connectorv2.Source_Run_Response, error) {