batch

Documentation

Index

• type ActionState
• type BatchRunner
• type LocalBatchService
  • func NewLocalBatchService() *LocalBatchService
  • func (l *LocalBatchService) GetState() State
  • func (l *LocalBatchService) HandleJob(stream batchpb.Job_HandleJobServer) error
  • func (l *LocalBatchService) SubmitJob(ctx context.Context, req *batchpb.JobSubmitRequest) (*batchpb.JobSubmitResponse, error)
  • func (l *LocalBatchService) SubscribeToAction(subscription func(ActionState))
  • func (l *LocalBatchService) SubscribeToState(subscriberFunction func(State))
• type State

Types

type ActionState

type ActionState struct {
	JobName string
	Payload string
	Success bool
}

type BatchRunner

type BatchRunner func(req *batchpb.JobSubmitRequest) error

type LocalBatchService

type LocalBatchService struct {
	*jobs.JobManager
	batchpb.UnimplementedBatchServer
	// contains filtered or unexported fields
}

func NewLocalBatchService

func NewLocalBatchService() *LocalBatchService

func (*LocalBatchService) GetState

func (l *LocalBatchService) GetState() State

func (*LocalBatchService) HandleJob

func (l *LocalBatchService) HandleJob(stream batchpb.Job_HandleJobServer) error

func (*LocalBatchService) SubmitJob

func (l *LocalBatchService) SubmitJob(ctx context.Context, req *batchpb.JobSubmitRequest) (*batchpb.JobSubmitResponse, error)

func (*LocalBatchService) SubscribeToAction

func (l *LocalBatchService) SubscribeToAction(subscription func(ActionState))

func (*LocalBatchService) SubscribeToState

func (l *LocalBatchService) SubscribeToState(subscriberFunction func(State))

type State

type State = map[jobName]map[serviceName]int