proto

package
v0.0.0-...-f66a8c4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 22, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ConfigService_SetConfig_FullMethodName = "/proto.ConfigService/SetConfig"
	ConfigService_GetConfig_FullMethodName = "/proto.ConfigService/GetConfig"
)
View Source 
const (
	StartProcess_Run_FullMethodName             = "/proto.StartProcess/Run"
	StartProcess_RunWithProgress_FullMethodName = "/proto.StartProcess/RunWithProgress"
)
View Source 
const (
	ProgressProcess_Run_FullMethodName = "/progress.ProgressProcess/Run"
)
View Source 
const (
	StopProcess_Run_FullMethodName = "/proto.StopProcess/Run"
)
View Source 
const (
	WatchProcess_Run_FullMethodName = "/proto.WatchProcess/Run"
)

Variables

View Source 
var ConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.ConfigService",
	HandlerType: (*ConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SetConfig",
			Handler:    _ConfigService_SetConfig_Handler,
		},
		{
			MethodName: "GetConfig",
			Handler:    _ConfigService_GetConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "lbot/proto/config.proto",
}

ConfigService_ServiceDesc is the grpc.ServiceDesc for ConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_lbot_proto_config_proto protoreflect.FileDescriptor
View Source 
var File_lbot_proto_stop_proto protoreflect.FileDescriptor
View Source 
var File_lbot_proto_watch_proto protoreflect.FileDescriptor
View Source 
var File_progress_proto protoreflect.FileDescriptor
View Source 
var File_start_proto protoreflect.FileDescriptor
View Source 
var ProgressProcess_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "progress.ProgressProcess",
	HandlerType: (*ProgressProcessServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Run",
			Handler:       _ProgressProcess_Run_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "progress.proto",
}

ProgressProcess_ServiceDesc is the grpc.ServiceDesc for ProgressProcess service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var StartProcess_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.StartProcess",
	HandlerType: (*StartProcessServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Run",
			Handler:    _StartProcess_Run_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RunWithProgress",
			Handler:       _StartProcess_RunWithProgress_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "start.proto",
}

StartProcess_ServiceDesc is the grpc.ServiceDesc for StartProcess service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var StopProcess_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.StopProcess",
	HandlerType: (*StopProcessServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Run",
			Handler:    _StopProcess_Run_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "lbot/proto/stop.proto",
}

StopProcess_ServiceDesc is the grpc.ServiceDesc for StopProcess service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var WatchProcess_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.WatchProcess",
	HandlerType: (*WatchProcessServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Run",
			Handler:       _WatchProcess_Run_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "lbot/proto/watch.proto",
}

WatchProcess_ServiceDesc is the grpc.ServiceDesc for WatchProcess service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterConfigServiceServer 

func RegisterConfigServiceServer(s grpc.ServiceRegistrar, srv ConfigServiceServer)

func RegisterProgressProcessServer 

func RegisterProgressProcessServer(s grpc.ServiceRegistrar, srv ProgressProcessServer)

func RegisterStartProcessServer 

func RegisterStartProcessServer(s grpc.ServiceRegistrar, srv StartProcessServer)

func RegisterStopProcessServer 

func RegisterStopProcessServer(s grpc.ServiceRegistrar, srv StopProcessServer)

func RegisterWatchProcessServer 

func RegisterWatchProcessServer(s grpc.ServiceRegistrar, srv WatchProcessServer)

Types

type AgentRequest 

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
}

func (*AgentRequest) Descriptor deprecated 

func (*AgentRequest) Descriptor() ([]byte, []int)

Deprecated: Use AgentRequest.ProtoReflect.Descriptor instead.

func (*AgentRequest) GetMetricsExportIntervalSeconds 

func (x *AgentRequest) GetMetricsExportIntervalSeconds() uint64

func (*AgentRequest) GetMetricsExportPort 

func (x *AgentRequest) GetMetricsExportPort() string

