pb

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ExecuteTaskRequest_Command_name = map[int32]string{
	0: "START",
	1: "STOP",
}
View Source 
var ExecuteTaskRequest_Command_value = map[string]int32{
	"START": 0,
	"STOP":  1,
}
View Source 
var ExecuteTaskResponse_Status_name = map[int32]string{
	0: "SUCC",
	1: "FAIL",
}
View Source 
var ExecuteTaskResponse_Status_value = map[string]int32{
	"SUCC": 0,
	"FAIL": 1,
}
View Source 
var HeartBeatRequest_Task_Status_name = map[int32]string{
	0: "DONE",
	1: "RUNNING",
}
View Source 
var HeartBeatRequest_Task_Status_value = map[string]int32{
	"DONE":    0,
	"RUNNING": 1,
}
View Source 
var Protocol_name = map[int32]string{
	0: "UNKNOWN",
	1: "HTTP",
	2: "TCP",
	3: "UDP",
	4: "REDIS",
	5: "MYSQL",
	6: "MONGO",
	7: "GRPC",
	8: "THRIFT",
	9: "WEBSOCKET",
}
View Source 
var Protocol_value = map[string]int32{
	"UNKNOWN":   0,
	"HTTP":      1,
	"TCP":       2,
	"UDP":       3,
	"REDIS":     4,
	"MYSQL":     5,
	"MONGO":     6,
	"GRPC":      7,
	"THRIFT":    8,
	"WEBSOCKET": 9,
}

Functions

func RegisterSqueezeServiceServer 

func RegisterSqueezeServiceServer(s *grpc.Server, srv SqueezeServiceServer)

Types

type ExecuteTaskRequest 

