inputtable

Documentation

Index

• Variables
• func RegisterInputTableServiceServer(s grpc.ServiceRegistrar, srv InputTableServiceServer)
• type AddTableRequest
  • func (*AddTableRequest) Descriptor() ([]byte, []int)
  • func (x *AddTableRequest) GetInputTable() *ticket.Ticket
  • func (x *AddTableRequest) GetTableToAdd() *ticket.Ticket
  • func (*AddTableRequest) ProtoMessage()
  • func (x *AddTableRequest) ProtoReflect() protoreflect.Message
  • func (x *AddTableRequest) Reset()
  • func (x *AddTableRequest) String() string
• type AddTableResponse
  • func (*AddTableResponse) Descriptor() ([]byte, []int)
  • func (*AddTableResponse) ProtoMessage()
  • func (x *AddTableResponse) ProtoReflect() protoreflect.Message
  • func (x *AddTableResponse) Reset()
  • func (x *AddTableResponse) String() string
• type DeleteTableRequest
  • func (*DeleteTableRequest) Descriptor() ([]byte, []int)
  • func (x *DeleteTableRequest) GetInputTable() *ticket.Ticket
  • func (x *DeleteTableRequest) GetTableToRemove() *ticket.Ticket
  • func (*DeleteTableRequest) ProtoMessage()
  • func (x *DeleteTableRequest) ProtoReflect() protoreflect.Message
  • func (x *DeleteTableRequest) Reset()
  • func (x *DeleteTableRequest) String() string
• type DeleteTableResponse
  • func (*DeleteTableResponse) Descriptor() ([]byte, []int)
  • func (*DeleteTableResponse) ProtoMessage()
  • func (x *DeleteTableResponse) ProtoReflect() protoreflect.Message
  • func (x *DeleteTableResponse) Reset()
  • func (x *DeleteTableResponse) String() string
• type InputTableServiceClient
  • func NewInputTableServiceClient(cc grpc.ClientConnInterface) InputTableServiceClient
• type InputTableServiceServer
• type UnimplementedInputTableServiceServer
  • func (UnimplementedInputTableServiceServer) AddTableToInputTable(context.Context, *AddTableRequest) (*AddTableResponse, error)
  • func (UnimplementedInputTableServiceServer) DeleteTableFromInputTable(context.Context, *DeleteTableRequest) (*DeleteTableResponse, error)
• type UnsafeInputTableServiceServer

Variables

var File_deephaven_core_proto_inputtable_proto protoreflect.FileDescriptor

var InputTableService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "io.deephaven.proto.backplane.grpc.InputTableService",
	HandlerType: (*InputTableServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddTableToInputTable",
			Handler:    _InputTableService_AddTableToInputTable_Handler,
		},
		{
			MethodName: "DeleteTableFromInputTable",
			Handler:    _InputTableService_DeleteTableFromInputTable_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "deephaven_core/proto/inputtable.proto",
}

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

Functions

func RegisterInputTableServiceServer

func RegisterInputTableServiceServer(s grpc.ServiceRegistrar, srv InputTableServiceServer)

Types

type AddTableRequest

