table_diff

package
v0.93.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 8, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_table_diff_proto protoreflect.FileDescriptor
View Source 
var TableDiffer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "diff.TableDiffer",
	HandlerType: (*TableDifferServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TableDiff",
			Handler:    _TableDiffer_TableDiff_Handler,
		},
		{
			MethodName: "ShowHistory",
			Handler:    _TableDiffer_ShowHistory_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "table_diff.proto",
}

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

Functions

func RegisterTableDifferServer 

func RegisterTableDifferServer(s grpc.ServiceRegistrar, srv TableDifferServer)

Types

type DiffProps 

type DiffProps struct {
	Repo           string     `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	LeftTablePath  *TablePath `protobuf:"bytes,2,opt,name=left_table_path,json=leftTablePath,proto3" json:"left_table_path,omitempty"`
	RightTablePath *TablePath `protobuf:"bytes,3,opt,name=right_table_path,json=rightTablePath,proto3" json:"right_table_path,omitempty"`
	BaseTablePath  *TablePath `protobuf:"bytes,4,opt,name=base_table_path,json=baseTablePath,proto3,oneof" json:"base_table_path,omitempty"`
	// contains filtered or unexported fields
}

func (*DiffProps) Descriptor deprecated 

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

Deprecated: Use DiffProps.ProtoReflect.Descriptor instead.

func (*DiffProps) GetBaseTablePath 

func (x *DiffProps) GetBaseTablePath() *TablePath

func (*DiffProps) GetLeftTablePath 

func (x *DiffProps) GetLeftTablePath() *TablePath

func (*DiffProps) GetRepo 

func (x *DiffProps) GetRepo() string

func (*DiffProps) GetRightTablePath 

func (x *DiffProps) GetRightTablePath() *TablePath

func (*DiffProps) ProtoMessage 

func (*DiffProps) ProtoMessage()

func (*DiffProps) ProtoReflect 

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

func (*DiffProps) Reset 

func (x *DiffProps) Reset()

func (*DiffProps) String 

func (x *DiffProps) String() string

type DiffRequest 

type DiffRequest struct {
	Props         *DiffProps     `protobuf:"bytes,1,opt,name=props,proto3" json:"props,omitempty"`
	GatewayConfig *GatewayConfig `protobuf:"bytes,2,opt,name=gateway_config,json=gatewayConfig,proto3" json:"gateway_config,omitempty"`
	// contains filtered or unexported fields
}

func (*DiffRequest) Descriptor deprecated 

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

Deprecated: Use DiffRequest.ProtoReflect.Descriptor instead.

func (*DiffRequest) GetGatewayConfig 

func (x *DiffRequest) GetGatewayConfig() *GatewayConfig

func (*DiffRequest) GetProps 

func (x *DiffRequest) GetProps() *DiffProps

func (*DiffRequest) ProtoMessage 

func (*DiffRequest) ProtoMessage()

func (*DiffRequest) ProtoReflect 

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

func (*DiffRequest) Reset 

func (x *DiffRequest) Reset()

func (*DiffRequest) String 

func (x *DiffRequest) String() string

type DiffResponse 

type DiffResponse struct {
	Records []*TableOperation `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*DiffResponse) Descriptor deprecated 

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

Deprecated: Use DiffResponse.ProtoReflect.Descriptor instead.

func (*DiffResponse) GetRecords 

func (x *DiffResponse) GetRecords() []*TableOperation

func (*DiffResponse) ProtoMessage 

func (*DiffResponse) ProtoMessage()

func (*DiffResponse) ProtoReflect 

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

func (*DiffResponse) Reset 

func (x *DiffResponse) Reset()

func (*DiffResponse) String 

func (x *DiffResponse) String() string

type GatewayConfig 

type GatewayConfig struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Secret   string `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewayConfig) Descriptor deprecated 

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

Deprecated: Use GatewayConfig.ProtoReflect.Descriptor instead.

func (*GatewayConfig) GetEndpoint 

func (x *GatewayConfig) GetEndpoint() string

func (*GatewayConfig) GetKey 

func (x *GatewayConfig) GetKey() string

func (*GatewayConfig) GetSecret 

func (x *GatewayConfig) GetSecret() string

func (*GatewayConfig) ProtoMessage 

func (*GatewayConfig) ProtoMessage()

func (*GatewayConfig) ProtoReflect 

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

func (*GatewayConfig) Reset 

func (x *GatewayConfig) Reset()

func (*GatewayConfig) String 

func (x *GatewayConfig) String() string

type HistoryRequest 

type HistoryRequest struct {
	Path *TablePath `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryRequest) Descriptor deprecated 

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

