protoCommonV1

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Apr 21, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

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

func (m *AggregatorSpec) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *TaskRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *TaskResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *TimeSeries) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *TimeSeriesList) MarshalTo(dAtA []byte) (int, 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

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.