func (*AgentRequest) GetMetricsExportUrl 

func (x *AgentRequest) GetMetricsExportUrl() string

func (*AgentRequest) GetName 

func (x *AgentRequest) GetName() string

func (*AgentRequest) GetPort 

func (x *AgentRequest) GetPort() string

func (*AgentRequest) ProtoMessage 

func (*AgentRequest) ProtoMessage()

func (*AgentRequest) ProtoReflect 

func (x *AgentRequest) ProtoReflect() protoreflect.Message

func (*AgentRequest) Reset 

func (x *AgentRequest) Reset()

func (*AgentRequest) String 

func (x *AgentRequest) String() string

type ConfigRequest 

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
}

func (*ConfigRequest) Descriptor deprecated 

func (*ConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest.ProtoReflect.Descriptor instead.

func (*ConfigRequest) GetAgent 

func (x *ConfigRequest) GetAgent() *AgentRequest

func (*ConfigRequest) GetConnectionString 

func (x *ConfigRequest) GetConnectionString() string

func (*ConfigRequest) GetDebug 

func (x *ConfigRequest) GetDebug() bool

func (*ConfigRequest) GetJobs 

func (x *ConfigRequest) GetJobs() []*JobRequest

func (*ConfigRequest) GetSchemas 

func (x *ConfigRequest) GetSchemas() []*SchemaRequest

func (*ConfigRequest) ProtoMessage 

func (*ConfigRequest) ProtoMessage()

func (*ConfigRequest) ProtoReflect 

func (x *ConfigRequest) ProtoReflect() protoreflect.Message

func (*ConfigRequest) Reset 

func (x *ConfigRequest) Reset()

func (*ConfigRequest) String 

func (x *ConfigRequest) String() string

type ConfigResponse 

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
}

func (*ConfigResponse) Descriptor deprecated 

func (*ConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConfigResponse.ProtoReflect.Descriptor instead.

func (*ConfigResponse) GetAgent 

func (x *ConfigResponse) GetAgent() *AgentRequest

func (*ConfigResponse) GetConnectionString 

func (x *ConfigResponse) GetConnectionString() string

func (*ConfigResponse) GetDebug 

func (x *ConfigResponse) GetDebug() bool

func (*ConfigResponse) GetJobs 

func (x *ConfigResponse) GetJobs() []*JobRequest

func (*ConfigResponse) GetSchemas 

func (x *ConfigResponse) GetSchemas() []*SchemaRequest

func (*ConfigResponse) ProtoMessage 

func (*ConfigResponse) ProtoMessage()

func (*ConfigResponse) ProtoReflect 

func (x *ConfigResponse) ProtoReflect() protoreflect.Message

func (*ConfigResponse) Reset 

func (x *ConfigResponse) Reset()

func (*ConfigResponse) String 

func (x *ConfigResponse) String() string

type ConfigServiceClient 

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)
}

ConfigServiceClient is the client API for ConfigService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewConfigServiceClient 

func NewConfigServiceClient(cc grpc.ClientConnInterface) ConfigServiceClient

type ConfigServiceServer 

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

ConfigServiceServer is the server API for ConfigService service. All implementations must embed UnimplementedConfigServiceServer for forward compatibility

type JobRequest 

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
}

func (*JobRequest) Descriptor deprecated 

func (*JobRequest) Descriptor() ([]byte, []int)

Deprecated: Use JobRequest.ProtoReflect.Descriptor instead.

func (*JobRequest) GetBatchSize 

func (x *JobRequest) GetBatchSize() uint64

func (*JobRequest) GetCollection 

func (x *JobRequest) GetCollection() string

func (*JobRequest) GetConnections 

func (x *JobRequest) GetConnections() uint64

func (*JobRequest) GetDataSize 

func (x *JobRequest) GetDataSize() uint64

func (*JobRequest) GetDatabase 

