scarab

type Job struct {
	Id      string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Profile string           `protobuf:"bytes,2,opt,name=profile,proto3" json:"profile,omitempty"`
	Version string           `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Args    []*JobArg        `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	Workers []*WorkerDetails `protobuf:"bytes,5,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

type JobArg struct {
	Name  string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value *JobArgValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type JobArgOption struct {
	Option   []string `protobuf:"bytes,1,rep,name=option,proto3" json:"option,omitempty"`
	Multiple bool     `protobuf:"varint,2,opt,name=multiple,proto3" json:"multiple,omitempty"`
	// contains filtered or unexported fields
}

type JobArgValue struct {

	// Types that are assignable to Value:
	//	*JobArgValue_String_
	//	*JobArgValue_Float
	//	*JobArgValue_Bool
	//	*JobArgValue_Option
	Value isJobArgValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type JobArgValue_Bool struct {
	Bool bool `protobuf:"varint,3,opt,name=bool,proto3,oneof"`
}

type JobArgValue_Float struct {
	Float float32 `protobuf:"fixed32,2,opt,name=float,proto3,oneof"`
}

type JobArgValue_Option struct {
	Option *JobArgOption `protobuf:"bytes,4,opt,name=option,proto3,oneof"`
}

type JobArgValue_String_ struct {
	String_ string `protobuf:"bytes,1,opt,name=string,proto3,oneof"`
}

type JobMetrics struct {
	Metrics []*_go.MetricFamily `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

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

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

type ListJobsResponse struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

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

type ListProfilesResponse struct {
	Registered []*RegisteredProfile `protobuf:"bytes,1,rep,name=registered,proto3" json:"registered,omitempty"`
	// contains filtered or unexported fields
}

type LoadMetrics struct {
	Metrics []*_go.MetricFamily `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

type ManagerClient interface {
	RegisterProfile(ctx context.Context, in *RegisterProfileRequest, opts ...grpc.CallOption) (Manager_RegisterProfileClient, error)
}

type ManagerServer interface {
	RegisterProfile(*RegisterProfileRequest, Manager_RegisterProfileServer) error
	// contains filtered or unexported methods
}

type ManagerUIClient interface {
	StartJob(ctx context.Context, in *StartJobRequest, opts ...grpc.CallOption) (*StartJobResponse, error)
	StopJob(ctx context.Context, in *StopJobRequest, opts ...grpc.CallOption) (*StopJobResponse, error)
	ListProfiles(ctx context.Context, in *ListProfilesRequest, opts ...grpc.CallOption) (*ListProfilesResponse, error)
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	WatchActiveJobs(ctx context.Context, in *WatchActiveJobsRequest, opts ...grpc.CallOption) (ManagerUI_WatchActiveJobsClient, error)
}

type ManagerUIServer interface {
	StartJob(context.Context, *StartJobRequest) (*StartJobResponse, error)
	StopJob(context.Context, *StopJobRequest) (*StopJobResponse, error)
	ListProfiles(context.Context, *ListProfilesRequest) (*ListProfilesResponse, error)
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	WatchActiveJobs(*WatchActiveJobsRequest, ManagerUI_WatchActiveJobsServer) error
	// contains filtered or unexported methods
}

type ManagerUI_WatchActiveJobsClient interface {
	Recv() (*WatchActiveJobsResponse, error)
	grpc.ClientStream
}

type ManagerUI_WatchActiveJobsServer interface {
	Send(*WatchActiveJobsResponse) error
	grpc.ServerStream
}

type Manager_RegisterProfileClient interface {
	Recv() (*KeepAlive, error)
	grpc.ClientStream
}

type Manager_RegisterProfileServer interface {
	Send(*KeepAlive) error
	grpc.ServerStream
}

type ProfileArg struct {
	Name        string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string       `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Default     *JobArgValue `protobuf:"bytes,3,opt,name=default,proto3" json:"default,omitempty"`
	// contains filtered or unexported fields
}

type ProfileSpec struct {
	Profile     string        `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	Version     string        `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Description string        `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Args        []*ProfileArg `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

type RegisterProfileRequest struct {
	Spec   *ProfileSpec   `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Worker *WorkerDetails `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	// contains filtered or unexported fields
}

type RegisteredProfile struct {
	Spec              *ProfileSpec         `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	FirstRegistration *timestamp.Timestamp `protobuf:"bytes,2,opt,name=firstRegistration,proto3" json:"firstRegistration,omitempty"`
	Workers           []*WorkerDetails     `protobuf:"bytes,3,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

type ReportLoadRequest struct {
	Interval float32 `protobuf:"fixed32,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

type RunProfileRequest struct {
	Profile  string    `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	Interval float32   `protobuf:"fixed32,2,opt,name=interval,proto3" json:"interval,omitempty"`
	MaxRate  float32   `protobuf:"fixed32,3,opt,name=maxRate,proto3" json:"maxRate,omitempty"`
	Users    uint64    `protobuf:"varint,4,opt,name=users,proto3" json:"users,omitempty"`
	Args     []*JobArg `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

type StartJobRequest struct {
	Profile string    `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	Version string    `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Users   uint64    `protobuf:"varint,3,opt,name=users,proto3" json:"users,omitempty"`
	MaxRate float32   `protobuf:"fixed32,4,opt,name=maxRate,proto3" json:"maxRate,omitempty"`
	Args    []*JobArg `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

type StartJobResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type StopJobRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

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

type UnimplementedManagerServer struct {
}

type UnimplementedManagerUIServer struct {
}

type UnimplementedWorkerServer struct {
}

type UnsafeManagerServer interface {
	// contains filtered or unexported methods
}

type UnsafeManagerUIServer interface {
	// contains filtered or unexported methods
}

type UnsafeWorkerServer interface {
	// contains filtered or unexported methods
}

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

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

type WorkerClient interface {
	ReportLoad(ctx context.Context, in *ReportLoadRequest, opts ...grpc.CallOption) (Worker_ReportLoadClient, error)
	RunProfile(ctx context.Context, opts ...grpc.CallOption) (Worker_RunProfileClient, error)
}

type WorkerDetails struct {
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type WorkerServer interface {
	ReportLoad(*ReportLoadRequest, Worker_ReportLoadServer) error
	RunProfile(Worker_RunProfileServer) error
	// contains filtered or unexported methods
}

type Worker_ReportLoadClient interface {
	Recv() (*LoadMetrics, error)
	grpc.ClientStream
}

type Worker_ReportLoadServer interface {
	Send(*LoadMetrics) error
	grpc.ServerStream
}

type Worker_RunProfileClient interface {
	Send(*RunProfileRequest) error
	Recv() (*JobMetrics, error)
	grpc.ClientStream
}

type Worker_RunProfileServer interface {
	Send(*JobMetrics) error
	Recv() (*RunProfileRequest, error)
	grpc.ServerStream
}