brokerutil

package

v0.0.0-...-e0c7ee5 Latest Latest Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/secretflow/scql

Links

Open Source Insights

Documentation ¶

Overview ¶

Due to circular references, please avoid moving this file to testutil.

Index ¶

type Command
- func NewCommand(host string, timeoutS int) *Command
type TestAppBuilder
- func (b *TestAppBuilder) BuildAppTests() error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Command ¶

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

Simplify the complexity of calling HTTP interfaces when writing debugging tools or test code.

func NewCommand ¶

func NewCommand(host string, timeoutS int) *Command

func (*Command) CancelJob ¶

func (c *Command) CancelJob(jobID string) error

func (*Command) CreateJob ¶

func (c *Command) CreateJob(projectID, query string, debugOpts *pb.DebugOptions) (string, error)

func (*Command) CreateProject ¶

func (c *Command) CreateProject(projectID, projectConf string) (string, error)

func (*Command) CreateTable ¶

func (c *Command) CreateTable(projectID, tableName, dbType, refTable string, columns []*pb.CreateTableRequest_ColumnDesc) error

func (*Command) DeleteTable ¶

func (c *Command) DeleteTable(projectID, name string) error

func (*Command) DoQuery ¶

func (c *Command) DoQuery(projectID, query string, debugOpts *pb.DebugOptions) (*pb.QueryResponse, error)

func (*Command) GetCCL ¶

func (c *Command) GetCCL(projectID string, tables, destParties []string) (*pb.ShowCCLResponse, error)

func (*Command) GetInvitation ¶

func (c *Command) GetInvitation() (*pb.ListInvitationsResponse, error)

func (*Command) GetProject ¶

func (c *Command) GetProject(projectID string) (*pb.ListProjectsResponse, error)

func (*Command) GetResult ¶

func (c *Command) GetResult(jobID string) (result *pb.QueryResponse, not_ready bool, err error)

func (*Command) GetTable ¶

func (c *Command) GetTable(projectID string, tableNames []string) (*pb.ListTablesResponse, error)

func (*Command) GrantCCL ¶

func (c *Command) GrantCCL(projectID string, ccls []*pb.ColumnControl) error

func (*Command) InviteMember ¶

func (c *Command) InviteMember(projectID, member string) error

func (*Command) ProcessInvitation ¶

func (c *Command) ProcessInvitation(ids string, accept bool) error

func (*Command) RevokeCCL ¶

func (c *Command) RevokeCCL(projectID, party string, ccls []*pb.ColumnControl) error

type TestAppBuilder ¶

type TestAppBuilder struct {
	PartyInfoTmpPath string
	PemFilePaths     map[string]string
	ServerAlice      *httptest.Server
	ServerBob        *httptest.Server
	ServerCarol      *httptest.Server
	ServerEngine     *httptest.Server
	ServerAliceUrl   string
	ServerBobUrl     string
	ServerCarolUrl   string
	ServerEngineUrl  string
	AppAlice         *application.App
	AppBob           *application.App
	AppCarol         *application.App
}

func (*TestAppBuilder) BuildAppTests ¶

func (b *TestAppBuilder) BuildAppTests() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL