scqlstub

Documentation

Index

• type ScqlStub
  • func NewStub(conf *config.Config, clusterDefine *appconfig.ClusterDefine, ...) (*ScqlStub, error)
  • func (s *ScqlStub) CreateJob() error
  • func (s *ScqlStub) CreateProject() error
  • func (s *ScqlStub) CreateTable() error
  • func (s *ScqlStub) GrantCcl() error
  • func (s *ScqlStub) InviteMember() error
  • func (s *ScqlStub) WaitAndAcceptInvitation() error
  • func (s *ScqlStub) WaitCclReady() error
  • func (s *ScqlStub) WaitMemberReady() error
  • func (s *ScqlStub) WaitResult(skipWait bool) (*scql.QueryResult, error)

Types

type ScqlStub

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

func NewStub

func NewStub(conf *config.Config, clusterDefine *appconfig.ClusterDefine, taskConfig *taskconfig.ScqlTaskInputConfig, brokerUrl, selfParty string) (*ScqlStub, error)

func (*ScqlStub) CreateJob

func (s *ScqlStub) CreateJob() error

func (*ScqlStub) CreateProject

func (s *ScqlStub) CreateProject() error

func (*ScqlStub) CreateTable

func (s *ScqlStub) CreateTable() error

func (*ScqlStub) GrantCcl

func (s *ScqlStub) GrantCcl() error

func (*ScqlStub) InviteMember

func (s *ScqlStub) InviteMember() error

func (*ScqlStub) WaitAndAcceptInvitation

func (s *ScqlStub) WaitAndAcceptInvitation() error

func (*ScqlStub) WaitCclReady

func (s *ScqlStub) WaitCclReady() error

func (*ScqlStub) WaitMemberReady

func (s *ScqlStub) WaitMemberReady() error

func (*ScqlStub) WaitResult

func (s *ScqlStub) WaitResult(skipWait bool) (*scql.QueryResult, error)