Documentation
¶
Index ¶
- Constants
- type Client
- func (*Client) GetMaskingPolicies(table *odps.Table) (maskingPolicies map[Column][]Policy, err error)
- func (c *Client) GetTablePreview(_ context.Context, partitionValue string, table *odps.Table, maxRows int) ([]string, *structpb.ListValue, error)
- func (*Client) GetTableSchema(_ context.Context, table *odps.Table) (string, *tableschema.TableSchema, error)
- func (c *Client) ListSchema(_ context.Context) (schemas []*odps.Schema, err error)
- func (c *Client) ListTable(_ context.Context, schemaName string) (tables []*odps.Table, err error)
- type Column
- type OptimusClient
- type Policy
Constants ¶
View Source
const ( OptimusGRPCMaxClientSendSizeMB = 45 OptimusGRPCMaxClientRecvSizeMB = 45 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) GetMaskingPolicies ¶ added in v0.11.3
func (*Client) GetTablePreview ¶ added in v0.11.1
func (*Client) GetTableSchema ¶
func (*Client) GetTableSchema(_ context.Context, table *odps.Table) (string, *tableschema.TableSchema, error)
func (*Client) ListSchema ¶
type OptimusClient ¶ added in v0.12.0
type OptimusClient interface {
ListResourceSpecification(ctx context.Context, in *pb.ListResourceSpecificationRequest, opts ...grpc.CallOption) (*pb.ListResourceSpecificationResponse, error)
Connect(ctx context.Context, host string, maxSizeInMB int) error
Close() error
}
func NewOptimusClient ¶ added in v0.12.0
func NewOptimusClient() OptimusClient
Source Files
Click to show internal directories.
Click to hide internal directories.