func (x *JobRequest) GetDatabase() string

func (*JobRequest) GetDuration 

func (x *JobRequest) GetDuration() string

func (*JobRequest) GetFilter 

func (x *JobRequest) GetFilter() *anypb.Any

func (*JobRequest) GetName 

func (x *JobRequest) GetName() string

func (*JobRequest) GetOperations 

func (x *JobRequest) GetOperations() uint64

func (*JobRequest) GetPace 

func (x *JobRequest) GetPace() uint64

func (*JobRequest) GetSchema 

func (x *JobRequest) GetSchema() string

func (*JobRequest) GetTimeout 

func (x *JobRequest) GetTimeout() string

func (*JobRequest) GetType 

func (x *JobRequest) GetType() string

func (*JobRequest) ProtoMessage 

func (*JobRequest) ProtoMessage()

func (*JobRequest) ProtoReflect 

func (x *JobRequest) ProtoReflect() protoreflect.Message

func (*JobRequest) Reset 

func (x *JobRequest) Reset()

func (*JobRequest) String 

func (x *JobRequest) String() string

type ProgressProcessClient 

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

ProgressProcessClient is the client API for ProgressProcess service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewProgressProcessClient 

func NewProgressProcessClient(cc grpc.ClientConnInterface) ProgressProcessClient

type ProgressProcessServer 

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

ProgressProcessServer is the server API for ProgressProcess service. All implementations must embed UnimplementedProgressProcessServer for forward compatibility

type ProgressProcess_RunClient 

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

type ProgressProcess_RunServer 

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

type ProgressRequest 

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

func (*ProgressRequest) Descriptor deprecated 

func (*ProgressRequest) Descriptor() ([]byte, []int)

Deprecated: Use ProgressRequest.ProtoReflect.Descriptor instead.

func (*ProgressRequest) GetRefreshInterval 

func (x *ProgressRequest) GetRefreshInterval() string

func (*ProgressRequest) ProtoMessage 

func (*ProgressRequest) ProtoMessage()

func (*ProgressRequest) ProtoReflect 

func (x *ProgressRequest) ProtoReflect() protoreflect.Message

func (*ProgressRequest) Reset 

func (x *ProgressRequest) Reset()

func (*ProgressRequest) String 

func (x *ProgressRequest) String() string

type ProgressResponse 

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
}

func (*ProgressResponse) Descriptor deprecated 

func (*ProgressResponse) Descriptor() ([]byte, []int)

Deprecated: Use ProgressResponse.ProtoReflect.Descriptor instead.

func (*ProgressResponse) GetDuration 

func (x *ProgressResponse) GetDuration() uint64

func (*ProgressResponse) GetErrorRate 

func (x *ProgressResponse) GetErrorRate() float32

func (*ProgressResponse) GetIsFinished 

func (x *ProgressResponse) GetIsFinished() bool

func (*ProgressResponse) GetJobName 

func (x *ProgressResponse) GetJobName() string

func (*ProgressResponse) GetRequestDuration 

func (x *ProgressResponse) GetRequestDuration() uint64

func (*ProgressResponse) GetRequestOperations 

func (x *ProgressResponse) GetRequestOperations() uint64

func (*ProgressResponse) GetRequests 

func (x *ProgressResponse) GetRequests() uint64

func (*ProgressResponse) GetRps 

func (x *ProgressResponse) GetRps() uint64

func (*ProgressResponse) ProtoMessage 

func (*ProgressResponse) ProtoMessage()

func (*ProgressResponse) ProtoReflect 

func (x *ProgressResponse) ProtoReflect() protoreflect.Message

func (*ProgressResponse) Reset 

func (x *ProgressResponse) Reset()

func (*ProgressResponse) String 

func (x *ProgressResponse) String() string

type SchemaRequest 

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
}

func (*SchemaRequest) Descriptor deprecated 

func (*SchemaRequest) Descriptor() ([]byte, []int)

