flight_integration

Documentation

Index

• Variables
• func CheckActionResults(ctx context.Context, client flight.Client, action *flight.Action, ...) error
• type Scenario
  • func GetScenario(name string, args ...string) Scenario

Variables

var (
	// Schema to be returned for mocking the statement/prepared statement
	// results. Must be the same across all languages
	QuerySchema = arrow.NewSchema([]arrow.Field{{
		Name: "id", Type: arrow.PrimitiveTypes.Int64, Nullable: true,
		Metadata: flightsql.NewColumnMetadataBuilder().
			TableName("test").IsAutoIncrement(true).IsCaseSensitive(false).
			TypeName("type_test").SchemaName("schema_test").IsSearchable(true).
			CatalogName("catalog_test").Precision(100).Metadata(),
	}}, nil)
)

Functions

func CheckActionResults

func CheckActionResults(ctx context.Context, client flight.Client, action *flight.Action, results []string) error

Types

type Scenario

type Scenario interface {
	MakeServer(port int) flight.Server
	RunClient(addr string, opts ...grpc.DialOption) error
}

func GetScenario

func GetScenario(name string, args ...string) Scenario