type AddTableRequest struct {
	InputTable *ticket.Ticket `protobuf:"bytes,1,opt,name=input_table,json=inputTable,proto3" json:"input_table,omitempty"`
	TableToAdd *ticket.Ticket `protobuf:"bytes,2,opt,name=table_to_add,json=tableToAdd,proto3" json:"table_to_add,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTableRequest) Descriptor

func (*AddTableRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddTableRequest.ProtoReflect.Descriptor instead.

func (*AddTableRequest) GetInputTable

func (x *AddTableRequest) GetInputTable() *ticket.Ticket

func (*AddTableRequest) GetTableToAdd

func (x *AddTableRequest) GetTableToAdd() *ticket.Ticket

func (*AddTableRequest) ProtoMessage

func (*AddTableRequest) ProtoMessage()

func (*AddTableRequest) ProtoReflect

func (x *AddTableRequest) ProtoReflect() protoreflect.Message

func (*AddTableRequest) Reset

func (x *AddTableRequest) Reset()

func (*AddTableRequest) String

func (x *AddTableRequest) String() string

type AddTableResponse

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

func (*AddTableResponse) Descriptor

func (*AddTableResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddTableResponse.ProtoReflect.Descriptor instead.

func (*AddTableResponse) ProtoMessage

func (*AddTableResponse) ProtoMessage()

func (*AddTableResponse) ProtoReflect

func (x *AddTableResponse) ProtoReflect() protoreflect.Message

func (*AddTableResponse) Reset

func (x *AddTableResponse) Reset()

func (*AddTableResponse) String

func (x *AddTableResponse) String() string

type DeleteTableRequest

type DeleteTableRequest struct {
	InputTable    *ticket.Ticket `protobuf:"bytes,1,opt,name=input_table,json=inputTable,proto3" json:"input_table,omitempty"`
	TableToRemove *ticket.Ticket `protobuf:"bytes,2,opt,name=table_to_remove,json=tableToRemove,proto3" json:"table_to_remove,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTableRequest) Descriptor

func (*DeleteTableRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTableRequest.ProtoReflect.Descriptor instead.

func (*DeleteTableRequest) GetInputTable

func (x *DeleteTableRequest) GetInputTable() *ticket.Ticket

func (*DeleteTableRequest) GetTableToRemove

func (x *DeleteTableRequest) GetTableToRemove() *ticket.Ticket

func (*DeleteTableRequest) ProtoMessage

func (*DeleteTableRequest) ProtoMessage()

func (*DeleteTableRequest) ProtoReflect

func (x *DeleteTableRequest) ProtoReflect() protoreflect.Message

func (*DeleteTableRequest) Reset

func (x *DeleteTableRequest) Reset()

func (*DeleteTableRequest) String

func (x *DeleteTableRequest) String() string

type DeleteTableResponse

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

func (*DeleteTableResponse) Descriptor

func (*DeleteTableResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTableResponse.ProtoReflect.Descriptor instead.

func (*DeleteTableResponse) ProtoMessage

func (*DeleteTableResponse) ProtoMessage()

func (*DeleteTableResponse) ProtoReflect

func (x *DeleteTableResponse) ProtoReflect() protoreflect.Message

func (*DeleteTableResponse) Reset

func (x *DeleteTableResponse) Reset()

func (*DeleteTableResponse) String

func (x *DeleteTableResponse) String() string

type InputTableServiceClient

type InputTableServiceClient interface {
	//
	// Adds the provided table to the specified input table. The new data to add must only have
	// columns (name, types, and order) which match the given input table's columns.
	AddTableToInputTable(ctx context.Context, in *AddTableRequest, opts ...grpc.CallOption) (*AddTableResponse, error)
	//
	// Removes the provided table from the specified input tables. The tables indicating which rows
	// to remove are expected to only have columns that match the key columns of the input table.
	DeleteTableFromInputTable(ctx context.Context, in *DeleteTableRequest, opts ...grpc.CallOption) (*DeleteTableResponse, error)
}

InputTableServiceClient is the client API for InputTableService 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 NewInputTableServiceClient

func NewInputTableServiceClient(cc grpc.ClientConnInterface) InputTableServiceClient

type InputTableServiceServer

type InputTableServiceServer interface {
	//
	// Adds the provided table to the specified input table. The new data to add must only have
	// columns (name, types, and order) which match the given input table's columns.
	AddTableToInputTable(context.Context, *AddTableRequest) (*AddTableResponse, error)
	//
	// Removes the provided table from the specified input tables. The tables indicating which rows
	// to remove are expected to only have columns that match the key columns of the input table.
	DeleteTableFromInputTable(context.Context, *DeleteTableRequest) (*DeleteTableResponse, error)
	// contains filtered or unexported methods
}

InputTableServiceServer is the server API for InputTableService service. All implementations must embed UnimplementedInputTableServiceServer for forward compatibility

type UnimplementedInputTableServiceServer

type UnimplementedInputTableServiceServer struct {
}

UnimplementedInputTableServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedInputTableServiceServer) AddTableToInputTable

func (UnimplementedInputTableServiceServer) AddTableToInputTable(context.Context, *AddTableRequest) (*AddTableResponse, error)

func (UnimplementedInputTableServiceServer) DeleteTableFromInputTable

func (UnimplementedInputTableServiceServer) DeleteTableFromInputTable(context.Context, *DeleteTableRequest) (*DeleteTableResponse, error)

type UnsafeInputTableServiceServer

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

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