Documentation
¶
Index ¶
- Variables
- func RegisterBuildServiceServer(s *grpc.Server, srv BuildServiceServer)
- func RegisterControlServiceServer(s *grpc.Server, srv ControlServiceServer)
- func RegisterInjectServiceServer(s *grpc.Server, srv InjectServiceServer)
- func RegisterLogServiceServer(s *grpc.Server, srv LogServiceServer)
- func RegisterMonitorServiceServer(s *grpc.Server, srv MonitorServiceServer)
- func RegisterProxyServiceServer(s *grpc.Server, srv ProxyServiceServer)
- func RegisterTioDeployCommServiceServer(s *grpc.Server, srv TioDeployCommServiceServer)
- func RegisterTioDeployServiceServer(s *grpc.Server, srv TioDeployServiceServer)
- type BuildReply
- func (*BuildReply) Descriptor() ([]byte, []int)
- func (m *BuildReply) GetCode() int32
- func (m *BuildReply) GetMsg() string
- func (*BuildReply) ProtoMessage()
- func (m *BuildReply) Reset()
- func (m *BuildReply) String() string
- func (m *BuildReply) XXX_DiscardUnknown()
- func (m *BuildReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BuildReply) XXX_Merge(src proto.Message)
- func (m *BuildReply) XXX_Size() int
- func (m *BuildReply) XXX_Unmarshal(b []byte) error
- type BuildServiceClient
- type BuildServiceServer
- type BuildStatus
- func (*BuildStatus) Descriptor() ([]byte, []int)
- func (m *BuildStatus) GetApi() string
- func (m *BuildStatus) GetImage() string
- func (m *BuildStatus) GetName() string
- func (m *BuildStatus) GetRate() int32
- func (m *BuildStatus) GetRaw() string
- func (m *BuildStatus) GetSid() int32
- func (m *BuildStatus) GetStatus() JobStatus
- func (m *BuildStatus) GetStype() string
- func (m *BuildStatus) GetUser() string
- func (m *BuildStatus) GetVersion() string
- func (*BuildStatus) ProtoMessage()
- func (m *BuildStatus) Reset()
- func (m *BuildStatus) String() string
- func (m *BuildStatus) XXX_DiscardUnknown()
- func (m *BuildStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BuildStatus) XXX_Merge(src proto.Message)
- func (m *BuildStatus) XXX_Size() int
- func (m *BuildStatus) XXX_Unmarshal(b []byte) error
- type CommonRespCode
- type ControlServiceClient
- type ControlServiceServer
- type ControlService_GetLogsClient
- type ControlService_GetLogsServer
- type DeployRequest
- func (*DeployRequest) Descriptor() ([]byte, []int)
- func (m *DeployRequest) GetConfig() string
- func (m *DeployRequest) GetImage() string
- func (m *DeployRequest) GetInstanceMultiple() float64
- func (m *DeployRequest) GetInstanceNum() int32
- func (m *DeployRequest) GetName() string
- func (m *DeployRequest) GetSid() int32
- func (m *DeployRequest) GetStype() int32
- func (*DeployRequest) ProtoMessage()
- func (m *DeployRequest) Reset()
- func (m *DeployRequest) String() string
- func (m *DeployRequest) XXX_DiscardUnknown()
- func (m *DeployRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeployRequest) XXX_Merge(src proto.Message)
- func (m *DeployRequest) XXX_Size() int
- func (m *DeployRequest) XXX_Unmarshal(b []byte) error
- type InjectRequest
- func (*InjectRequest) Descriptor() ([]byte, []int)
- func (m *InjectRequest) GetAddress() string
- func (m *InjectRequest) GetName() string
- func (*InjectRequest) ProtoMessage()
- func (m *InjectRequest) Reset()
- func (m *InjectRequest) String() string
- func (m *InjectRequest) XXX_DiscardUnknown()
- func (m *InjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InjectRequest) XXX_Merge(src proto.Message)
- func (m *InjectRequest) XXX_Size() int
- func (m *InjectRequest) XXX_Unmarshal(b []byte) error
- type InjectServiceClient
- type InjectServiceServer
- type JobStatus
- type LogServiceClient
- type LogServiceServer
- type LogService_GetLogsClient
- type LogService_GetLogsServer
- type MonitorScalaRequest
- func (*MonitorScalaRequest) Descriptor() ([]byte, []int)
- func (m *MonitorScalaRequest) GetName() string
- func (m *MonitorScalaRequest) GetNum() int32
- func (*MonitorScalaRequest) ProtoMessage()
- func (m *MonitorScalaRequest) Reset()
- func (m *MonitorScalaRequest) String() string
- func (m *MonitorScalaRequest) XXX_DiscardUnknown()
- func (m *MonitorScalaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MonitorScalaRequest) XXX_Merge(src proto.Message)
- func (m *MonitorScalaRequest) XXX_Size() int
- func (m *MonitorScalaRequest) XXX_Unmarshal(b []byte) error
- type MonitorServiceClient
- type MonitorServiceServer
- type ProxyEndpointRequest
- func (*ProxyEndpointRequest) Descriptor() ([]byte, []int)
- func (m *ProxyEndpointRequest) GetEndpoint() string
- func (m *ProxyEndpointRequest) GetName() string
- func (*ProxyEndpointRequest) ProtoMessage()
- func (m *ProxyEndpointRequest) Reset()
- func (m *ProxyEndpointRequest) String() string
- func (m *ProxyEndpointRequest) XXX_DiscardUnknown()
- func (m *ProxyEndpointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProxyEndpointRequest) XXX_Merge(src proto.Message)
- func (m *ProxyEndpointRequest) XXX_Size() int
- func (m *ProxyEndpointRequest) XXX_Unmarshal(b []byte) error
- type ProxyServiceClient
- type ProxyServiceServer
- type Reply
- func (*Reply) Descriptor() ([]byte, []int)
- func (m *Reply) GetCode() int32
- func (m *Reply) GetMsg() string
- func (*Reply) ProtoMessage()
- func (m *Reply) Reset()
- func (m *Reply) String() string
- func (m *Reply) XXX_DiscardUnknown()
- func (m *Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Reply) XXX_Merge(src proto.Message)
- func (m *Reply) XXX_Size() int
- func (m *Reply) XXX_Unmarshal(b []byte) error
- type Request
- func (*Request) Descriptor() ([]byte, []int)
- func (m *Request) GetAddress() string
- func (m *Request) GetBuildType() string
- func (m *Request) GetName() string
- func (m *Request) GetSid() int32
- func (*Request) ProtoMessage()
- func (m *Request) Reset()
- func (m *Request) String() string
- func (m *Request) XXX_DiscardUnknown()
- func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Request) XXX_Merge(src proto.Message)
- func (m *Request) XXX_Size() int
- func (m *Request) XXX_Unmarshal(b []byte) error
- type SrvMeta
- func (*SrvMeta) Descriptor() ([]byte, []int)
- func (m *SrvMeta) GetEnv() map[string]string
- func (m *SrvMeta) GetImage() string
- func (m *SrvMeta) GetName() string
- func (*SrvMeta) ProtoMessage()
- func (m *SrvMeta) Reset()
- func (m *SrvMeta) String() string
- func (m *SrvMeta) XXX_DiscardUnknown()
- func (m *SrvMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SrvMeta) XXX_Merge(src proto.Message)
- func (m *SrvMeta) XXX_Size() int
- func (m *SrvMeta) XXX_Unmarshal(b []byte) error
- type TioAgentReply
- func (*TioAgentReply) Descriptor() ([]byte, []int)
- func (m *TioAgentReply) GetAddress() string
- func (m *TioAgentReply) GetCode() CommonRespCode
- func (*TioAgentReply) ProtoMessage()
- func (m *TioAgentReply) Reset()
- func (m *TioAgentReply) String() string
- func (m *TioAgentReply) XXX_DiscardUnknown()
- func (m *TioAgentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioAgentReply) XXX_Merge(src proto.Message)
- func (m *TioAgentReply) XXX_Size() int
- func (m *TioAgentReply) XXX_Unmarshal(b []byte) error
- type TioAgentRequest
- func (*TioAgentRequest) Descriptor() ([]byte, []int)
- func (m *TioAgentRequest) GetName() string
- func (*TioAgentRequest) ProtoMessage()
- func (m *TioAgentRequest) Reset()
- func (m *TioAgentRequest) String() string
- func (m *TioAgentRequest) XXX_DiscardUnknown()
- func (m *TioAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioAgentRequest) XXX_Merge(src proto.Message)
- func (m *TioAgentRequest) XXX_Size() int
- func (m *TioAgentRequest) XXX_Unmarshal(b []byte) error
- type TioBuildQueryReply
- func (*TioBuildQueryReply) Descriptor() ([]byte, []int)
- func (m *TioBuildQueryReply) GetBuilds() []*BuildStatus
- func (m *TioBuildQueryReply) GetCode() CommonRespCode
- func (*TioBuildQueryReply) ProtoMessage()
- func (m *TioBuildQueryReply) Reset()
- func (m *TioBuildQueryReply) String() string
- func (m *TioBuildQueryReply) XXX_DiscardUnknown()
- func (m *TioBuildQueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioBuildQueryReply) XXX_Merge(src proto.Message)
- func (m *TioBuildQueryReply) XXX_Size() int
- func (m *TioBuildQueryReply) XXX_Unmarshal(b []byte) error
- type TioBuildQueryRequest
- func (*TioBuildQueryRequest) Descriptor() ([]byte, []int)
- func (m *TioBuildQueryRequest) GetLimit() int32
- func (m *TioBuildQueryRequest) GetName() string
- func (m *TioBuildQueryRequest) GetUid() int32
- func (*TioBuildQueryRequest) ProtoMessage()
- func (m *TioBuildQueryRequest) Reset()
- func (m *TioBuildQueryRequest) String() string
- func (m *TioBuildQueryRequest) XXX_DiscardUnknown()
- func (m *TioBuildQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioBuildQueryRequest) XXX_Merge(src proto.Message)
- func (m *TioBuildQueryRequest) XXX_Size() int
- func (m *TioBuildQueryRequest) XXX_Unmarshal(b []byte) error
- type TioDeployCommServiceClient
- type TioDeployCommServiceServer
- type TioDeployServiceClient
- type TioDeployServiceServer
- type TioLogReply
- func (*TioLogReply) Descriptor() ([]byte, []int)
- func (m *TioLogReply) GetMessage() string
- func (*TioLogReply) ProtoMessage()
- func (m *TioLogReply) Reset()
- func (m *TioLogReply) String() string
- func (m *TioLogReply) XXX_DiscardUnknown()
- func (m *TioLogReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioLogReply) XXX_Merge(src proto.Message)
- func (m *TioLogReply) XXX_Size() int
- func (m *TioLogReply) XXX_Unmarshal(b []byte) error
- type TioLogRequest
- func (*TioLogRequest) Descriptor() ([]byte, []int)
- func (m *TioLogRequest) GetFlowing() bool
- func (m *TioLogRequest) GetName() string
- func (m *TioLogRequest) GetStype() string
- func (*TioLogRequest) ProtoMessage()
- func (m *TioLogRequest) Reset()
- func (m *TioLogRequest) String() string
- func (m *TioLogRequest) XXX_DiscardUnknown()
- func (m *TioLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioLogRequest) XXX_Merge(src proto.Message)
- func (m *TioLogRequest) XXX_Size() int
- func (m *TioLogRequest) XXX_Unmarshal(b []byte) error
- type TioPloy
- func (*TioPloy) Descriptor() ([]byte, []int)
- func (m *TioPloy) GetPloy() map[string]int32
- func (*TioPloy) ProtoMessage()
- func (m *TioPloy) Reset()
- func (m *TioPloy) String() string
- func (m *TioPloy) XXX_DiscardUnknown()
- func (m *TioPloy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioPloy) XXX_Merge(src proto.Message)
- func (m *TioPloy) XXX_Size() int
- func (m *TioPloy) XXX_Unmarshal(b []byte) error
- type TioReply
- func (*TioReply) Descriptor() ([]byte, []int)
- func (m *TioReply) GetCode() CommonRespCode
- func (m *TioReply) GetMsg() string
- func (*TioReply) ProtoMessage()
- func (m *TioReply) Reset()
- func (m *TioReply) String() string
- func (m *TioReply) XXX_DiscardUnknown()
- func (m *TioReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioReply) XXX_Merge(src proto.Message)
- func (m *TioReply) XXX_Size() int
- func (m *TioReply) XXX_Unmarshal(b []byte) error
- type TioToken
- func (*TioToken) Descriptor() ([]byte, []int)
- func (m *TioToken) GetAccessKey() string
- func (m *TioToken) GetBucket() string
- func (m *TioToken) GetCallBackUrl() string
- func (m *TioToken) GetSecretKey() string
- func (*TioToken) ProtoMessage()
- func (m *TioToken) Reset()
- func (m *TioToken) String() string
- func (m *TioToken) XXX_DiscardUnknown()
- func (m *TioToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioToken) XXX_Merge(src proto.Message)
- func (m *TioToken) XXX_Size() int
- func (m *TioToken) XXX_Unmarshal(b []byte) error
- type TioUserInfo
- func (*TioUserInfo) Descriptor() ([]byte, []int)
- func (m *TioUserInfo) GetUid() int32
- func (*TioUserInfo) ProtoMessage()
- func (m *TioUserInfo) Reset()
- func (m *TioUserInfo) String() string
- func (m *TioUserInfo) XXX_DiscardUnknown()
- func (m *TioUserInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioUserInfo) XXX_Merge(src proto.Message)
- func (m *TioUserInfo) XXX_Size() int
- func (m *TioUserInfo) XXX_Unmarshal(b []byte) error
- type TioUserReply
- func (*TioUserReply) Descriptor() ([]byte, []int)
- func (m *TioUserReply) GetCode() CommonRespCode
- func (m *TioUserReply) GetToken() *TioToken
- func (m *TioUserReply) GetUser() *TioUserInfo
- func (*TioUserReply) ProtoMessage()
- func (m *TioUserReply) Reset()
- func (m *TioUserReply) String() string
- func (m *TioUserReply) XXX_DiscardUnknown()
- func (m *TioUserReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioUserReply) XXX_Merge(src proto.Message)
- func (m *TioUserReply) XXX_Size() int
- func (m *TioUserReply) XXX_Unmarshal(b []byte) error
- type TioUserRequest
- func (*TioUserRequest) Descriptor() ([]byte, []int)
- func (m *TioUserRequest) GetName() string
- func (m *TioUserRequest) GetPasswd() string
- func (*TioUserRequest) ProtoMessage()
- func (m *TioUserRequest) Reset()
- func (m *TioUserRequest) String() string
- func (m *TioUserRequest) XXX_DiscardUnknown()
- func (m *TioUserRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TioUserRequest) XXX_Merge(src proto.Message)
- func (m *TioUserRequest) XXX_Size() int
- func (m *TioUserRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedBuildServiceServer
- type UnimplementedControlServiceServer
- func (*UnimplementedControlServiceServer) GetAgentMeta(ctx context.Context, req *TioAgentRequest) (*TioAgentReply, error)
- func (*UnimplementedControlServiceServer) GetBuildStatus(ctx context.Context, req *TioBuildQueryRequest) (*TioBuildQueryReply, error)
- func (*UnimplementedControlServiceServer) GetLogs(req *TioLogRequest, srv ControlService_GetLogsServer) error
- func (*UnimplementedControlServiceServer) GetPloy(ctx context.Context, req *TioPloy) (*TioPloy, error)
- func (*UnimplementedControlServiceServer) GetToken(ctx context.Context, req *TioUserRequest) (*TioUserReply, error)
- func (*UnimplementedControlServiceServer) Login(ctx context.Context, req *TioUserRequest) (*TioUserReply, error)
- func (*UnimplementedControlServiceServer) UpdateBuildStatus(ctx context.Context, req *BuildStatus) (*BuildReply, error)
- func (*UnimplementedControlServiceServer) UpdateServerMetadata(ctx context.Context, req *SrvMeta) (*TioReply, error)
- type UnimplementedInjectServiceServer
- type UnimplementedLogServiceServer
- type UnimplementedMonitorServiceServer
- type UnimplementedProxyServiceServer
- type UnimplementedTioDeployCommServiceServer
- type UnimplementedTioDeployServiceServer
- func (*UnimplementedTioDeployServiceServer) DeployInfo(ctx context.Context, req *DeployRequest) (*TioReply, error)
- func (*UnimplementedTioDeployServiceServer) NewDeploy(ctx context.Context, req *DeployRequest) (*TioReply, error)
- func (*UnimplementedTioDeployServiceServer) ScalaDeploy(ctx context.Context, req *DeployRequest) (*TioReply, error)
Constants ¶
This section is empty.
Variables ¶
var CommonRespCode_name = map[int32]string{
0: "RespSucc",
-1: "RespFaild",
}
var CommonRespCode_value = map[string]int32{
"RespSucc": 0,
"RespFaild": -1,
}
var JobStatus_name = map[int32]string{
0: "Ready",
1: "BuildSucc",
2: "BuildFailed",
3: "BuildIng",
4: "DeployIng",
5: "DeploySuc",
6: "DeployFailed",
}
var JobStatus_value = map[string]int32{
"Ready": 0,
"BuildSucc": 1,
"BuildFailed": 2,
"BuildIng": 3,
"DeployIng": 4,
"DeploySuc": 5,
"DeployFailed": 6,
}
Functions ¶
func RegisterBuildServiceServer ¶
func RegisterBuildServiceServer(s *grpc.Server, srv BuildServiceServer)
func RegisterControlServiceServer ¶
func RegisterControlServiceServer(s *grpc.Server, srv ControlServiceServer)
func RegisterInjectServiceServer ¶
func RegisterInjectServiceServer(s *grpc.Server, srv InjectServiceServer)
func RegisterLogServiceServer ¶
func RegisterLogServiceServer(s *grpc.Server, srv LogServiceServer)
func RegisterMonitorServiceServer ¶
func RegisterMonitorServiceServer(s *grpc.Server, srv MonitorServiceServer)
func RegisterProxyServiceServer ¶
func RegisterProxyServiceServer(s *grpc.Server, srv ProxyServiceServer)
func RegisterTioDeployCommServiceServer ¶
func RegisterTioDeployCommServiceServer(s *grpc.Server, srv TioDeployCommServiceServer)
func RegisterTioDeployServiceServer ¶
func RegisterTioDeployServiceServer(s *grpc.Server, srv TioDeployServiceServer)
Types ¶
type BuildReply ¶
type BuildReply struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BuildReply) Descriptor ¶
func (*BuildReply) Descriptor() ([]byte, []int)
func (*BuildReply) GetCode ¶
func (m *BuildReply) GetCode() int32
func (*BuildReply) GetMsg ¶
func (m *BuildReply) GetMsg() string
func (*BuildReply) ProtoMessage ¶
func (*BuildReply) ProtoMessage()
func (*BuildReply) Reset ¶
func (m *BuildReply) Reset()
func (*BuildReply) String ¶
func (m *BuildReply) String() string
func (*BuildReply) XXX_DiscardUnknown ¶
func (m *BuildReply) XXX_DiscardUnknown()
func (*BuildReply) XXX_Marshal ¶
func (m *BuildReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BuildReply) XXX_Merge ¶
func (m *BuildReply) XXX_Merge(src proto.Message)
func (*BuildReply) XXX_Size ¶
func (m *BuildReply) XXX_Size() int
func (*BuildReply) XXX_Unmarshal ¶
func (m *BuildReply) XXX_Unmarshal(b []byte) error
type BuildServiceClient ¶
type BuildServiceClient interface {
Build(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Reply, error)
}
BuildServiceClient is the client API for BuildService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBuildServiceClient ¶
func NewBuildServiceClient(cc *grpc.ClientConn) BuildServiceClient
type BuildServiceServer ¶
BuildServiceServer is the server API for BuildService service.
type BuildStatus ¶
type BuildStatus struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"` Api string `protobuf:"bytes,4,opt,name=api,proto3" json:"api,omitempty"` Rate int32 `protobuf:"varint,5,opt,name=rate,proto3" json:"rate,omitempty"` Raw string `protobuf:"bytes,6,opt,name=raw,proto3" json:"raw,omitempty"` Status JobStatus `protobuf:"varint,7,opt,name=status,proto3,enum=JobStatus" json:"status,omitempty"` Sid int32 `protobuf:"varint,8,opt,name=sid,proto3" json:"sid,omitempty"` Stype string `protobuf:"bytes,9,opt,name=stype,proto3" json:"stype,omitempty"` Version string `protobuf:"bytes,10,opt,name=version,proto3" json:"version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BuildStatus) Descriptor ¶
func (*BuildStatus) Descriptor() ([]byte, []int)
func (*BuildStatus) GetApi ¶
func (m *BuildStatus) GetApi() string
func (*BuildStatus) GetImage ¶
func (m *BuildStatus) GetImage() string
func (*BuildStatus) GetName ¶
func (m *BuildStatus) GetName() string
func (*BuildStatus) GetRate ¶
func (m *BuildStatus) GetRate() int32
func (*BuildStatus) GetRaw ¶
func (m *BuildStatus) GetRaw() string
func (*BuildStatus) GetSid ¶
func (m *BuildStatus) GetSid() int32
func (*BuildStatus) GetStatus ¶
func (m *BuildStatus) GetStatus() JobStatus
func (*BuildStatus) GetStype ¶
func (m *BuildStatus) GetStype() string
func (*BuildStatus) GetUser ¶
func (m *BuildStatus) GetUser() string
func (*BuildStatus) GetVersion ¶
func (m *BuildStatus) GetVersion() string
func (*BuildStatus) ProtoMessage ¶
func (*BuildStatus) ProtoMessage()
func (*BuildStatus) Reset ¶
func (m *BuildStatus) Reset()
func (*BuildStatus) String ¶
func (m *BuildStatus) String() string
func (*BuildStatus) XXX_DiscardUnknown ¶
func (m *BuildStatus) XXX_DiscardUnknown()
func (*BuildStatus) XXX_Marshal ¶
func (m *BuildStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BuildStatus) XXX_Merge ¶
func (m *BuildStatus) XXX_Merge(src proto.Message)
func (*BuildStatus) XXX_Size ¶
func (m *BuildStatus) XXX_Size() int
func (*BuildStatus) XXX_Unmarshal ¶
func (m *BuildStatus) XXX_Unmarshal(b []byte) error
type CommonRespCode ¶
type CommonRespCode int32
const ( CommonRespCode_RespSucc CommonRespCode = 0 CommonRespCode_RespFaild CommonRespCode = -1 )
func (CommonRespCode) EnumDescriptor ¶
func (CommonRespCode) EnumDescriptor() ([]byte, []int)
func (CommonRespCode) String ¶
func (x CommonRespCode) String() string
type ControlServiceClient ¶
type ControlServiceClient interface { UpdateBuildStatus(ctx context.Context, in *BuildStatus, opts ...grpc.CallOption) (*BuildReply, error) GetBuildStatus(ctx context.Context, in *TioBuildQueryRequest, opts ...grpc.CallOption) (*TioBuildQueryReply, error) GetToken(ctx context.Context, in *TioUserRequest, opts ...grpc.CallOption) (*TioUserReply, error) Login(ctx context.Context, in *TioUserRequest, opts ...grpc.CallOption) (*TioUserReply, error) // GetAgentMeta 获取其它Agents元数据 GetAgentMeta(ctx context.Context, in *TioAgentRequest, opts ...grpc.CallOption) (*TioAgentReply, error) GetLogs(ctx context.Context, in *TioLogRequest, opts ...grpc.CallOption) (ControlService_GetLogsClient, error) // UpdateServerMetadata 更新服务运行参数 UpdateServerMetadata(ctx context.Context, in *SrvMeta, opts ...grpc.CallOption) (*TioReply, error) GetPloy(ctx context.Context, in *TioPloy, opts ...grpc.CallOption) (*TioPloy, error) }
ControlServiceClient is the client API for ControlService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewControlServiceClient ¶
func NewControlServiceClient(cc *grpc.ClientConn) ControlServiceClient
type ControlServiceServer ¶
type ControlServiceServer interface { UpdateBuildStatus(context.Context, *BuildStatus) (*BuildReply, error) GetBuildStatus(context.Context, *TioBuildQueryRequest) (*TioBuildQueryReply, error) GetToken(context.Context, *TioUserRequest) (*TioUserReply, error) Login(context.Context, *TioUserRequest) (*TioUserReply, error) // GetAgentMeta 获取其它Agents元数据 GetAgentMeta(context.Context, *TioAgentRequest) (*TioAgentReply, error) GetLogs(*TioLogRequest, ControlService_GetLogsServer) error // UpdateServerMetadata 更新服务运行参数 UpdateServerMetadata(context.Context, *SrvMeta) (*TioReply, error) GetPloy(context.Context, *TioPloy) (*TioPloy, error) }
ControlServiceServer is the server API for ControlService service.
type ControlService_GetLogsClient ¶
type ControlService_GetLogsClient interface { Recv() (*TioLogReply, error) grpc.ClientStream }
type ControlService_GetLogsServer ¶
type ControlService_GetLogsServer interface { Send(*TioLogReply) error grpc.ServerStream }
type DeployRequest ¶
type DeployRequest struct { Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"` Config string `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` Sid int32 `protobuf:"varint,3,opt,name=sid,proto3" json:"sid,omitempty"` Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` Stype int32 `protobuf:"varint,5,opt,name=stype,proto3" json:"stype,omitempty"` InstanceNum int32 `protobuf:"varint,6,opt,name=instanceNum,proto3" json:"instanceNum,omitempty"` InstanceMultiple float64 `protobuf:"fixed64,7,opt,name=instanceMultiple,proto3" json:"instanceMultiple,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeployRequest) Descriptor ¶
func (*DeployRequest) Descriptor() ([]byte, []int)
func (*DeployRequest) GetConfig ¶
func (m *DeployRequest) GetConfig() string
func (*DeployRequest) GetImage ¶
func (m *DeployRequest) GetImage() string
func (*DeployRequest) GetInstanceMultiple ¶
func (m *DeployRequest) GetInstanceMultiple() float64
func (*DeployRequest) GetInstanceNum ¶
func (m *DeployRequest) GetInstanceNum() int32
func (*DeployRequest) GetName ¶
func (m *DeployRequest) GetName() string
func (*DeployRequest) GetSid ¶
func (m *DeployRequest) GetSid() int32
func (*DeployRequest) GetStype ¶
func (m *DeployRequest) GetStype() int32
func (*DeployRequest) ProtoMessage ¶
func (*DeployRequest) ProtoMessage()
func (*DeployRequest) Reset ¶
func (m *DeployRequest) Reset()
func (*DeployRequest) String ¶
func (m *DeployRequest) String() string
func (*DeployRequest) XXX_DiscardUnknown ¶
func (m *DeployRequest) XXX_DiscardUnknown()
func (*DeployRequest) XXX_Marshal ¶
func (m *DeployRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeployRequest) XXX_Merge ¶
func (m *DeployRequest) XXX_Merge(src proto.Message)
func (*DeployRequest) XXX_Size ¶
func (m *DeployRequest) XXX_Size() int
func (*DeployRequest) XXX_Unmarshal ¶
func (m *DeployRequest) XXX_Unmarshal(b []byte) error
type InjectRequest ¶
type InjectRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InjectRequest) Descriptor ¶
func (*InjectRequest) Descriptor() ([]byte, []int)
func (*InjectRequest) GetAddress ¶
func (m *InjectRequest) GetAddress() string
func (*InjectRequest) GetName ¶
func (m *InjectRequest) GetName() string
func (*InjectRequest) ProtoMessage ¶
func (*InjectRequest) ProtoMessage()
func (*InjectRequest) Reset ¶
func (m *InjectRequest) Reset()
func (*InjectRequest) String ¶
func (m *InjectRequest) String() string
func (*InjectRequest) XXX_DiscardUnknown ¶
func (m *InjectRequest) XXX_DiscardUnknown()
func (*InjectRequest) XXX_Marshal ¶
func (m *InjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InjectRequest) XXX_Merge ¶
func (m *InjectRequest) XXX_Merge(src proto.Message)
func (*InjectRequest) XXX_Size ¶
func (m *InjectRequest) XXX_Size() int
func (*InjectRequest) XXX_Unmarshal ¶
func (m *InjectRequest) XXX_Unmarshal(b []byte) error
type InjectServiceClient ¶
type InjectServiceClient interface {
NewGrpcSrv(ctx context.Context, in *InjectRequest, opts ...grpc.CallOption) (*TioReply, error)
}
InjectServiceClient is the client API for InjectService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewInjectServiceClient ¶
func NewInjectServiceClient(cc *grpc.ClientConn) InjectServiceClient
type InjectServiceServer ¶
type InjectServiceServer interface {
NewGrpcSrv(context.Context, *InjectRequest) (*TioReply, error)
}
InjectServiceServer is the server API for InjectService service.
type LogServiceClient ¶
type LogServiceClient interface { // GetLogs 代理客户端读取其它服务的日志 GetLogs(ctx context.Context, in *TioLogRequest, opts ...grpc.CallOption) (LogService_GetLogsClient, error) }
LogServiceClient is the client API for LogService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLogServiceClient ¶
func NewLogServiceClient(cc *grpc.ClientConn) LogServiceClient
type LogServiceServer ¶
type LogServiceServer interface { // GetLogs 代理客户端读取其它服务的日志 GetLogs(*TioLogRequest, LogService_GetLogsServer) error }
LogServiceServer is the server API for LogService service.
type LogService_GetLogsClient ¶
type LogService_GetLogsClient interface { Recv() (*TioLogReply, error) grpc.ClientStream }
type LogService_GetLogsServer ¶
type LogService_GetLogsServer interface { Send(*TioLogReply) error grpc.ServerStream }
type MonitorScalaRequest ¶
type MonitorScalaRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Num int32 `protobuf:"varint,2,opt,name=num,proto3" json:"num,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MonitorScalaRequest) Descriptor ¶
func (*MonitorScalaRequest) Descriptor() ([]byte, []int)
func (*MonitorScalaRequest) GetName ¶
func (m *MonitorScalaRequest) GetName() string
func (*MonitorScalaRequest) GetNum ¶
func (m *MonitorScalaRequest) GetNum() int32
func (*MonitorScalaRequest) ProtoMessage ¶
func (*MonitorScalaRequest) ProtoMessage()
func (*MonitorScalaRequest) Reset ¶
func (m *MonitorScalaRequest) Reset()
func (*MonitorScalaRequest) String ¶
func (m *MonitorScalaRequest) String() string
func (*MonitorScalaRequest) XXX_DiscardUnknown ¶
func (m *MonitorScalaRequest) XXX_DiscardUnknown()
func (*MonitorScalaRequest) XXX_Marshal ¶
func (m *MonitorScalaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MonitorScalaRequest) XXX_Merge ¶
func (m *MonitorScalaRequest) XXX_Merge(src proto.Message)
func (*MonitorScalaRequest) XXX_Size ¶
func (m *MonitorScalaRequest) XXX_Size() int
func (*MonitorScalaRequest) XXX_Unmarshal ¶
func (m *MonitorScalaRequest) XXX_Unmarshal(b []byte) error
type MonitorServiceClient ¶
type MonitorServiceClient interface { Scala(ctx context.Context, in *MonitorScalaRequest, opts ...grpc.CallOption) (*TioReply, error) Ploy(ctx context.Context, in *MonitorScalaRequest, opts ...grpc.CallOption) (*TioReply, error) }
MonitorServiceClient is the client API for MonitorService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMonitorServiceClient ¶
func NewMonitorServiceClient(cc *grpc.ClientConn) MonitorServiceClient
type MonitorServiceServer ¶
type MonitorServiceServer interface { Scala(context.Context, *MonitorScalaRequest) (*TioReply, error) Ploy(context.Context, *MonitorScalaRequest) (*TioReply, error) }
MonitorServiceServer is the server API for MonitorService service.
type ProxyEndpointRequest ¶
type ProxyEndpointRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProxyEndpointRequest) Descriptor ¶
func (*ProxyEndpointRequest) Descriptor() ([]byte, []int)
func (*ProxyEndpointRequest) GetEndpoint ¶
func (m *ProxyEndpointRequest) GetEndpoint() string
func (*ProxyEndpointRequest) GetName ¶
func (m *ProxyEndpointRequest) GetName() string
func (*ProxyEndpointRequest) ProtoMessage ¶
func (*ProxyEndpointRequest) ProtoMessage()
func (*ProxyEndpointRequest) Reset ¶
func (m *ProxyEndpointRequest) Reset()
func (*ProxyEndpointRequest) String ¶
func (m *ProxyEndpointRequest) String() string
func (*ProxyEndpointRequest) XXX_DiscardUnknown ¶
func (m *ProxyEndpointRequest) XXX_DiscardUnknown()
func (*ProxyEndpointRequest) XXX_Marshal ¶
func (m *ProxyEndpointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProxyEndpointRequest) XXX_Merge ¶
func (m *ProxyEndpointRequest) XXX_Merge(src proto.Message)
func (*ProxyEndpointRequest) XXX_Size ¶
func (m *ProxyEndpointRequest) XXX_Size() int
func (*ProxyEndpointRequest) XXX_Unmarshal ¶
func (m *ProxyEndpointRequest) XXX_Unmarshal(b []byte) error
type ProxyServiceClient ¶
type ProxyServiceClient interface { // NewEndpoint Monitor通过此接口通知服务创建完成的通知 NewEndpoint(ctx context.Context, in *ProxyEndpointRequest, opts ...grpc.CallOption) (*TioReply, error) // InjectSync 通知Proxy更新缓存 InjectSync(ctx context.Context, in *ProxyEndpointRequest, opts ...grpc.CallOption) (*TioReply, error) }
ProxyServiceClient is the client API for ProxyService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewProxyServiceClient ¶
func NewProxyServiceClient(cc *grpc.ClientConn) ProxyServiceClient
type ProxyServiceServer ¶
type ProxyServiceServer interface { // NewEndpoint Monitor通过此接口通知服务创建完成的通知 NewEndpoint(context.Context, *ProxyEndpointRequest) (*TioReply, error) // InjectSync 通知Proxy更新缓存 InjectSync(context.Context, *ProxyEndpointRequest) (*TioReply, error) }
ProxyServiceServer is the server API for ProxyService service.
type Reply ¶
type Reply struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Reply) Descriptor ¶
func (*Reply) ProtoMessage ¶
func (*Reply) ProtoMessage()
func (*Reply) XXX_DiscardUnknown ¶
func (m *Reply) XXX_DiscardUnknown()
func (*Reply) XXX_Marshal ¶
func (*Reply) XXX_Unmarshal ¶
type Request ¶
type Request struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Sid int32 `protobuf:"varint,2,opt,name=sid,proto3" json:"sid,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` BuildType string `protobuf:"bytes,4,opt,name=buildType,proto3" json:"buildType,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Request) Descriptor ¶
func (*Request) GetAddress ¶
func (*Request) GetBuildType ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) XXX_DiscardUnknown ¶
func (m *Request) XXX_DiscardUnknown()
func (*Request) XXX_Marshal ¶
func (*Request) XXX_Unmarshal ¶
type SrvMeta ¶
type SrvMeta struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"` Env map[string]string `` /* 147-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SrvMeta) Descriptor ¶
func (*SrvMeta) ProtoMessage ¶
func (*SrvMeta) ProtoMessage()
func (*SrvMeta) XXX_DiscardUnknown ¶
func (m *SrvMeta) XXX_DiscardUnknown()
func (*SrvMeta) XXX_Marshal ¶
func (*SrvMeta) XXX_Unmarshal ¶
type TioAgentReply ¶
type TioAgentReply struct { Code CommonRespCode `protobuf:"varint,1,opt,name=Code,proto3,enum=CommonRespCode" json:"Code,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioAgentReply) Descriptor ¶
func (*TioAgentReply) Descriptor() ([]byte, []int)
func (*TioAgentReply) GetAddress ¶
func (m *TioAgentReply) GetAddress() string
func (*TioAgentReply) GetCode ¶
func (m *TioAgentReply) GetCode() CommonRespCode
func (*TioAgentReply) ProtoMessage ¶
func (*TioAgentReply) ProtoMessage()
func (*TioAgentReply) Reset ¶
func (m *TioAgentReply) Reset()
func (*TioAgentReply) String ¶
func (m *TioAgentReply) String() string
func (*TioAgentReply) XXX_DiscardUnknown ¶
func (m *TioAgentReply) XXX_DiscardUnknown()
func (*TioAgentReply) XXX_Marshal ¶
func (m *TioAgentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TioAgentReply) XXX_Merge ¶
func (m *TioAgentReply) XXX_Merge(src proto.Message)
func (*TioAgentReply) XXX_Size ¶
func (m *TioAgentReply) XXX_Size() int
func (*TioAgentReply) XXX_Unmarshal ¶
func (m *TioAgentReply) XXX_Unmarshal(b []byte) error
type TioAgentRequest ¶
type TioAgentRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioAgentRequest) Descriptor ¶
func (*TioAgentRequest) Descriptor() ([]byte, []int)
func (*TioAgentRequest) GetName ¶
func (m *TioAgentRequest) GetName() string
func (*TioAgentRequest) ProtoMessage ¶
func (*TioAgentRequest) ProtoMessage()
func (*TioAgentRequest) Reset ¶
func (m *TioAgentRequest) Reset()
func (*TioAgentRequest) String ¶
func (m *TioAgentRequest) String() string
func (*TioAgentRequest) XXX_DiscardUnknown ¶
func (m *TioAgentRequest) XXX_DiscardUnknown()
func (*TioAgentRequest) XXX_Marshal ¶
func (m *TioAgentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TioAgentRequest) XXX_Merge ¶
func (m *TioAgentRequest) XXX_Merge(src proto.Message)
func (*TioAgentRequest) XXX_Size ¶
func (m *TioAgentRequest) XXX_Size() int
func (*TioAgentRequest) XXX_Unmarshal ¶
func (m *TioAgentRequest) XXX_Unmarshal(b []byte) error
type TioBuildQueryReply ¶
type TioBuildQueryReply struct { Code CommonRespCode `protobuf:"varint,1,opt,name=Code,proto3,enum=CommonRespCode" json:"Code,omitempty"` Builds []*BuildStatus `protobuf:"bytes,2,rep,name=builds,proto3" json:"builds,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioBuildQueryReply) Descriptor ¶
func (*TioBuildQueryReply) Descriptor() ([]byte, []int)
func (*TioBuildQueryReply) GetBuilds ¶
func (m *TioBuildQueryReply) GetBuilds() []*BuildStatus
func (*TioBuildQueryReply) GetCode ¶
func (m *TioBuildQueryReply) GetCode() CommonRespCode
func (*TioBuildQueryReply) ProtoMessage ¶
func (*TioBuildQueryReply) ProtoMessage()
func (*TioBuildQueryReply) Reset ¶
func (m *TioBuildQueryReply) Reset()
func (*TioBuildQueryReply) String ¶
func (m *TioBuildQueryReply) String() string
func (*TioBuildQueryReply) XXX_DiscardUnknown ¶
func (m *TioBuildQueryReply) XXX_DiscardUnknown()
func (*TioBuildQueryReply) XXX_Marshal ¶
func (m *TioBuildQueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TioBuildQueryReply) XXX_Merge ¶
func (m *TioBuildQueryReply) XXX_Merge(src proto.Message)
func (*TioBuildQueryReply) XXX_Size ¶
func (m *TioBuildQueryReply) XXX_Size() int
func (*TioBuildQueryReply) XXX_Unmarshal ¶
func (m *TioBuildQueryReply) XXX_Unmarshal(b []byte) error
type TioBuildQueryRequest ¶
type TioBuildQueryRequest struct { Uid int32 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioBuildQueryRequest) Descriptor ¶
func (*TioBuildQueryRequest) Descriptor() ([]byte, []int)
func (*TioBuildQueryRequest) GetLimit ¶
func (m *TioBuildQueryRequest) GetLimit() int32
func (*TioBuildQueryRequest) GetName ¶
func (m *TioBuildQueryRequest) GetName() string
func (*TioBuildQueryRequest) GetUid ¶
func (m *TioBuildQueryRequest) GetUid() int32
func (*TioBuildQueryRequest) ProtoMessage ¶
func (*TioBuildQueryRequest) ProtoMessage()
func (*TioBuildQueryRequest) Reset ¶
func (m *TioBuildQueryRequest) Reset()
func (*TioBuildQueryRequest) String ¶
func (m *TioBuildQueryRequest) String() string
func (*TioBuildQueryRequest) XXX_DiscardUnknown ¶
func (m *TioBuildQueryRequest) XXX_DiscardUnknown()
func (*TioBuildQueryRequest) XXX_Marshal ¶
func (m *TioBuildQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TioBuildQueryRequest) XXX_Merge ¶
func (m *TioBuildQueryRequest) XXX_Merge(src proto.Message)
func (*TioBuildQueryRequest) XXX_Size ¶
func (m *TioBuildQueryRequest) XXX_Size() int
func (*TioBuildQueryRequest) XXX_Unmarshal ¶
func (m *TioBuildQueryRequest) XXX_Unmarshal(b []byte) error
type TioDeployCommServiceClient ¶
type TioDeployCommServiceClient interface {
UpdateSrvMeta(ctx context.Context, in *SrvMeta, opts ...grpc.CallOption) (*TioReply, error)
}
TioDeployCommServiceClient is the client API for TioDeployCommService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTioDeployCommServiceClient ¶
func NewTioDeployCommServiceClient(cc *grpc.ClientConn) TioDeployCommServiceClient
type TioDeployCommServiceServer ¶
type TioDeployCommServiceServer interface {
UpdateSrvMeta(context.Context, *SrvMeta) (*TioReply, error)
}
TioDeployCommServiceServer is the server API for TioDeployCommService service.
type TioDeployServiceClient ¶
type TioDeployServiceClient interface { NewDeploy(ctx context.Context, in *DeployRequest, opts ...grpc.CallOption) (*TioReply, error) ScalaDeploy(ctx context.Context, in *DeployRequest, opts ...grpc.CallOption) (*TioReply, error) DeployInfo(ctx context.Context, in *DeployRequest, opts ...grpc.CallOption) (*TioReply, error) }
TioDeployServiceClient is the client API for TioDeployService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTioDeployServiceClient ¶
func NewTioDeployServiceClient(cc *grpc.ClientConn) TioDeployServiceClient
type TioDeployServiceServer ¶
type TioDeployServiceServer interface { NewDeploy(context.Context, *DeployRequest) (*TioReply, error) ScalaDeploy(context.Context, *DeployRequest) (*TioReply, error) DeployInfo(context.Context, *DeployRequest) (*TioReply, error) }
TioDeployServiceServer is the server API for TioDeployService service.
type TioLogReply ¶
type TioLogReply struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioLogReply) Descriptor ¶
func (*TioLogReply) Descriptor() ([]byte, []int)
func (*TioLogReply) GetMessage ¶
func (m *TioLogReply) GetMessage() string
func (*TioLogReply) ProtoMessage ¶
func (*TioLogReply) ProtoMessage()
func (*TioLogReply) Reset ¶
func (m *TioLogReply) Reset()
func (*TioLogReply) String ¶
func (m *TioLogReply) String() string
func (*TioLogReply) XXX_DiscardUnknown ¶
func (m *TioLogReply) XXX_DiscardUnknown()
func (*TioLogReply) XXX_Marshal ¶
func (m *TioLogReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TioLogReply) XXX_Merge ¶
func (m *TioLogReply) XXX_Merge(src proto.Message)
func (*TioLogReply) XXX_Size ¶
func (m *TioLogReply) XXX_Size() int
func (*TioLogReply) XXX_Unmarshal ¶
func (m *TioLogReply) XXX_Unmarshal(b []byte) error
type TioLogRequest ¶
type TioLogRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Flowing bool `protobuf:"varint,2,opt,name=flowing,proto3" json:"flowing,omitempty"` Stype string `protobuf:"bytes,3,opt,name=stype,proto3" json:"stype,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioLogRequest) Descriptor ¶
func (*TioLogRequest) Descriptor() ([]byte, []int)
func (*TioLogRequest) GetFlowing ¶
func (m *TioLogRequest) GetFlowing() bool
func (*TioLogRequest) GetName ¶
func (m *TioLogRequest) GetName() string
func (*TioLogRequest) GetStype ¶
func (m *TioLogRequest) GetStype() string
func (*TioLogRequest) ProtoMessage ¶
func (*TioLogRequest) ProtoMessage()
func (*TioLogRequest) Reset ¶
func (m *TioLogRequest) Reset()
func (*TioLogRequest) String ¶
func (m *TioLogRequest) String() string
func (*TioLogRequest) XXX_DiscardUnknown ¶
func (m *TioLogRequest) XXX_DiscardUnknown()
func (*TioLogRequest) XXX_Marshal ¶
func (m *TioLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TioLogRequest) XXX_Merge ¶
func (m *TioLogRequest) XXX_Merge(src proto.Message)
func (*TioLogRequest) XXX_Size ¶
func (m *TioLogRequest) XXX_Size() int
func (*TioLogRequest) XXX_Unmarshal ¶
func (m *TioLogRequest) XXX_Unmarshal(b []byte) error
type TioPloy ¶
type TioPloy struct { Ploy map[string]int32 `` /* 150-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioPloy) Descriptor ¶
func (*TioPloy) ProtoMessage ¶
func (*TioPloy) ProtoMessage()
func (*TioPloy) XXX_DiscardUnknown ¶
func (m *TioPloy) XXX_DiscardUnknown()
func (*TioPloy) XXX_Marshal ¶
func (*TioPloy) XXX_Unmarshal ¶
type TioReply ¶
type TioReply struct { Code CommonRespCode `protobuf:"varint,1,opt,name=code,proto3,enum=CommonRespCode" json:"code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioReply) Descriptor ¶
func (*TioReply) GetCode ¶
func (m *TioReply) GetCode() CommonRespCode
func (*TioReply) ProtoMessage ¶
func (*TioReply) ProtoMessage()
func (*TioReply) XXX_DiscardUnknown ¶
func (m *TioReply) XXX_DiscardUnknown()
func (*TioReply) XXX_Marshal ¶
func (*TioReply) XXX_Unmarshal ¶
type TioToken ¶
type TioToken struct { AccessKey string `protobuf:"bytes,1,opt,name=accessKey,proto3" json:"accessKey,omitempty"` SecretKey string `protobuf:"bytes,2,opt,name=secretKey,proto3" json:"secretKey,omitempty"` Bucket string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"` CallBackUrl string `protobuf:"bytes,4,opt,name=callBackUrl,proto3" json:"callBackUrl,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioToken) Descriptor ¶
func (*TioToken) GetAccessKey ¶
func (*TioToken) GetCallBackUrl ¶
func (*TioToken) GetSecretKey ¶
func (*TioToken) ProtoMessage ¶
func (*TioToken) ProtoMessage()
func (*TioToken) XXX_DiscardUnknown ¶
func (m *TioToken) XXX_DiscardUnknown()
func (*TioToken) XXX_Marshal ¶
func (*TioToken) XXX_Unmarshal ¶
type TioUserInfo ¶
type TioUserInfo struct { Uid int32 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioUserInfo) Descriptor ¶
func (*TioUserInfo) Descriptor() ([]byte, []int)
func (*TioUserInfo) GetUid ¶
func (m *TioUserInfo) GetUid() int32
func (*TioUserInfo) ProtoMessage ¶
func (*TioUserInfo) ProtoMessage()
func (*TioUserInfo) Reset ¶
func (m *TioUserInfo) Reset()
func (*TioUserInfo) String ¶
func (m *TioUserInfo) String() string
func (*TioUserInfo) XXX_DiscardUnknown ¶
func (m *TioUserInfo) XXX_DiscardUnknown()
func (*TioUserInfo) XXX_Marshal ¶
func (m *TioUserInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TioUserInfo) XXX_Merge ¶
func (m *TioUserInfo) XXX_Merge(src proto.Message)
func (*TioUserInfo) XXX_Size ¶
func (m *TioUserInfo) XXX_Size() int
func (*TioUserInfo) XXX_Unmarshal ¶
func (m *TioUserInfo) XXX_Unmarshal(b []byte) error
type TioUserReply ¶
type TioUserReply struct { Code CommonRespCode `protobuf:"varint,1,opt,name=Code,proto3,enum=CommonRespCode" json:"Code,omitempty"` Token *TioToken `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` User *TioUserInfo `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioUserReply) Descriptor ¶
func (*TioUserReply) Descriptor() ([]byte, []int)
func (*TioUserReply) GetCode ¶
func (m *TioUserReply) GetCode() CommonRespCode
func (*TioUserReply) GetToken ¶
func (m *TioUserReply) GetToken() *TioToken
func (*TioUserReply) GetUser ¶
func (m *TioUserReply) GetUser() *TioUserInfo
func (*TioUserReply) ProtoMessage ¶
func (*TioUserReply) ProtoMessage()
func (*TioUserReply) Reset ¶
func (m *TioUserReply) Reset()
func (*TioUserReply) String ¶
func (m *TioUserReply) String() string
func (*TioUserReply) XXX_DiscardUnknown ¶
func (m *TioUserReply) XXX_DiscardUnknown()
func (*TioUserReply) XXX_Marshal ¶
func (m *TioUserReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TioUserReply) XXX_Merge ¶
func (m *TioUserReply) XXX_Merge(src proto.Message)
func (*TioUserReply) XXX_Size ¶
func (m *TioUserReply) XXX_Size() int
func (*TioUserReply) XXX_Unmarshal ¶
func (m *TioUserReply) XXX_Unmarshal(b []byte) error
type TioUserRequest ¶
type TioUserRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Passwd string `protobuf:"bytes,2,opt,name=passwd,proto3" json:"passwd,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TioUserRequest) Descriptor ¶
func (*TioUserRequest) Descriptor() ([]byte, []int)
func (*TioUserRequest) GetName ¶
func (m *TioUserRequest) GetName() string
func (*TioUserRequest) GetPasswd ¶
func (m *TioUserRequest) GetPasswd() string
func (*TioUserRequest) ProtoMessage ¶
func (*TioUserRequest) ProtoMessage()
func (*TioUserRequest) Reset ¶
func (m *TioUserRequest) Reset()
func (*TioUserRequest) String ¶
func (m *TioUserRequest) String() string
func (*TioUserRequest) XXX_DiscardUnknown ¶
func (m *TioUserRequest) XXX_DiscardUnknown()
func (*TioUserRequest) XXX_Marshal ¶
func (m *TioUserRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TioUserRequest) XXX_Merge ¶
func (m *TioUserRequest) XXX_Merge(src proto.Message)
func (*TioUserRequest) XXX_Size ¶
func (m *TioUserRequest) XXX_Size() int
func (*TioUserRequest) XXX_Unmarshal ¶
func (m *TioUserRequest) XXX_Unmarshal(b []byte) error
type UnimplementedBuildServiceServer ¶
type UnimplementedBuildServiceServer struct { }
UnimplementedBuildServiceServer can be embedded to have forward compatible implementations.
type UnimplementedControlServiceServer ¶
type UnimplementedControlServiceServer struct { }
UnimplementedControlServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedControlServiceServer) GetAgentMeta ¶
func (*UnimplementedControlServiceServer) GetAgentMeta(ctx context.Context, req *TioAgentRequest) (*TioAgentReply, error)
func (*UnimplementedControlServiceServer) GetBuildStatus ¶
func (*UnimplementedControlServiceServer) GetBuildStatus(ctx context.Context, req *TioBuildQueryRequest) (*TioBuildQueryReply, error)
func (*UnimplementedControlServiceServer) GetLogs ¶
func (*UnimplementedControlServiceServer) GetLogs(req *TioLogRequest, srv ControlService_GetLogsServer) error
func (*UnimplementedControlServiceServer) GetToken ¶
func (*UnimplementedControlServiceServer) GetToken(ctx context.Context, req *TioUserRequest) (*TioUserReply, error)
func (*UnimplementedControlServiceServer) Login ¶
func (*UnimplementedControlServiceServer) Login(ctx context.Context, req *TioUserRequest) (*TioUserReply, error)
func (*UnimplementedControlServiceServer) UpdateBuildStatus ¶
func (*UnimplementedControlServiceServer) UpdateBuildStatus(ctx context.Context, req *BuildStatus) (*BuildReply, error)
func (*UnimplementedControlServiceServer) UpdateServerMetadata ¶
type UnimplementedInjectServiceServer ¶
type UnimplementedInjectServiceServer struct { }
UnimplementedInjectServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedInjectServiceServer) NewGrpcSrv ¶
func (*UnimplementedInjectServiceServer) NewGrpcSrv(ctx context.Context, req *InjectRequest) (*TioReply, error)
type UnimplementedLogServiceServer ¶
type UnimplementedLogServiceServer struct { }
UnimplementedLogServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedLogServiceServer) GetLogs ¶
func (*UnimplementedLogServiceServer) GetLogs(req *TioLogRequest, srv LogService_GetLogsServer) error
type UnimplementedMonitorServiceServer ¶
type UnimplementedMonitorServiceServer struct { }
UnimplementedMonitorServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedMonitorServiceServer) Ploy ¶
func (*UnimplementedMonitorServiceServer) Ploy(ctx context.Context, req *MonitorScalaRequest) (*TioReply, error)
func (*UnimplementedMonitorServiceServer) Scala ¶
func (*UnimplementedMonitorServiceServer) Scala(ctx context.Context, req *MonitorScalaRequest) (*TioReply, error)
type UnimplementedProxyServiceServer ¶
type UnimplementedProxyServiceServer struct { }
UnimplementedProxyServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedProxyServiceServer) InjectSync ¶
func (*UnimplementedProxyServiceServer) InjectSync(ctx context.Context, req *ProxyEndpointRequest) (*TioReply, error)
func (*UnimplementedProxyServiceServer) NewEndpoint ¶
func (*UnimplementedProxyServiceServer) NewEndpoint(ctx context.Context, req *ProxyEndpointRequest) (*TioReply, error)
type UnimplementedTioDeployCommServiceServer ¶
type UnimplementedTioDeployCommServiceServer struct { }
UnimplementedTioDeployCommServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTioDeployCommServiceServer) UpdateSrvMeta ¶
type UnimplementedTioDeployServiceServer ¶
type UnimplementedTioDeployServiceServer struct { }
UnimplementedTioDeployServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTioDeployServiceServer) DeployInfo ¶
func (*UnimplementedTioDeployServiceServer) DeployInfo(ctx context.Context, req *DeployRequest) (*TioReply, error)
func (*UnimplementedTioDeployServiceServer) NewDeploy ¶
func (*UnimplementedTioDeployServiceServer) NewDeploy(ctx context.Context, req *DeployRequest) (*TioReply, error)
func (*UnimplementedTioDeployServiceServer) ScalaDeploy ¶
func (*UnimplementedTioDeployServiceServer) ScalaDeploy(ctx context.Context, req *DeployRequest) (*TioReply, error)