server

Documentation

Index

• func Start() (err error)
• type JobManagerServer
  • func NewJobManagerServer(service *service.JobManagerService) *JobManagerServer
  • func (s *JobManagerServer) CancelFlinkJob(ctx context.Context, req *pbrequest.CancelFlinkJob) (*pbmodel.EmptyStruct, error)
  • func (s *JobManagerServer) FreeFlinkJob(ctx context.Context, req *pbrequest.FreeFlinkJob) (*pbmodel.EmptyStruct, error)
  • func (s *JobManagerServer) GetFlinkJob(ctx context.Context, req *pbrequest.GetFlinkJob) (*pbresponse.GetFlinkJob, error)
  • func (s *JobManagerServer) InitFlinkJob(ctx context.Context, req *pbrequest.InitFlinkJob) (*pbresponse.InitFlinkJob, error)
  • func (s *JobManagerServer) SubmitFlinkJob(ctx context.Context, req *pbrequest.SubmitFlinkJob) (*pbresponse.SubmitFlinkJob, error)
  • func (s *JobManagerServer) ValidateFlinkJob(ctx context.Context, req *pbrequest.ValidateFlinkJob) (*pbresponse.ValidateFlinkJob, error)

Functions

func Start

func Start() (err error)

Types

type JobManagerServer

type JobManagerServer struct {
	pbsvcdeveloper.UnimplementedJobManageServer
	// contains filtered or unexported fields
}

func NewJobManagerServer

func NewJobManagerServer(service *service.JobManagerService) *JobManagerServer

func (*JobManagerServer) CancelFlinkJob

func (s *JobManagerServer) CancelFlinkJob(ctx context.Context, req *pbrequest.CancelFlinkJob) (*pbmodel.EmptyStruct, error)

func (*JobManagerServer) FreeFlinkJob

func (s *JobManagerServer) FreeFlinkJob(ctx context.Context, req *pbrequest.FreeFlinkJob) (*pbmodel.EmptyStruct, error)

func (*JobManagerServer) GetFlinkJob

func (s *JobManagerServer) GetFlinkJob(ctx context.Context, req *pbrequest.GetFlinkJob) (*pbresponse.GetFlinkJob, error)

func (*JobManagerServer) InitFlinkJob

func (s *JobManagerServer) InitFlinkJob(ctx context.Context, req *pbrequest.InitFlinkJob) (*pbresponse.InitFlinkJob, error)

func (*JobManagerServer) SubmitFlinkJob

func (s *JobManagerServer) SubmitFlinkJob(ctx context.Context, req *pbrequest.SubmitFlinkJob) (*pbresponse.SubmitFlinkJob, error)

func (*JobManagerServer) ValidateFlinkJob

func (s *JobManagerServer) ValidateFlinkJob(ctx context.Context, req *pbrequest.ValidateFlinkJob) (*pbresponse.ValidateFlinkJob, error)