psdbconnectv1alpha1grpc

Documentation

Index

• Constants
• Variables
• func RegisterConnectServer(s grpc.ServiceRegistrar, srv ConnectServer)
• type ConnectClient
  • func NewConnectClient(cc grpc.ClientConnInterface) ConnectClient
• type ConnectServer
• type Connect_SyncClient
• type Connect_SyncServer
• type UnimplementedConnectServer
  • func (UnimplementedConnectServer) Sync(*v1alpha1.SyncRequest, Connect_SyncServer) error
• type UnsafeConnectServer

Constants

const (
	Connect_Sync_FullMethodName = "/psdbconnect.v1alpha1.Connect/Sync"
)

Variables

var Connect_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "psdbconnect.v1alpha1.Connect",
	HandlerType: (*ConnectServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Sync",
			Handler:       _Connect_Sync_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "psdbconnect/v1alpha1/connect.proto",
}

Connect_ServiceDesc is the grpc.ServiceDesc for Connect service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterConnectServer

func RegisterConnectServer(s grpc.ServiceRegistrar, srv ConnectServer)

Types

type ConnectClient

type ConnectClient interface {
	// Sync will continuously stream data from a PlanetScale database given a table, keyspace and shard.
	// Sync also allows you to incrementally sync data from a table given a TableCursor that is returned as part of the SyncResponse.
	// If the last known position is empty, Sync will download all the rows for a given table in a shard
	// and then wait to stream any changes to the table (inserts/updates/deletes)
	// If the last known position is not empty, Sync will pickup where the last Sync session left off and stream
	// any changes to the table since the last Sync session.
	Sync(ctx context.Context, in *v1alpha1.SyncRequest, opts ...grpc.CallOption) (Connect_SyncClient, error)
}

ConnectClient is the client API for Connect 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.

func NewConnectClient

func NewConnectClient(cc grpc.ClientConnInterface) ConnectClient

type ConnectServer

type ConnectServer interface {
	// Sync will continuously stream data from a PlanetScale database given a table, keyspace and shard.
	// Sync also allows you to incrementally sync data from a table given a TableCursor that is returned as part of the SyncResponse.
	// If the last known position is empty, Sync will download all the rows for a given table in a shard
	// and then wait to stream any changes to the table (inserts/updates/deletes)
	// If the last known position is not empty, Sync will pickup where the last Sync session left off and stream
	// any changes to the table since the last Sync session.
	Sync(*v1alpha1.SyncRequest, Connect_SyncServer) error
}

ConnectServer is the server API for Connect service. All implementations should embed UnimplementedConnectServer for forward compatibility

type Connect_SyncClient

type Connect_SyncClient interface {
	Recv() (*v1alpha1.SyncResponse, error)
	grpc.ClientStream
}

type Connect_SyncServer

type Connect_SyncServer interface {
	Send(*v1alpha1.SyncResponse) error
	grpc.ServerStream
}

type UnimplementedConnectServer

type UnimplementedConnectServer struct {
}

UnimplementedConnectServer should be embedded to have forward compatible implementations.

func (UnimplementedConnectServer) Sync

func (UnimplementedConnectServer) Sync(*v1alpha1.SyncRequest, Connect_SyncServer) error

type UnsafeConnectServer

type UnsafeConnectServer interface {
	// contains filtered or unexported methods
}

UnsafeConnectServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConnectServer will result in compilation errors.