Deprecated: Use HistoryRequest.ProtoReflect.Descriptor instead.

func (*HistoryRequest) GetPath 

func (x *HistoryRequest) GetPath() *TablePath

func (*HistoryRequest) ProtoMessage 

func (*HistoryRequest) ProtoMessage()

func (*HistoryRequest) ProtoReflect 

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

func (*HistoryRequest) Reset 

func (x *HistoryRequest) Reset()

func (*HistoryRequest) String 

func (x *HistoryRequest) String() string

type HistoryResponse 

type HistoryResponse struct {
	Records []*TableOperation `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryResponse) Descriptor deprecated 

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

Deprecated: Use HistoryResponse.ProtoReflect.Descriptor instead.

func (*HistoryResponse) GetRecords 

func (x *HistoryResponse) GetRecords() []*TableOperation

func (*HistoryResponse) ProtoMessage 

func (*HistoryResponse) ProtoMessage()

func (*HistoryResponse) ProtoReflect 

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

func (*HistoryResponse) Reset 

func (x *HistoryResponse) Reset()

func (*HistoryResponse) String 

func (x *HistoryResponse) String() string

type TableDifferClient 

type TableDifferClient interface {
	TableDiff(ctx context.Context, in *DiffRequest, opts ...grpc.CallOption) (*DiffResponse, error)
	ShowHistory(ctx context.Context, in *HistoryRequest, opts ...grpc.CallOption) (*HistoryResponse, error)
}

TableDifferClient is the client API for TableDiffer 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 NewTableDifferClient 

func NewTableDifferClient(cc grpc.ClientConnInterface) TableDifferClient

type TableDifferServer 

type TableDifferServer interface {
	TableDiff(context.Context, *DiffRequest) (*DiffResponse, error)
	ShowHistory(context.Context, *HistoryRequest) (*HistoryResponse, error)
	// contains filtered or unexported methods
}

TableDifferServer is the server API for TableDiffer service. All implementations must embed UnimplementedTableDifferServer for forward compatibility

type TableOperation 

type TableOperation struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Operation string                 `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	Content   map[string]string      `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TableOperation) Descriptor deprecated 

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

Deprecated: Use TableOperation.ProtoReflect.Descriptor instead.

func (*TableOperation) GetContent 

func (x *TableOperation) GetContent() map[string]string

func (*TableOperation) GetId 

func (x *TableOperation) GetId() string

func (*TableOperation) GetOperation 

func (x *TableOperation) GetOperation() string

func (*TableOperation) GetTimestamp 

func (x *TableOperation) GetTimestamp() *timestamppb.Timestamp

func (*TableOperation) ProtoMessage 

func (*TableOperation) ProtoMessage()

func (*TableOperation) ProtoReflect 

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

func (*TableOperation) Reset 

func (x *TableOperation) Reset()

func (*TableOperation) String 

func (x *TableOperation) String() string

type TablePath 

type TablePath struct {
	Ref  string `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*TablePath) Descriptor deprecated 

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

Deprecated: Use TablePath.ProtoReflect.Descriptor instead.

func (*TablePath) GetPath 

func (x *TablePath) GetPath() string

func (*TablePath) GetRef 

func (x *TablePath) GetRef() string

func (*TablePath) ProtoMessage 

func (*TablePath) ProtoMessage()

func (*TablePath) ProtoReflect 

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

func (*TablePath) Reset 

func (x *TablePath) Reset()

func (*TablePath) String 

func (x *TablePath) String() string

type UnimplementedTableDifferServer 

type UnimplementedTableDifferServer struct {
}

UnimplementedTableDifferServer must be embedded to have forward compatible implementations.

func (UnimplementedTableDifferServer) ShowHistory 

func (UnimplementedTableDifferServer) ShowHistory(context.Context, *HistoryRequest) (*HistoryResponse, error)

func (UnimplementedTableDifferServer) TableDiff 

func (UnimplementedTableDifferServer) TableDiff(context.Context, *DiffRequest) (*DiffResponse, error)

type UnsafeTableDifferServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.