type ExecuteTaskRequest struct {
	Cmd                  ExecuteTaskRequest_Command `protobuf:"varint,1,opt,name=cmd,proto3,enum=pb.ExecuteTaskRequest_Command" json:"cmd,omitempty"`
	Protocol             Protocol                   `protobuf:"varint,2,opt,name=protocol,proto3,enum=pb.Protocol" json:"protocol,omitempty"`
	Callback             string                     `protobuf:"bytes,3,opt,name=callback,proto3" json:"callback,omitempty"`
	Duration             uint32                     `protobuf:"varint,4,opt,name=duration,proto3" json:"duration,omitempty"`
	Id                   uint32                     `protobuf:"varint,5,opt,name=id,proto3" json:"id,omitempty"`
	Concurrency          uint32                     `protobuf:"varint,6,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	Requests             uint32                     `protobuf:"varint,7,opt,name=requests,proto3" json:"requests,omitempty"`
	RateLimit            uint32                     `protobuf:"varint,8,opt,name=rateLimit,proto3" json:"rateLimit,omitempty"`
	Data                 string                     `protobuf:"bytes,9,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

ExecuteTaskRequest describes the task information to be executed.

func (*ExecuteTaskRequest) Descriptor 

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

func (*ExecuteTaskRequest) GetCallback 

func (m *ExecuteTaskRequest) GetCallback() string

func (*ExecuteTaskRequest) GetCmd 

func (m *ExecuteTaskRequest) GetCmd() ExecuteTaskRequest_Command

func (*ExecuteTaskRequest) GetConcurrency added in v0.1.1 

func (m *ExecuteTaskRequest) GetConcurrency() uint32

func (*ExecuteTaskRequest) GetData added in v0.1.1 

func (m *ExecuteTaskRequest) GetData() string

func (*ExecuteTaskRequest) GetDuration 

func (m *ExecuteTaskRequest) GetDuration() uint32

func (*ExecuteTaskRequest) GetId 

func (m *ExecuteTaskRequest) GetId() uint32

func (*ExecuteTaskRequest) GetProtocol 

func (m *ExecuteTaskRequest) GetProtocol() Protocol

func (*ExecuteTaskRequest) GetRateLimit added in v0.1.1 

func (m *ExecuteTaskRequest) GetRateLimit() uint32

func (*ExecuteTaskRequest) GetRequests added in v0.1.1 

func (m *ExecuteTaskRequest) GetRequests() uint32

func (*ExecuteTaskRequest) ProtoMessage 

func (*ExecuteTaskRequest) ProtoMessage()

func (*ExecuteTaskRequest) Reset 

func (m *ExecuteTaskRequest) Reset()

func (*ExecuteTaskRequest) String 

func (m *ExecuteTaskRequest) String() string

func (*ExecuteTaskRequest) XXX_DiscardUnknown 

func (m *ExecuteTaskRequest) XXX_DiscardUnknown()

func (*ExecuteTaskRequest) XXX_Marshal 

func (m *ExecuteTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteTaskRequest) XXX_Merge 

func (dst *ExecuteTaskRequest) XXX_Merge(src proto.Message)

func (*ExecuteTaskRequest) XXX_Size 

func (m *ExecuteTaskRequest) XXX_Size() int

func (*ExecuteTaskRequest) XXX_Unmarshal 

func (m *ExecuteTaskRequest) XXX_Unmarshal(b []byte) error

type ExecuteTaskRequest_Command 

type ExecuteTaskRequest_Command int32
const (
	ExecuteTaskRequest_START ExecuteTaskRequest_Command = 0
	ExecuteTaskRequest_STOP  ExecuteTaskRequest_Command = 1
)

func (ExecuteTaskRequest_Command) EnumDescriptor 

func (ExecuteTaskRequest_Command) EnumDescriptor() ([]byte, []int)

func (ExecuteTaskRequest_Command) String 

func (x ExecuteTaskRequest_Command) String() string

type ExecuteTaskResponse 

type ExecuteTaskResponse struct {
	// Slave address
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// Task status
	Status ExecuteTaskResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=pb.ExecuteTaskResponse_Status" json:"status,omitempty"`
	// When status is equal to FAIL, error will be set
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// Task results in json format
	Data                 string   `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ExecuteTaskResponse for ExecuteTaskRequest, is used to report the results of this execution task.

func (*ExecuteTaskResponse) Descriptor 

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

func (*ExecuteTaskResponse) GetAddr 

func (m *ExecuteTaskResponse) GetAddr() string

func (*ExecuteTaskResponse) GetData 

func (m *ExecuteTaskResponse) GetData() string

func (*ExecuteTaskResponse) GetError 

func (m *ExecuteTaskResponse) GetError() string

func (*ExecuteTaskResponse) GetStatus 

func (m *ExecuteTaskResponse) GetStatus() ExecuteTaskResponse_Status

func (*ExecuteTaskResponse) ProtoMessage 

func (*ExecuteTaskResponse) ProtoMessage()

func (*ExecuteTaskResponse) Reset 

func (m *ExecuteTaskResponse) Reset()

func (*ExecuteTaskResponse) String 

func (m *ExecuteTaskResponse) String() string

func (*ExecuteTaskResponse) XXX_DiscardUnknown 

func (m *ExecuteTaskResponse) XXX_DiscardUnknown()

func (*ExecuteTaskResponse) XXX_Marshal 

func (m *ExecuteTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteTaskResponse) XXX_Merge 

func (dst *ExecuteTaskResponse) XXX_Merge(src proto.Message)

func (*ExecuteTaskResponse) XXX_Size 

func (m *ExecuteTaskResponse) XXX_Size() int

func (*ExecuteTaskResponse) XXX_Unmarshal 

func (m *ExecuteTaskResponse) XXX_Unmarshal(b []byte) error

type ExecuteTaskResponse_Status 

type ExecuteTaskResponse_Status int32
const (
	ExecuteTaskResponse_SUCC ExecuteTaskResponse_Status = 0
	ExecuteTaskResponse_FAIL ExecuteTaskResponse_Status = 1
)

func (ExecuteTaskResponse_Status) EnumDescriptor 

func (ExecuteTaskResponse_Status) EnumDescriptor() ([]byte, []int)

func (ExecuteTaskResponse_Status) String 

func (x ExecuteTaskResponse_Status) String() string

type HeartBeatRequest 

type HeartBeatRequest struct {
	Task                 *HeartBeatRequest_Task      `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Info                 *HeartBeatRequest_SlaveInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

HeartBeatRequest describes the tasks status on the slave and the information about the slave & host.

func (*HeartBeatRequest) Descriptor 

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

func (*HeartBeatRequest) GetInfo 

func (m *HeartBeatRequest) GetInfo() *HeartBeatRequest_SlaveInfo

func (*HeartBeatRequest) GetTask 

func (m *HeartBeatRequest) GetTask() *HeartBeatRequest_Task

func (*HeartBeatRequest) ProtoMessage 

func (*HeartBeatRequest) ProtoMessage()

func (*HeartBeatRequest) Reset 

func (m *HeartBeatRequest) Reset()

func (*HeartBeatRequest) String 

func (m *HeartBeatRequest) String() string

func (*HeartBeatRequest) XXX_DiscardUnknown 

func (m *HeartBeatRequest) XXX_DiscardUnknown()

func (*HeartBeatRequest) XXX_Marshal 

func (m *HeartBeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeartBeatRequest) XXX_Merge 

func (dst *HeartBeatRequest) XXX_Merge(src proto.Message)

func (*HeartBeatRequest) XXX_Size 

func (m *HeartBeatRequest) XXX_Size() int

func (*HeartBeatRequest) XXX_Unmarshal 

func (m *HeartBeatRequest) XXX_Unmarshal(b []byte) error

type HeartBeatRequest_SlaveInfo 

type HeartBeatRequest_SlaveInfo struct {
	GrpcPort             uint32   `protobuf:"varint,1,opt,name=grpcPort,proto3" json:"grpcPort,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HeartBeatRequest_SlaveInfo) Descriptor 

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

func (*HeartBeatRequest_SlaveInfo) GetGrpcPort 

func (m *HeartBeatRequest_SlaveInfo) GetGrpcPort() uint32

func (*HeartBeatRequest_SlaveInfo) ProtoMessage 

func (*HeartBeatRequest_SlaveInfo) ProtoMessage()

func (*HeartBeatRequest_SlaveInfo) Reset 

func (m *HeartBeatRequest_SlaveInfo) Reset()

func (*HeartBeatRequest_SlaveInfo) String 

func (m *HeartBeatRequest_SlaveInfo) String() string

func (*HeartBeatRequest_SlaveInfo) XXX_DiscardUnknown 

func (m *HeartBeatRequest_SlaveInfo) XXX_DiscardUnknown()

func (*HeartBeatRequest_SlaveInfo) XXX_Marshal 

func (m *HeartBeatRequest_SlaveInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeartBeatRequest_SlaveInfo) XXX_Merge 

func (dst *HeartBeatRequest_SlaveInfo) XXX_Merge(src proto.Message)

func (*HeartBeatRequest_SlaveInfo) XXX_Size 

func (m *HeartBeatRequest_SlaveInfo) XXX_Size() int

func (*HeartBeatRequest_SlaveInfo) XXX_Unmarshal 

func (m *HeartBeatRequest_SlaveInfo) XXX_Unmarshal(b []byte) error

type HeartBeatRequest_Task 

type HeartBeatRequest_Task struct {
	Id                   uint32                       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Status               HeartBeatRequest_Task_Status `protobuf:"varint,2,opt,name=status,proto3,enum=pb.HeartBeatRequest_Task_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*HeartBeatRequest_Task) Descriptor 

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

func (*HeartBeatRequest_Task) GetId 

func (m *HeartBeatRequest_Task) GetId() uint32

func (*HeartBeatRequest_Task) GetStatus 

func (m *HeartBeatRequest_Task) GetStatus() HeartBeatRequest_Task_Status

func (*HeartBeatRequest_Task) ProtoMessage 

func (*HeartBeatRequest_Task) ProtoMessage()

func (*HeartBeatRequest_Task) Reset 

func (m *HeartBeatRequest_Task) Reset()

func (*HeartBeatRequest_Task) String 

func (m *HeartBeatRequest_Task) String() string

func (*HeartBeatRequest_Task) XXX_DiscardUnknown 

func (m *HeartBeatRequest_Task) XXX_DiscardUnknown()

func (*HeartBeatRequest_Task) XXX_Marshal 

func (m *HeartBeatRequest_Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeartBeatRequest_Task) XXX_Merge 

func (dst *HeartBeatRequest_Task) XXX_Merge(src proto.Message)

func (*HeartBeatRequest_Task) XXX_Size 

func (m *HeartBeatRequest_Task) XXX_Size() int

func (*HeartBeatRequest_Task) XXX_Unmarshal 

func (m *HeartBeatRequest_Task) XXX_Unmarshal(b []byte) error

type HeartBeatRequest_Task_Status 

type HeartBeatRequest_Task_Status int32
const (
	HeartBeatRequest_Task_DONE    HeartBeatRequest_Task_Status = 0
	HeartBeatRequest_Task_RUNNING HeartBeatRequest_Task_Status = 1
)

func (HeartBeatRequest_Task_Status) EnumDescriptor 

func (HeartBeatRequest_Task_Status) EnumDescriptor() ([]byte, []int)

func (HeartBeatRequest_Task_Status) String 

func (x HeartBeatRequest_Task_Status) String() string

type HeartBeatResponse 

type HeartBeatResponse struct {
	Tasks                []*TaskRequest `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

HeartBeatResponse for HeartBeatRequest, is used to send tasks from master to slave. !!!Send task is not yet supported!!!

func (*HeartBeatResponse) Descriptor 

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

func (*HeartBeatResponse) GetTasks 

func (m *HeartBeatResponse) GetTasks() []*TaskRequest

func (*HeartBeatResponse) ProtoMessage 

func (*HeartBeatResponse) ProtoMessage()

func (*HeartBeatResponse) Reset 

func (m *HeartBeatResponse) Reset()

func (*HeartBeatResponse) String 

func (m *HeartBeatResponse) String() string

func (*HeartBeatResponse) XXX_DiscardUnknown 

func (m *HeartBeatResponse) XXX_DiscardUnknown()

func (*HeartBeatResponse) XXX_Marshal 

func (m *HeartBeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeartBeatResponse) XXX_Merge 

func (dst *HeartBeatResponse) XXX_Merge(src proto.Message)

func (*HeartBeatResponse) XXX_Size 

func (m *HeartBeatResponse) XXX_Size() int

func (*HeartBeatResponse) XXX_Unmarshal 

func (m *HeartBeatResponse) XXX_Unmarshal(b []byte) error

type Protocol 

type Protocol int32

All supported protocols 

const (
	Protocol_UNKNOWN   Protocol = 0
	Protocol_HTTP      Protocol = 1
	Protocol_TCP       Protocol = 2
	Protocol_UDP       Protocol = 3
	Protocol_REDIS     Protocol = 4
	Protocol_MYSQL     Protocol = 5
	Protocol_MONGO     Protocol = 6
	Protocol_GRPC      Protocol = 7
	Protocol_THRIFT    Protocol = 8
	Protocol_WEBSOCKET Protocol = 9
)

func (Protocol) EnumDescriptor 

func (Protocol) EnumDescriptor() ([]byte, []int)

func (Protocol) String 

func (x Protocol) String() string

type SqueezeServiceClient 

type SqueezeServiceClient interface {
	// ExecuteTask is used to perform tasks on the slave node
	ExecuteTask(ctx context.Context, in *ExecuteTaskRequest, opts ...grpc.CallOption) (*ExecuteTaskResponse, error)
	// HeartBeat is used to report task status to master node
	HeartBeat(ctx context.Context, opts ...grpc.CallOption) (SqueezeService_HeartBeatClient, error)
}

SqueezeServiceClient is the client API for SqueezeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSqueezeServiceClient 

func NewSqueezeServiceClient(cc *grpc.ClientConn) SqueezeServiceClient

type SqueezeServiceServer 

type SqueezeServiceServer interface {
	// ExecuteTask is used to perform tasks on the slave node
	ExecuteTask(context.Context, *ExecuteTaskRequest) (*ExecuteTaskResponse, error)
	// HeartBeat is used to report task status to master node
	HeartBeat(SqueezeService_HeartBeatServer) error
}

SqueezeServiceServer is the server API for SqueezeService service.

type SqueezeService_HeartBeatClient 

type SqueezeService_HeartBeatClient interface {
	Send(*HeartBeatRequest) error
	Recv() (*HeartBeatResponse, error)
	grpc.ClientStream
}

type SqueezeService_HeartBeatServer 

type SqueezeService_HeartBeatServer interface {
	Send(*HeartBeatResponse) error
	Recv() (*HeartBeatRequest, error)
	grpc.ServerStream
}

type TaskRequest 

type TaskRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskRequest) Descriptor 

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

func (*TaskRequest) ProtoMessage 

func (*TaskRequest) ProtoMessage()

func (*TaskRequest) Reset 

func (m *TaskRequest) Reset()

func (*TaskRequest) String 

func (m *TaskRequest) String() string

func (*TaskRequest) XXX_DiscardUnknown 

func (m *TaskRequest) XXX_DiscardUnknown()

func (*TaskRequest) XXX_Marshal 

func (m *TaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskRequest) XXX_Merge 

func (dst *TaskRequest) XXX_Merge(src proto.Message)

func (*TaskRequest) XXX_Size 

func (m *TaskRequest) XXX_Size() int

func (*TaskRequest) XXX_Unmarshal 

func (m *TaskRequest) XXX_Unmarshal(b []byte) error

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.