Documentation ¶
Index ¶
- Variables
- func RegisterTaskServiceServer(s *grpc.Server, srv TaskServiceServer)
- type AggregatorSpec
- func (*AggregatorSpec) Descriptor() ([]byte, []int)
- func (m *AggregatorSpec) GetFieldName() string
- func (m *AggregatorSpec) GetFieldType() uint32
- func (m *AggregatorSpec) GetFuncTypeList() []uint32
- func (m *AggregatorSpec) Marshal() (dAtA []byte, err error)
- func (m *AggregatorSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *AggregatorSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AggregatorSpec) ProtoMessage()
- func (m *AggregatorSpec) Reset()
- func (m *AggregatorSpec) Size() (n int)
- func (m *AggregatorSpec) String() string
- func (m *AggregatorSpec) Unmarshal(dAtA []byte) error
- func (m *AggregatorSpec) XXX_DiscardUnknown()
- func (m *AggregatorSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AggregatorSpec) XXX_Merge(src proto.Message)
- func (m *AggregatorSpec) XXX_Size() int
- func (m *AggregatorSpec) XXX_Unmarshal(b []byte) error
- type RequestType
- type TaskRequest
- func (*TaskRequest) Descriptor() ([]byte, []int)
- func (m *TaskRequest) GetPayload() []byte
- func (m *TaskRequest) GetPhysicalPlan() []byte
- func (m *TaskRequest) GetRequestID() string
- func (m *TaskRequest) GetRequestType() RequestType
- func (m *TaskRequest) Marshal() (dAtA []byte, err error)
- func (m *TaskRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *TaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TaskRequest) ProtoMessage()
- func (m *TaskRequest) Reset()
- func (m *TaskRequest) Size() (n int)
- func (m *TaskRequest) String() string
- func (m *TaskRequest) Unmarshal(dAtA []byte) error
- func (m *TaskRequest) XXX_DiscardUnknown()
- func (m *TaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskRequest) XXX_Merge(src proto.Message)
- func (m *TaskRequest) XXX_Size() int
- func (m *TaskRequest) XXX_Unmarshal(b []byte) error
- type TaskResponse
- func (*TaskResponse) Descriptor() ([]byte, []int)
- func (m *TaskResponse) GetCompleted() bool
- func (m *TaskResponse) GetErrMsg() string
- func (m *TaskResponse) GetPayload() []byte
- func (m *TaskResponse) GetRequestID() string
- func (m *TaskResponse) GetRequestType() RequestType
- func (m *TaskResponse) GetSendTime() int64
- func (m *TaskResponse) GetStats() []byte
- func (m *TaskResponse) Marshal() (dAtA []byte, err error)
- func (m *TaskResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *TaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TaskResponse) ProtoMessage()
- func (m *TaskResponse) Reset()
- func (m *TaskResponse) Size() (n int)
- func (m *TaskResponse) String() string
- func (m *TaskResponse) Unmarshal(dAtA []byte) error
- func (m *TaskResponse) XXX_DiscardUnknown()
- func (m *TaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskResponse) XXX_Merge(src proto.Message)
- func (m *TaskResponse) XXX_Size() int
- func (m *TaskResponse) XXX_Unmarshal(b []byte) error
- type TaskServiceClient
- type TaskServiceServer
- type TaskService_HandleClient
- type TaskService_HandleServer
- type TimeSeries
- func (*TimeSeries) Descriptor() ([]byte, []int)
- func (m *TimeSeries) GetFields() map[string][]byte
- func (m *TimeSeries) GetTags() string
- func (m *TimeSeries) Marshal() (dAtA []byte, err error)
- func (m *TimeSeries) MarshalTo(dAtA []byte) (int, error)
- func (m *TimeSeries) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TimeSeries) ProtoMessage()
- func (m *TimeSeries) Reset()
- func (m *TimeSeries) Size() (n int)
- func (m *TimeSeries) String() string
- func (m *TimeSeries) Unmarshal(dAtA []byte) error
- func (m *TimeSeries) XXX_DiscardUnknown()
- func (m *TimeSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TimeSeries) XXX_Merge(src proto.Message)
- func (m *TimeSeries) XXX_Size() int
- func (m *TimeSeries) XXX_Unmarshal(b []byte) error
- type TimeSeriesList
- func (*TimeSeriesList) Descriptor() ([]byte, []int)
- func (m *TimeSeriesList) GetEnd() int64
- func (m *TimeSeriesList) GetFieldAggSpecs() []*AggregatorSpec
- func (m *TimeSeriesList) GetInterval() int64
- func (m *TimeSeriesList) GetStart() int64
- func (m *TimeSeriesList) GetTimeSeriesList() []*TimeSeries
- func (m *TimeSeriesList) Marshal() (dAtA []byte, err error)
- func (m *TimeSeriesList) MarshalTo(dAtA []byte) (int, error)
- func (m *TimeSeriesList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TimeSeriesList) ProtoMessage()
- func (m *TimeSeriesList) Reset()
- func (m *TimeSeriesList) Size() (n int)
- func (m *TimeSeriesList) String() string
- func (m *TimeSeriesList) Unmarshal(dAtA []byte) error
- func (m *TimeSeriesList) XXX_DiscardUnknown()
- func (m *TimeSeriesList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TimeSeriesList) XXX_Merge(src proto.Message)
- func (m *TimeSeriesList) XXX_Size() int
- func (m *TimeSeriesList) XXX_Unmarshal(b []byte) error
- type UnimplementedTaskServiceServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthCommon = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCommon = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupCommon = fmt.Errorf("proto: unexpected end of group") )
View Source
var RequestType_name = map[int32]string{
0: "Data",
1: "Metadata",
}
View Source
var RequestType_value = map[string]int32{
"Data": 0,
"Metadata": 1,
}
Functions ¶
func RegisterTaskServiceServer ¶
func RegisterTaskServiceServer(s *grpc.Server, srv TaskServiceServer)
Types ¶
type AggregatorSpec ¶
type AggregatorSpec struct { FieldName string `protobuf:"bytes,1,opt,name=fieldName,proto3" json:"fieldName,omitempty"` FieldType uint32 `protobuf:"varint,2,opt,name=fieldType,proto3" json:"fieldType,omitempty"` FuncTypeList []uint32 `protobuf:"varint,3,rep,packed,name=funcTypeList,proto3" json:"funcTypeList,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AggregatorSpec) Descriptor ¶
func (*AggregatorSpec) Descriptor() ([]byte, []int)
func (*AggregatorSpec) GetFieldName ¶
func (m *AggregatorSpec) GetFieldName() string
func (*AggregatorSpec) GetFieldType ¶
func (m *AggregatorSpec) GetFieldType() uint32
func (*AggregatorSpec) GetFuncTypeList ¶
func (m *AggregatorSpec) GetFuncTypeList() []uint32
func (*AggregatorSpec) Marshal ¶
func (m *AggregatorSpec) Marshal() (dAtA []byte, err error)
func (*AggregatorSpec) MarshalToSizedBuffer ¶
func (m *AggregatorSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AggregatorSpec) ProtoMessage ¶
func (*AggregatorSpec) ProtoMessage()
func (*AggregatorSpec) Reset ¶
func (m *AggregatorSpec) Reset()
func (*AggregatorSpec) Size ¶
func (m *AggregatorSpec) Size() (n int)
func (*AggregatorSpec) String ¶
func (m *AggregatorSpec) String() string
func (*AggregatorSpec) Unmarshal ¶
func (m *AggregatorSpec) Unmarshal(dAtA []byte) error
func (*AggregatorSpec) XXX_DiscardUnknown ¶
func (m *AggregatorSpec) XXX_DiscardUnknown()
func (*AggregatorSpec) XXX_Marshal ¶
func (m *AggregatorSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AggregatorSpec) XXX_Merge ¶
func (m *AggregatorSpec) XXX_Merge(src proto.Message)
func (*AggregatorSpec) XXX_Size ¶
func (m *AggregatorSpec) XXX_Size() int
func (*AggregatorSpec) XXX_Unmarshal ¶
func (m *AggregatorSpec) XXX_Unmarshal(b []byte) error
type RequestType ¶
type RequestType int32
const ( RequestType_Data RequestType = 0 RequestType_Metadata RequestType = 1 )
func (RequestType) EnumDescriptor ¶
func (RequestType) EnumDescriptor() ([]byte, []int)
func (RequestType) String ¶
func (x RequestType) String() string
type TaskRequest ¶
type TaskRequest struct { RequestID string `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"` RequestType RequestType `protobuf:"varint,3,opt,name=requestType,proto3,enum=protoCommonV1.RequestType" json:"requestType,omitempty"` PhysicalPlan []byte `protobuf:"bytes,4,opt,name=physicalPlan,proto3" json:"physicalPlan,omitempty"` Payload []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TaskRequest) Descriptor ¶
func (*TaskRequest) Descriptor() ([]byte, []int)
func (*TaskRequest) GetPayload ¶
func (m *TaskRequest) GetPayload() []byte
func (*TaskRequest) GetPhysicalPlan ¶
func (m *TaskRequest) GetPhysicalPlan() []byte
func (*TaskRequest) GetRequestID ¶
func (m *TaskRequest) GetRequestID() string
func (*TaskRequest) GetRequestType ¶
func (m *TaskRequest) GetRequestType() RequestType
func (*TaskRequest) Marshal ¶
func (m *TaskRequest) Marshal() (dAtA []byte, err error)
func (*TaskRequest) MarshalToSizedBuffer ¶
func (m *TaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TaskRequest) ProtoMessage ¶
func (*TaskRequest) ProtoMessage()
func (*TaskRequest) Reset ¶
func (m *TaskRequest) Reset()
func (*TaskRequest) Size ¶
func (m *TaskRequest) Size() (n int)
func (*TaskRequest) String ¶
func (m *TaskRequest) String() string
func (*TaskRequest) Unmarshal ¶
func (m *TaskRequest) Unmarshal(dAtA []byte) error
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 (m *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
type TaskResponse ¶
type TaskResponse struct { RequestID string `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"` RequestType RequestType `protobuf:"varint,2,opt,name=requestType,proto3,enum=protoCommonV1.RequestType" json:"requestType,omitempty"` Completed bool `protobuf:"varint,3,opt,name=completed,proto3" json:"completed,omitempty"` ErrMsg string `protobuf:"bytes,4,opt,name=errMsg,proto3" json:"errMsg,omitempty"` SendTime int64 `protobuf:"varint,5,opt,name=sendTime,proto3" json:"sendTime,omitempty"` Payload []byte `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"` Stats []byte `protobuf:"bytes,7,opt,name=stats,proto3" json:"stats,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TaskResponse) Descriptor ¶
func (*TaskResponse) Descriptor() ([]byte, []int)
func (*TaskResponse) GetCompleted ¶
func (m *TaskResponse) GetCompleted() bool
func (*TaskResponse) GetErrMsg ¶
func (m *TaskResponse) GetErrMsg() string
func (*TaskResponse) GetPayload ¶
func (m *TaskResponse) GetPayload() []byte
func (*TaskResponse) GetRequestID ¶ added in v0.2.4
func (m *TaskResponse) GetRequestID() string
func (*TaskResponse) GetRequestType ¶ added in v0.2.4
func (m *TaskResponse) GetRequestType() RequestType
func (*TaskResponse) GetSendTime ¶
func (m *TaskResponse) GetSendTime() int64
func (*TaskResponse) GetStats ¶
func (m *TaskResponse) GetStats() []byte
func (*TaskResponse) Marshal ¶
func (m *TaskResponse) Marshal() (dAtA []byte, err error)
func (*TaskResponse) MarshalToSizedBuffer ¶
func (m *TaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TaskResponse) ProtoMessage ¶
func (*TaskResponse) ProtoMessage()
func (*TaskResponse) Reset ¶
func (m *TaskResponse) Reset()
func (*TaskResponse) Size ¶
func (m *TaskResponse) Size() (n int)
func (*TaskResponse) String ¶
func (m *TaskResponse) String() string
func (*TaskResponse) Unmarshal ¶
func (m *TaskResponse) Unmarshal(dAtA []byte) error
func (*TaskResponse) XXX_DiscardUnknown ¶
func (m *TaskResponse) XXX_DiscardUnknown()
func (*TaskResponse) XXX_Marshal ¶
func (m *TaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TaskResponse) XXX_Merge ¶
func (m *TaskResponse) XXX_Merge(src proto.Message)
func (*TaskResponse) XXX_Size ¶
func (m *TaskResponse) XXX_Size() int
func (*TaskResponse) XXX_Unmarshal ¶
func (m *TaskResponse) XXX_Unmarshal(b []byte) error
type TaskServiceClient ¶
type TaskServiceClient interface {
Handle(ctx context.Context, opts ...grpc.CallOption) (TaskService_HandleClient, error)
}
TaskServiceClient is the client API for TaskService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTaskServiceClient ¶
func NewTaskServiceClient(cc *grpc.ClientConn) TaskServiceClient
type TaskServiceServer ¶
type TaskServiceServer interface {
Handle(TaskService_HandleServer) error
}
TaskServiceServer is the server API for TaskService service.
type TaskService_HandleClient ¶
type TaskService_HandleClient interface { Send(*TaskRequest) error Recv() (*TaskResponse, error) grpc.ClientStream }
type TaskService_HandleServer ¶
type TaskService_HandleServer interface { Send(*TaskResponse) error Recv() (*TaskRequest, error) grpc.ServerStream }
type TimeSeries ¶
type TimeSeries struct { Tags string `protobuf:"bytes,1,opt,name=tags,proto3" json:"tags,omitempty"` Fields map[string][]byte `` /* 153-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TimeSeries) Descriptor ¶
func (*TimeSeries) Descriptor() ([]byte, []int)
func (*TimeSeries) GetFields ¶
func (m *TimeSeries) GetFields() map[string][]byte
func (*TimeSeries) GetTags ¶
func (m *TimeSeries) GetTags() string
func (*TimeSeries) Marshal ¶
func (m *TimeSeries) Marshal() (dAtA []byte, err error)
func (*TimeSeries) MarshalToSizedBuffer ¶
func (m *TimeSeries) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TimeSeries) ProtoMessage ¶
func (*TimeSeries) ProtoMessage()
func (*TimeSeries) Reset ¶
func (m *TimeSeries) Reset()
func (*TimeSeries) Size ¶
func (m *TimeSeries) Size() (n int)
func (*TimeSeries) String ¶
func (m *TimeSeries) String() string
func (*TimeSeries) Unmarshal ¶
func (m *TimeSeries) Unmarshal(dAtA []byte) error
func (*TimeSeries) XXX_DiscardUnknown ¶
func (m *TimeSeries) XXX_DiscardUnknown()
func (*TimeSeries) XXX_Marshal ¶
func (m *TimeSeries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TimeSeries) XXX_Merge ¶
func (m *TimeSeries) XXX_Merge(src proto.Message)
func (*TimeSeries) XXX_Size ¶
func (m *TimeSeries) XXX_Size() int
func (*TimeSeries) XXX_Unmarshal ¶
func (m *TimeSeries) XXX_Unmarshal(b []byte) error
type TimeSeriesList ¶
type TimeSeriesList struct { Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` Interval int64 `protobuf:"varint,3,opt,name=interval,proto3" json:"interval,omitempty"` TimeSeriesList []*TimeSeries `protobuf:"bytes,4,rep,name=timeSeriesList,proto3" json:"timeSeriesList,omitempty"` FieldAggSpecs []*AggregatorSpec `protobuf:"bytes,5,rep,name=fieldAggSpecs,proto3" json:"fieldAggSpecs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TimeSeriesList) Descriptor ¶
func (*TimeSeriesList) Descriptor() ([]byte, []int)
func (*TimeSeriesList) GetEnd ¶ added in v0.2.4
func (m *TimeSeriesList) GetEnd() int64
func (*TimeSeriesList) GetFieldAggSpecs ¶
func (m *TimeSeriesList) GetFieldAggSpecs() []*AggregatorSpec
func (*TimeSeriesList) GetInterval ¶ added in v0.2.4
func (m *TimeSeriesList) GetInterval() int64
func (*TimeSeriesList) GetStart ¶ added in v0.2.4
func (m *TimeSeriesList) GetStart() int64
func (*TimeSeriesList) GetTimeSeriesList ¶
func (m *TimeSeriesList) GetTimeSeriesList() []*TimeSeries
func (*TimeSeriesList) Marshal ¶
func (m *TimeSeriesList) Marshal() (dAtA []byte, err error)
func (*TimeSeriesList) MarshalToSizedBuffer ¶
func (m *TimeSeriesList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TimeSeriesList) ProtoMessage ¶
func (*TimeSeriesList) ProtoMessage()
func (*TimeSeriesList) Reset ¶
func (m *TimeSeriesList) Reset()
func (*TimeSeriesList) Size ¶
func (m *TimeSeriesList) Size() (n int)
func (*TimeSeriesList) String ¶
func (m *TimeSeriesList) String() string
func (*TimeSeriesList) Unmarshal ¶
func (m *TimeSeriesList) Unmarshal(dAtA []byte) error
func (*TimeSeriesList) XXX_DiscardUnknown ¶
func (m *TimeSeriesList) XXX_DiscardUnknown()
func (*TimeSeriesList) XXX_Marshal ¶
func (m *TimeSeriesList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TimeSeriesList) XXX_Merge ¶
func (m *TimeSeriesList) XXX_Merge(src proto.Message)
func (*TimeSeriesList) XXX_Size ¶
func (m *TimeSeriesList) XXX_Size() int
func (*TimeSeriesList) XXX_Unmarshal ¶
func (m *TimeSeriesList) XXX_Unmarshal(b []byte) error
type UnimplementedTaskServiceServer ¶
type UnimplementedTaskServiceServer struct { }
UnimplementedTaskServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTaskServiceServer) Handle ¶
func (*UnimplementedTaskServiceServer) Handle(srv TaskService_HandleServer) error
Click to show internal directories.
Click to hide internal directories.