restapi

Documentation

Index

• Constants
• func GetCredentials(ctx context.Context) qc.Credentials
• func NewServer(coordinator *qc.QueryCoordinator, config ServerConfig) *http.Server
• type CoordinatorService
  • func (c CoordinatorService) ClusterNamesGet(_ context.Context, _ gen.ClusterNamesGetParams) ([]string, error)
  • func (c CoordinatorService) NewError(_ context.Context, err error) *gen.ErrorResponseStatusCode
  • func (c CoordinatorService) RawSQLPost(ctx context.Context, req *gen.RawSQLRequest, _ gen.RawSQLPostParams) (gen.RawSQLListResponse, error)
• type SecurityHandler
  • func (s SecurityHandler) HandleBasicAuth(ctx context.Context, _ string, t gs.BasicAuth) (context.Context, error)
• type ServerConfig

Constants

const CtxKeyCredentials = ctxKey(1)

Functions

func GetCredentials

func GetCredentials(ctx context.Context) qc.Credentials

func NewServer

func NewServer(coordinator *qc.QueryCoordinator, config ServerConfig) *http.Server

Types

type CoordinatorService

type CoordinatorService struct {
	Coordinator *qc.QueryCoordinator
}

func (CoordinatorService) ClusterNamesGet

func (c CoordinatorService) ClusterNamesGet(_ context.Context, _ gen.ClusterNamesGetParams) ([]string, error)

func (CoordinatorService) NewError

func (c CoordinatorService) NewError(_ context.Context, err error) *gen.ErrorResponseStatusCode

NewError handles not-error returned by 'action' methods

func (CoordinatorService) RawSQLPost

func (c CoordinatorService) RawSQLPost(
	ctx context.Context,
	req *gen.RawSQLRequest,
	_ gen.RawSQLPostParams,
) (gen.RawSQLListResponse, error)

type SecurityHandler

type SecurityHandler struct {
}

func (SecurityHandler) HandleBasicAuth

func (s SecurityHandler) HandleBasicAuth(
	ctx context.Context,
	_ string,
	t gs.BasicAuth,
) (context.Context, error)

type ServerConfig

type ServerConfig struct {
	Listen               string
	Timeout, IdleTimeout time.Duration
	Log                  *app.Logger
}