Deprecated: Use SchemaRequest.ProtoReflect.Descriptor instead.

func (*SchemaRequest) GetCollection 

func (x *SchemaRequest) GetCollection() string

func (*SchemaRequest) GetDatabase 

func (x *SchemaRequest) GetDatabase() string

func (*SchemaRequest) GetName 

func (x *SchemaRequest) GetName() string

func (*SchemaRequest) GetSave 

func (x *SchemaRequest) GetSave() []string

func (*SchemaRequest) GetSchema 

func (x *SchemaRequest) GetSchema() *anypb.Any

func (*SchemaRequest) ProtoMessage 

func (*SchemaRequest) ProtoMessage()

func (*SchemaRequest) ProtoReflect 

func (x *SchemaRequest) ProtoReflect() protoreflect.Message

func (*SchemaRequest) Reset 

func (x *SchemaRequest) Reset()

func (*SchemaRequest) String 

func (x *SchemaRequest) String() string

type StartProcessClient 

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)
}

StartProcessClient is the client API for StartProcess service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStartProcessClient 

func NewStartProcessClient(cc grpc.ClientConnInterface) StartProcessClient

type StartProcessServer 

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

StartProcessServer is the server API for StartProcess service. All implementations must embed UnimplementedStartProcessServer for forward compatibility

type StartProcess_RunWithProgressClient 

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

type StartProcess_RunWithProgressServer 

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

type StartRequest 

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

func (*StartRequest) Descriptor deprecated 

