proto

type AgentRequest struct {
	Name                         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Port                         string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	MetricsExportUrl             string `protobuf:"bytes,3,opt,name=metrics_export_url,json=metricsExportUrl,proto3" json:"metrics_export_url,omitempty"`
	MetricsExportIntervalSeconds uint64 `` /* 150-byte string literal not displayed */
	MetricsExportPort            string `protobuf:"bytes,5,opt,name=metrics_export_port,json=metricsExportPort,proto3" json:"metrics_export_port,omitempty"`
	// contains filtered or unexported fields
}

type ConfigRequest struct {
	ConnectionString string           `protobuf:"bytes,1,opt,name=connection_string,json=connectionString,proto3" json:"connection_string,omitempty"`
	Agent            *AgentRequest    `protobuf:"bytes,2,opt,name=agent,proto3" json:"agent,omitempty"`
	Jobs             []*JobRequest    `protobuf:"bytes,3,rep,name=jobs,proto3" json:"jobs,omitempty"`
	Schemas          []*SchemaRequest `protobuf:"bytes,4,rep,name=schemas,proto3" json:"schemas,omitempty"`
	Debug            bool             `protobuf:"varint,5,opt,name=debug,proto3" json:"debug,omitempty"`
	// contains filtered or unexported fields
}

type ConfigResponse struct {
	ConnectionString string           `protobuf:"bytes,1,opt,name=connection_string,json=connectionString,proto3" json:"connection_string,omitempty"`
	Agent            *AgentRequest    `protobuf:"bytes,2,opt,name=agent,proto3" json:"agent,omitempty"`
	Jobs             []*JobRequest    `protobuf:"bytes,3,rep,name=jobs,proto3" json:"jobs,omitempty"`
	Schemas          []*SchemaRequest `protobuf:"bytes,4,rep,name=schemas,proto3" json:"schemas,omitempty"`
	Debug            bool             `protobuf:"varint,5,opt,name=debug,proto3" json:"debug,omitempty"`
	// contains filtered or unexported fields
}

type ConfigServiceClient interface {
	SetConfig(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (*ConfigResponse, error)
	GetConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ConfigResponse, error)
}

type ConfigServiceServer interface {
	SetConfig(context.Context, *ConfigRequest) (*ConfigResponse, error)
	GetConfig(context.Context, *emptypb.Empty) (*ConfigResponse, error)
	// contains filtered or unexported methods
}

type JobRequest struct {
	Name        string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Database    string     `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	Collection  string     `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"`
	Type        string     `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Schema      string     `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	Connections uint64     `protobuf:"varint,6,opt,name=connections,proto3" json:"connections,omitempty"`
	Pace        uint64     `protobuf:"varint,7,opt,name=pace,proto3" json:"pace,omitempty"`
	DataSize    uint64     `protobuf:"varint,8,opt,name=data_size,json=dataSize,proto3" json:"data_size,omitempty"`
	BatchSize   uint64     `protobuf:"varint,9,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	Duration    string     `protobuf:"bytes,10,opt,name=duration,proto3" json:"duration,omitempty"`
	Operations  uint64     `protobuf:"varint,11,opt,name=operations,proto3" json:"operations,omitempty"`
	Timeout     string     `protobuf:"bytes,12,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Filter      *anypb.Any `protobuf:"bytes,13,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ProgressProcessClient interface {
	Run(ctx context.Context, in *ProgressRequest, opts ...grpc.CallOption) (ProgressProcess_RunClient, error)
}

type ProgressProcessServer interface {
	Run(*ProgressRequest, ProgressProcess_RunServer) error
	// contains filtered or unexported methods
}

type ProgressProcess_RunClient interface {
	Recv() (*ProgressResponse, error)
	grpc.ClientStream
}

type ProgressProcess_RunServer interface {
	Send(*ProgressResponse) error
	grpc.ServerStream
}

type ProgressRequest struct {
	RefreshInterval string `protobuf:"bytes,1,opt,name=refresh_interval,json=refreshInterval,proto3" json:"refresh_interval,omitempty"`
	// contains filtered or unexported fields
}

type ProgressResponse struct {

	// change request total
	Requests   uint64  `protobuf:"varint,1,opt,name=requests,proto3" json:"requests,omitempty"`
	Duration   uint64  `protobuf:"varint,2,opt,name=duration,proto3" json:"duration,omitempty"`
	Rps        uint64  `protobuf:"varint,3,opt,name=rps,proto3" json:"rps,omitempty"`
	ErrorRate  float32 `protobuf:"fixed32,4,opt,name=error_rate,json=errorRate,proto3" json:"error_rate,omitempty"`
	IsFinished bool    `protobuf:"varint,5,opt,name=is_finished,json=isFinished,proto3" json:"is_finished,omitempty"`
	// workload data
	JobName           string `protobuf:"bytes,6,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	RequestDuration   uint64 `protobuf:"varint,7,opt,name=request_duration,json=requestDuration,proto3" json:"request_duration,omitempty"`
	RequestOperations uint64 `protobuf:"varint,8,opt,name=request_operations,json=requestOperations,proto3" json:"request_operations,omitempty"`
	// contains filtered or unexported fields
}

type SchemaRequest struct {
	Name       string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Database   string     `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	Collection string     `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"`
	Schema     *anypb.Any `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	Save       []string   `protobuf:"bytes,5,rep,name=save,proto3" json:"save,omitempty"`
	// contains filtered or unexported fields
}

type StartProcessClient interface {
	Run(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	RunWithProgress(ctx context.Context, in *StartWithProgressRequest, opts ...grpc.CallOption) (StartProcess_RunWithProgressClient, error)
}

type StartProcessServer interface {
	Run(context.Context, *StartRequest) (*StartResponse, error)
	RunWithProgress(*StartWithProgressRequest, StartProcess_RunWithProgressServer) error
	// contains filtered or unexported methods
}

type StartProcess_RunWithProgressClient interface {
	Recv() (*ProgressResponse, error)
	grpc.ClientStream
}

type StartProcess_RunWithProgressServer interface {
	Send(*ProgressResponse) error
	grpc.ServerStream
}

type StartRequest struct {
	Watch bool `protobuf:"varint,1,opt,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

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

type StartWithProgressRequest struct {
	RefreshInterval string `protobuf:"bytes,1,opt,name=refresh_interval,json=refreshInterval,proto3" json:"refresh_interval,omitempty"`
	// contains filtered or unexported fields
}

type StopProcessClient interface {
	Run(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
}

type StopProcessServer interface {
	Run(context.Context, *StopRequest) (*StopResponse, error)
	// contains filtered or unexported methods
}

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

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

type UnimplementedConfigServiceServer struct {
}

type UnimplementedProgressProcessServer struct {
}

type UnimplementedStartProcessServer struct {
}

type UnimplementedStopProcessServer struct{}

type UnimplementedWatchProcessServer struct {
}

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

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

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

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

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

type WatchProcessClient interface {
	Run(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (WatchProcess_RunClient, error)
}

type WatchProcessServer interface {
	Run(*WatchRequest, WatchProcess_RunServer) error
	// contains filtered or unexported methods
}

type WatchProcess_RunClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type WatchProcess_RunServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

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

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