Documentation ¶
Index ¶
- Variables
- type ActionType
- type BomberStatusChange
- func (*BomberStatusChange) Descriptor() ([]byte, []int)
- func (m *BomberStatusChange) GetBomberId() string
- func (m *BomberStatusChange) GetIp() string
- func (m *BomberStatusChange) GetStatusBomber() StatusBomber
- func (m *BomberStatusChange) Marshal() (dAtA []byte, err error)
- func (m *BomberStatusChange) MarshalTo(dAtA []byte) (int, error)
- func (m *BomberStatusChange) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BomberStatusChange) ProtoMessage()
- func (m *BomberStatusChange) Reset()
- func (m *BomberStatusChange) Size() (n int)
- func (m *BomberStatusChange) String() string
- func (m *BomberStatusChange) Unmarshal(dAtA []byte) error
- func (m *BomberStatusChange) XXX_DiscardUnknown()
- func (m *BomberStatusChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BomberStatusChange) XXX_Merge(src proto.Message)
- func (m *BomberStatusChange) XXX_Size() int
- func (m *BomberStatusChange) XXX_Unmarshal(b []byte) error
- type StatusBomber
- type TaskAction
- func (*TaskAction) Descriptor() ([]byte, []int)
- func (m *TaskAction) GetAction() ActionType
- func (m *TaskAction) GetTaskId() string
- func (m *TaskAction) Marshal() (dAtA []byte, err error)
- func (m *TaskAction) MarshalTo(dAtA []byte) (int, error)
- func (m *TaskAction) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TaskAction) ProtoMessage()
- func (m *TaskAction) Reset()
- func (m *TaskAction) Size() (n int)
- func (m *TaskAction) String() string
- func (m *TaskAction) Unmarshal(dAtA []byte) error
- func (m *TaskAction) XXX_DiscardUnknown()
- func (m *TaskAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskAction) XXX_Merge(src proto.Message)
- func (m *TaskAction) XXX_Size() int
- func (m *TaskAction) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthStatusChanger = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowStatusChanger = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupStatusChanger = fmt.Errorf("proto: unexpected end of group") )
View Source
var ( ErrInvalidLengthTaskAction = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTaskAction = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTaskAction = fmt.Errorf("proto: unexpected end of group") )
View Source
var ActionType_name = map[int32]string{
0: "START",
1: "STOP",
}
View Source
var ActionType_value = map[string]int32{
"START": 0,
"STOP": 1,
}
View Source
var StatusBomber_name = map[int32]string{
0: "DOWN",
1: "UP",
2: "WORKING",
3: "PREPARING_DATA",
}
View Source
var StatusBomber_value = map[string]int32{
"DOWN": 0,
"UP": 1,
"WORKING": 2,
"PREPARING_DATA": 3,
}
Functions ¶
This section is empty.
Types ¶
type ActionType ¶ added in v0.2.2
type ActionType int32
const ( ActionType_START ActionType = 0 ActionType_STOP ActionType = 1 )
func (ActionType) EnumDescriptor ¶ added in v0.2.2
func (ActionType) EnumDescriptor() ([]byte, []int)
func (ActionType) String ¶ added in v0.2.2
func (x ActionType) String() string
type BomberStatusChange ¶
type BomberStatusChange struct { BomberId string `protobuf:"bytes,1,opt,name=bomberId,proto3" json:"bomberId,omitempty"` Ip string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"` StatusBomber StatusBomber `protobuf:"varint,3,opt,name=statusBomber,proto3,enum=contracts.system.StatusBomber" json:"statusBomber,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
send to main bomber server
func (*BomberStatusChange) Descriptor ¶
func (*BomberStatusChange) Descriptor() ([]byte, []int)
func (*BomberStatusChange) GetBomberId ¶
func (m *BomberStatusChange) GetBomberId() string
func (*BomberStatusChange) GetIp ¶
func (m *BomberStatusChange) GetIp() string
func (*BomberStatusChange) GetStatusBomber ¶
func (m *BomberStatusChange) GetStatusBomber() StatusBomber
func (*BomberStatusChange) Marshal ¶
func (m *BomberStatusChange) Marshal() (dAtA []byte, err error)
func (*BomberStatusChange) MarshalTo ¶
func (m *BomberStatusChange) MarshalTo(dAtA []byte) (int, error)
func (*BomberStatusChange) MarshalToSizedBuffer ¶
func (m *BomberStatusChange) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BomberStatusChange) ProtoMessage ¶
func (*BomberStatusChange) ProtoMessage()
func (*BomberStatusChange) Reset ¶
func (m *BomberStatusChange) Reset()
func (*BomberStatusChange) Size ¶
func (m *BomberStatusChange) Size() (n int)
func (*BomberStatusChange) String ¶
func (m *BomberStatusChange) String() string
func (*BomberStatusChange) Unmarshal ¶
func (m *BomberStatusChange) Unmarshal(dAtA []byte) error
func (*BomberStatusChange) XXX_DiscardUnknown ¶
func (m *BomberStatusChange) XXX_DiscardUnknown()
func (*BomberStatusChange) XXX_Marshal ¶
func (m *BomberStatusChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BomberStatusChange) XXX_Merge ¶
func (m *BomberStatusChange) XXX_Merge(src proto.Message)
func (*BomberStatusChange) XXX_Size ¶
func (m *BomberStatusChange) XXX_Size() int
func (*BomberStatusChange) XXX_Unmarshal ¶
func (m *BomberStatusChange) XXX_Unmarshal(b []byte) error
type StatusBomber ¶
type StatusBomber int32
const ( StatusBomber_DOWN StatusBomber = 0 StatusBomber_UP StatusBomber = 1 StatusBomber_WORKING StatusBomber = 2 StatusBomber_PREPARING_DATA StatusBomber = 3 )
func (StatusBomber) EnumDescriptor ¶
func (StatusBomber) EnumDescriptor() ([]byte, []int)
func (StatusBomber) String ¶
func (x StatusBomber) String() string
type TaskAction ¶ added in v0.2.2
type TaskAction struct { TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"` Action ActionType `protobuf:"varint,2,opt,name=action,proto3,enum=contracts.system.ActionType" json:"action,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
send to main bomber server
func (*TaskAction) Descriptor ¶ added in v0.2.2
func (*TaskAction) Descriptor() ([]byte, []int)
func (*TaskAction) GetAction ¶ added in v0.2.2
func (m *TaskAction) GetAction() ActionType
func (*TaskAction) GetTaskId ¶ added in v0.2.2
func (m *TaskAction) GetTaskId() string
func (*TaskAction) Marshal ¶ added in v0.2.2
func (m *TaskAction) Marshal() (dAtA []byte, err error)
func (*TaskAction) MarshalTo ¶ added in v0.2.2
func (m *TaskAction) MarshalTo(dAtA []byte) (int, error)
func (*TaskAction) MarshalToSizedBuffer ¶ added in v0.2.2
func (m *TaskAction) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TaskAction) ProtoMessage ¶ added in v0.2.2
func (*TaskAction) ProtoMessage()
func (*TaskAction) Reset ¶ added in v0.2.2
func (m *TaskAction) Reset()
func (*TaskAction) Size ¶ added in v0.2.2
func (m *TaskAction) Size() (n int)
func (*TaskAction) String ¶ added in v0.2.2
func (m *TaskAction) String() string
func (*TaskAction) Unmarshal ¶ added in v0.2.2
func (m *TaskAction) Unmarshal(dAtA []byte) error
func (*TaskAction) XXX_DiscardUnknown ¶ added in v0.2.2
func (m *TaskAction) XXX_DiscardUnknown()
func (*TaskAction) XXX_Marshal ¶ added in v0.2.2
func (m *TaskAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TaskAction) XXX_Merge ¶ added in v0.2.2
func (m *TaskAction) XXX_Merge(src proto.Message)
func (*TaskAction) XXX_Size ¶ added in v0.2.2
func (m *TaskAction) XXX_Size() int
func (*TaskAction) XXX_Unmarshal ¶ added in v0.2.2
func (m *TaskAction) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.