func (*StartRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.

func (*StartRequest) GetWatch 

func (x *StartRequest) GetWatch() bool

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect 

func (x *StartRequest) ProtoReflect() protoreflect.Message

func (*StartRequest) Reset 

func (x *StartRequest) Reset()

func (*StartRequest) String 

func (x *StartRequest) String() string

type StartResponse 

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

func (*StartResponse) Descriptor deprecated 

func (*StartResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) ProtoReflect 

func (x *StartResponse) ProtoReflect() protoreflect.Message

func (*StartResponse) Reset 

func (x *StartResponse) Reset()

func (*StartResponse) String 

func (x *StartResponse) String() string

type StartWithProgressRequest 

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

func (*StartWithProgressRequest) Descriptor deprecated 

func (*StartWithProgressRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartWithProgressRequest.ProtoReflect.Descriptor instead.

func (*StartWithProgressRequest) GetRefreshInterval 

func (x *StartWithProgressRequest) GetRefreshInterval() string

func (*StartWithProgressRequest) ProtoMessage 

func (*StartWithProgressRequest) ProtoMessage()

func (*StartWithProgressRequest) ProtoReflect 

func (x *StartWithProgressRequest) ProtoReflect() protoreflect.Message

func (*StartWithProgressRequest) Reset 

func (x *StartWithProgressRequest) Reset()

func (*StartWithProgressRequest) String 

func (x *StartWithProgressRequest) String() string

type StopProcessClient 

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

StopProcessClient is the client API for StopProcess service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStopProcessClient 

func NewStopProcessClient(cc grpc.ClientConnInterface) StopProcessClient

type StopProcessServer 

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

StopProcessServer is the server API for StopProcess service. All implementations must embed UnimplementedStopProcessServer for forward compatibility

type StopRequest 

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

func (*StopRequest) Descriptor deprecated 

func (*StopRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) ProtoReflect 

func (x *StopRequest) ProtoReflect() protoreflect.Message

func (*StopRequest) Reset 

func (x *StopRequest) Reset()

func (*StopRequest) String 

func (x *StopRequest) String() string

type StopResponse 

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

func (*StopResponse) Descriptor deprecated 

func (*StopResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) ProtoReflect 

func (x *StopResponse) ProtoReflect() protoreflect.Message

func (*StopResponse) Reset 

func (x *StopResponse) Reset()

func (*StopResponse) String 

func (x *StopResponse) String() string

type UnimplementedConfigServiceServer 

type UnimplementedConfigServiceServer struct {
}

UnimplementedConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedConfigServiceServer) GetConfig 

func (UnimplementedConfigServiceServer) GetConfig(context.Context, *emptypb.Empty) (*ConfigResponse, error)

func (UnimplementedConfigServiceServer) SetConfig 

func (UnimplementedConfigServiceServer) SetConfig(context.Context, *ConfigRequest) (*ConfigResponse, error)

type UnimplementedProgressProcessServer 

type UnimplementedProgressProcessServer struct {
}

UnimplementedProgressProcessServer must be embedded to have forward compatible implementations.

func (UnimplementedProgressProcessServer) Run 

func (UnimplementedProgressProcessServer) Run(*ProgressRequest, ProgressProcess_RunServer) error

type UnimplementedStartProcessServer 

type UnimplementedStartProcessServer struct {
}

UnimplementedStartProcessServer must be embedded to have forward compatible implementations.

func (UnimplementedStartProcessServer) Run 

func (UnimplementedStartProcessServer) Run(context.Context, *StartRequest) (*StartResponse, error)

func (UnimplementedStartProcessServer) RunWithProgress 

func (UnimplementedStartProcessServer) RunWithProgress(*StartWithProgressRequest, StartProcess_RunWithProgressServer) error

type UnimplementedStopProcessServer 

type UnimplementedStopProcessServer struct{}

UnimplementedStopProcessServer must be embedded to have forward compatible implementations.

func (UnimplementedStopProcessServer) Run 

func (UnimplementedStopProcessServer) Run(context.Context, *StopRequest) (*StopResponse, error)

type UnimplementedWatchProcessServer 

type UnimplementedWatchProcessServer struct {
}

UnimplementedWatchProcessServer must be embedded to have forward compatible implementations.

func (UnimplementedWatchProcessServer) Run 

func (UnimplementedWatchProcessServer) Run(*WatchRequest, WatchProcess_RunServer) error

type UnsafeConfigServiceServer 

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

UnsafeConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConfigServiceServer will result in compilation errors.

type UnsafeProgressProcessServer 

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

UnsafeProgressProcessServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProgressProcessServer will result in compilation errors.

type UnsafeStartProcessServer 

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

UnsafeStartProcessServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StartProcessServer will result in compilation errors.

type UnsafeStopProcessServer 

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

UnsafeStopProcessServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StopProcessServer will result in compilation errors.

type UnsafeWatchProcessServer 

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

UnsafeWatchProcessServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WatchProcessServer will result in compilation errors.

type WatchProcessClient 

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

WatchProcessClient is the client API for WatchProcess service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewWatchProcessClient 

func NewWatchProcessClient(cc grpc.ClientConnInterface) WatchProcessClient

type WatchProcessServer 

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

WatchProcessServer is the server API for WatchProcess service. All implementations must embed UnimplementedWatchProcessServer for forward compatibility

type WatchProcess_RunClient 

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

type WatchProcess_RunServer 

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

type WatchRequest 

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

func (*WatchRequest) Descriptor deprecated 

func (*WatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) ProtoReflect 

func (x *WatchRequest) ProtoReflect() protoreflect.Message

func (*WatchRequest) Reset 

func (x *WatchRequest) Reset()

func (*WatchRequest) String 

func (x *WatchRequest) String() string

type WatchResponse 

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

func (*WatchResponse) Descriptor deprecated 

func (*WatchResponse) Descriptor() ([]byte, []int)

Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.

func (*WatchResponse) GetMessage 

func (x *WatchResponse) GetMessage() string

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) ProtoReflect 

func (x *WatchResponse) ProtoReflect() protoreflect.Message

func (*WatchResponse) Reset 

func (x *WatchResponse) Reset()

func (*WatchResponse) String 

func (x *WatchResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.