Cloud Spanner - Package cloud.google.com/go/spanner/test/cloudexecutor/executor (v1.95.0)

1.95.0 (latest) 1.94.0 1.93.0 1.92.0 1.91.0 1.90.0 1.89.0 1.88.0 1.87.0 1.86.1 1.85.1 1.84.1 1.83.0 1.82.0 1.81.1 1.80.0 1.79.0 1.78.0 1.77.0 1.76.1 1.75.0 1.74.0 1.73.0 1.72.0 1.71.0 1.70.0 1.69.0 1.68.0 1.67.0 1.66.0 1.65.0 1.64.0 1.63.0 1.62.0 1.61.0 1.60.0 1.59.0 1.58.0 1.57.0 1.56.0 1.55.0 1.54.0 1.53.1 1.52.0 1.49.0 1.48.0 1.47.0 1.46.0 1.45.1 1.44.0 1.43.0 1.42.0 1.41.0 1.40.0 1.39.0 1.38.0 1.37.0 1.36.0 1.35.0 1.34.1 1.33.0 1.32.0 1.31.0 1.30.1 1.29.0 1.28.0 1.27.0 1.26.0 1.25.0 1.24.1 1.23.0 1.22.0 1.21.0 1.20.0 1.19.0 1.18.0 1.17.0 1.16.0 1.15.0 1.14.1 1.13.0

Note: To get more information about this package, such as access to older versions, view this package on pkg.go.dev.

CloudProxyServer

type CloudProxyServer struct {
	// contains filtered or unexported fields
}

CloudProxyServer holds the cloud executor server.

func NewCloudProxyServer

func NewCloudProxyServer(ctx context.Context, opts []option.ClientOption) (*CloudProxyServer, error)

NewCloudProxyServer initializes and returns a new CloudProxyServer instance.

func (*CloudProxyServer) ExecuteActionAsync

func (s *CloudProxyServer) ExecuteActionAsync(inputStream executorpb.SpannerExecutorProxy_ExecuteActionAsyncServer) error

ExecuteActionAsync is implementation of ExecuteActionAsync in SpannerExecutorProxyServer. It's a streaming method in which client and server exchange SpannerActions and SpannerActionOutcomes.