storagepb

package
v0.0.0-...-29cb0c6 Latest Latest
Warning

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

 Go to latest Published: Oct 19, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	QueryResponse_SchemaType_name = map[int32]string{
		0: "AVRO",
		1: "JSON",
	}
	QueryResponse_SchemaType_value = map[string]int32{
		"AVRO": 0,
		"JSON": 1,
	}
)

Enum value maps for QueryResponse_SchemaType.

View Source 
var File_storage_proto protoreflect.FileDescriptor
View Source 
var StorageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "storage.StorageService",
	HandlerType: (*StorageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Route",
			Handler:    _StorageService_Route_Handler,
		},
		{
			MethodName: "Write",
			Handler:    _StorageService_Write_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _StorageService_Query_Handler,
		},
		{
			MethodName: "PromQuery",
			Handler:    _StorageService_PromQuery_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamWrite",
			Handler:       _StorageService_StreamWrite_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "StreamQuery",
			Handler:       _StorageService_StreamQuery_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "storage.proto",
}

StorageService_ServiceDesc is the grpc.ServiceDesc for StorageService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterStorageServiceServer 

func RegisterStorageServiceServer(s grpc.ServiceRegistrar, srv StorageServiceServer)

Types

type Endpoint 

type Endpoint struct {
	Ip   string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*Endpoint) Descriptor deprecated 

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

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetIp 

func (x *Endpoint) GetIp() string

func (*Endpoint) GetPort 

func (x *Endpoint) GetPort() uint32

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect 

func (x *Endpoint) ProtoReflect() protoreflect.Message

func (*Endpoint) Reset 

func (x *Endpoint) Reset()

func (*Endpoint) String 

func (x *Endpoint) String() string

type Field 

type Field struct {
	NameIndex uint32 `protobuf:"varint,1,opt,name=name_index,json=nameIndex,proto3" json:"name_index,omitempty"`
	Value     *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Field) Descriptor deprecated 

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

Deprecated: Use Field.ProtoReflect.Descriptor instead.

func (*Field) GetNameIndex 

func (x *Field) GetNameIndex() uint32

func (*Field) GetValue 

func (x *Field) GetValue() *Value

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) ProtoReflect 

func (x *Field) ProtoReflect() protoreflect.Message

func (*Field) Reset 

func (x *Field) Reset()

func (*Field) String 

func (x *Field) String() string

type FieldGroup 

type FieldGroup struct {
	Timestamp int64    `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Fields    []*Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldGroup) Descriptor deprecated 

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

Deprecated: Use FieldGroup.ProtoReflect.Descriptor instead.

func (*FieldGroup) GetFields 

func (x *FieldGroup) GetFields() []*Field

func (*FieldGroup) GetTimestamp 

func (x *FieldGroup) GetTimestamp() int64

func (*FieldGroup) ProtoMessage 

func (*FieldGroup) ProtoMessage()

func (*FieldGroup) ProtoReflect 

func (x *FieldGroup) ProtoReflect() protoreflect.Message

func (*FieldGroup) Reset 

func (x *FieldGroup) Reset()

func (*FieldGroup) String 

func (x *FieldGroup) String() string

type QueryRequest 

type QueryRequest struct {
	Metrics []string `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	Ql      string   `protobuf:"bytes,2,opt,name=ql,proto3" json:"ql,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetMetrics 

func (x *QueryRequest) GetMetrics() []string

func (*QueryRequest) GetQl 

func (x *QueryRequest) GetQl() string

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

func (x *QueryRequest) ProtoReflect() protoreflect.Message

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResponse 

type QueryResponse struct {
	Header        *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	SchemaType    QueryResponse_SchemaType `` /* 130-byte string literal not displayed */
	SchemaContent string                   `protobuf:"bytes,3,opt,name=schema_content,json=schemaContent,proto3" json:"schema_content,omitempty"`
	Rows          [][]byte                 `protobuf:"bytes,4,rep,name=rows,proto3" json:"rows,omitempty"`
	AffectedRows  uint32                   `protobuf:"varint,5,opt,name=affected_rows,json=affectedRows,proto3" json:"affected_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetAffectedRows 

func (x *QueryResponse) GetAffectedRows() uint32

func (*QueryResponse) GetHeader 

func (x *QueryResponse) GetHeader() *commonpb.ResponseHeader

func (*QueryResponse) GetRows 

func (x *QueryResponse) GetRows() [][]byte

func (*QueryResponse) GetSchemaContent 

func (x *QueryResponse) GetSchemaContent() string

func (*QueryResponse) GetSchemaType 

func (x *QueryResponse) GetSchemaType() QueryResponse_SchemaType

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

func (x *QueryResponse) ProtoReflect() protoreflect.Message

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type QueryResponse_SchemaType 

type QueryResponse_SchemaType int32
const (
	QueryResponse_AVRO QueryResponse_SchemaType = 0
	QueryResponse_JSON QueryResponse_SchemaType = 1
)

func (QueryResponse_SchemaType) Descriptor 

func (QueryResponse_SchemaType) Descriptor() protoreflect.EnumDescriptor

func (QueryResponse_SchemaType) Enum 

func (x QueryResponse_SchemaType) Enum() *QueryResponse_SchemaType

func (QueryResponse_SchemaType) EnumDescriptor deprecated 

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

Deprecated: Use QueryResponse_SchemaType.Descriptor instead.

func (QueryResponse_SchemaType) Number 

func (x QueryResponse_SchemaType) Number() protoreflect.EnumNumber

func (QueryResponse_SchemaType) String 

func (x QueryResponse_SchemaType) String() string

func (QueryResponse_SchemaType) Type 

func (QueryResponse_SchemaType) Type() protoreflect.EnumType

type Route 

type Route struct {
	Metric   string    `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	Endpoint *Endpoint `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Ext      []byte    `protobuf:"bytes,3,opt,name=ext,proto3" json:"ext,omitempty"`
	// contains filtered or unexported fields
}

func (*Route) Descriptor deprecated 

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

Deprecated: Use Route.ProtoReflect.Descriptor instead.

func (*Route) GetEndpoint 

func (x *Route) GetEndpoint() *Endpoint

func (*Route) GetExt 

func (x *Route) GetExt() []byte

func (*Route) GetMetric 

func (x *Route) GetMetric() string

func (*Route) ProtoMessage 

func (*Route) ProtoMessage()

func (*Route) ProtoReflect 

func (x *Route) ProtoReflect() protoreflect.Message

func (*Route) Reset 

func (x *Route) Reset()

func (*Route) String 

func (x *Route) String() string

type RouteRequest 

type RouteRequest struct {
	Metrics []string `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteRequest) Descriptor deprecated 

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

Deprecated: Use RouteRequest.ProtoReflect.Descriptor instead.

func (*RouteRequest) GetMetrics 

func (x *RouteRequest) GetMetrics() []string

func (*RouteRequest) ProtoMessage 

func (*RouteRequest) ProtoMessage()

func (*RouteRequest) ProtoReflect 

func (x *RouteRequest) ProtoReflect() protoreflect.Message

func (*RouteRequest) Reset 

func (x *RouteRequest) Reset()

func (*RouteRequest) String 

func (x *RouteRequest) String() string

type RouteResponse 

type RouteResponse struct {
	Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Routes []*Route                 `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteResponse) Descriptor deprecated 

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

Deprecated: Use RouteResponse.ProtoReflect.Descriptor instead.

func (*RouteResponse) GetHeader 

func (x *RouteResponse) GetHeader() *commonpb.ResponseHeader

func (*RouteResponse) GetRoutes 

func (x *RouteResponse) GetRoutes() []*Route

func (*RouteResponse) ProtoMessage 

func (*RouteResponse) ProtoMessage()

func (*RouteResponse) ProtoReflect 

func (x *RouteResponse) ProtoReflect() protoreflect.Message

func (*RouteResponse) Reset 

func (x *RouteResponse) Reset()

func (*RouteResponse) String 

func (x *RouteResponse) String() string

type StorageServiceClient 

type StorageServiceClient interface {
	Route(ctx context.Context, in *RouteRequest, opts ...grpc.CallOption) (*RouteResponse, error)
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	StreamWrite(ctx context.Context, opts ...grpc.CallOption) (StorageService_StreamWriteClient, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	StreamQuery(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (StorageService_StreamQueryClient, error)
	PromQuery(ctx context.Context, in *ceresprompb.PrometheusQueryRequest, opts ...grpc.CallOption) (*ceresprompb.PrometheusQueryResponse, error)
}

StorageServiceClient is the client API for StorageService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStorageServiceClient 

func NewStorageServiceClient(cc grpc.ClientConnInterface) StorageServiceClient

type StorageServiceServer 

type StorageServiceServer interface {
	Route(context.Context, *RouteRequest) (*RouteResponse, error)
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	StreamWrite(StorageService_StreamWriteServer) error
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	StreamQuery(*QueryRequest, StorageService_StreamQueryServer) error
	PromQuery(context.Context, *ceresprompb.PrometheusQueryRequest) (*ceresprompb.PrometheusQueryResponse, error)
	// contains filtered or unexported methods
}

StorageServiceServer is the server API for StorageService service. All implementations must embed UnimplementedStorageServiceServer for forward compatibility

type StorageService_StreamQueryClient 

type StorageService_StreamQueryClient interface {
	Recv() (*QueryResponse, error)
	grpc.ClientStream
}

type StorageService_StreamQueryServer 

type StorageService_StreamQueryServer interface {
	Send(*QueryResponse) error
	grpc.ServerStream
}

type StorageService_StreamWriteClient 

type StorageService_StreamWriteClient interface {
	Send(*WriteRequest) error
	CloseAndRecv() (*WriteResponse, error)
	grpc.ClientStream
}

type StorageService_StreamWriteServer 

type StorageService_StreamWriteServer interface {
	SendAndClose(*WriteResponse) error
	Recv() (*WriteRequest, error)
	grpc.ServerStream
}

type Tag 

type Tag struct {
	NameIndex uint32 `protobuf:"varint,1,opt,name=name_index,json=nameIndex,proto3" json:"name_index,omitempty"`
	Value     *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Tag) Descriptor deprecated 

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

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetNameIndex 

func (x *Tag) GetNameIndex() uint32

func (*Tag) GetValue 

func (x *Tag) GetValue() *Value

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect 

func (x *Tag) ProtoReflect() protoreflect.Message

func (*Tag) Reset 

func (x *Tag) Reset()

func (*Tag) String 

func (x *Tag) String() string

type UnimplementedStorageServiceServer 

type UnimplementedStorageServiceServer struct {
}

UnimplementedStorageServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStorageServiceServer) PromQuery 

func (UnimplementedStorageServiceServer) PromQuery(context.Context, *ceresprompb.PrometheusQueryRequest) (*ceresprompb.PrometheusQueryResponse, error)

func (UnimplementedStorageServiceServer) Query 

func (UnimplementedStorageServiceServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

func (UnimplementedStorageServiceServer) Route 

func (UnimplementedStorageServiceServer) Route(context.Context, *RouteRequest) (*RouteResponse, error)

func (UnimplementedStorageServiceServer) StreamQuery 

func (UnimplementedStorageServiceServer) StreamQuery(*QueryRequest, StorageService_StreamQueryServer) error

func (UnimplementedStorageServiceServer) StreamWrite 

func (UnimplementedStorageServiceServer) StreamWrite(StorageService_StreamWriteServer) error

func (UnimplementedStorageServiceServer) Write 

func (UnimplementedStorageServiceServer) Write(context.Context, *WriteRequest) (*WriteResponse, error)

type UnsafeStorageServiceServer 

type UnsafeStorageServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeStorageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StorageServiceServer will result in compilation errors.

type Value 

type Value struct {

	// Types that are assignable to Value:
	//
	//	*Value_Float64Value
	//	*Value_StringValue
	//	*Value_Int64Value
	//	*Value_Float32Value
	//	*Value_Int32Value
	//	*Value_Int16Value
	//	*Value_Int8Value
	//	*Value_BoolValue
	//	*Value_Uint64Value
	//	*Value_Uint32Value
	//	*Value_Uint16Value
	//	*Value_Uint8Value
	//	*Value_TimestampValue
	//	*Value_VarbinaryValue
	Value isValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBoolValue 

func (x *Value) GetBoolValue() bool

func (*Value) GetFloat32Value 

func (x *Value) GetFloat32Value() float32

func (*Value) GetFloat64Value 

func (x *Value) GetFloat64Value() float64

func (*Value) GetInt16Value 

func (x *Value) GetInt16Value() int32

func (*Value) GetInt32Value 

func (x *Value) GetInt32Value() int32

func (*Value) GetInt64Value 

func (x *Value) GetInt64Value() int64

func (*Value) GetInt8Value 

func (x *Value) GetInt8Value() int32

func (*Value) GetStringValue 

func (x *Value) GetStringValue() string

func (*Value) GetTimestampValue 

func (x *Value) GetTimestampValue() int64

func (*Value) GetUint16Value 

func (x *Value) GetUint16Value() uint32

func (*Value) GetUint32Value 

func (x *Value) GetUint32Value() uint32

func (*Value) GetUint64Value 

func (x *Value) GetUint64Value() uint64

func (*Value) GetUint8Value 

func (x *Value) GetUint8Value() uint32

func (*Value) GetValue 

func (m *Value) GetValue() isValue_Value

func (*Value) GetVarbinaryValue 

func (x *Value) GetVarbinaryValue() []byte

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

func (x *Value) ProtoReflect() protoreflect.Message

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type Value_BoolValue 

type Value_BoolValue struct {
	BoolValue bool `protobuf:"varint,8,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type Value_Float32Value 

type Value_Float32Value struct {
	Float32Value float32 `protobuf:"fixed32,4,opt,name=float32_value,json=float32Value,proto3,oneof"`
}

type Value_Float64Value 

type Value_Float64Value struct {
	Float64Value float64 `protobuf:"fixed64,1,opt,name=float64_value,json=float64Value,proto3,oneof"`
}

type Value_Int16Value 

type Value_Int16Value struct {
	Int16Value int32 `protobuf:"varint,6,opt,name=int16_value,json=int16Value,proto3,oneof"`
}

type Value_Int32Value 

type Value_Int32Value struct {
	Int32Value int32 `protobuf:"varint,5,opt,name=int32_value,json=int32Value,proto3,oneof"`
}

type Value_Int64Value 

type Value_Int64Value struct {
	Int64Value int64 `protobuf:"varint,3,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type Value_Int8Value 

type Value_Int8Value struct {
	Int8Value int32 `protobuf:"varint,7,opt,name=int8_value,json=int8Value,proto3,oneof"`
}

type Value_StringValue 

type Value_StringValue struct {
	StringValue string `protobuf:"bytes,2,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Value_TimestampValue 

type Value_TimestampValue struct {
	TimestampValue int64 `protobuf:"varint,13,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

type Value_Uint16Value 

type Value_Uint16Value struct {
	Uint16Value uint32 `protobuf:"varint,11,opt,name=uint16_value,json=uint16Value,proto3,oneof"`
}

type Value_Uint32Value 

type Value_Uint32Value struct {
	Uint32Value uint32 `protobuf:"varint,10,opt,name=uint32_value,json=uint32Value,proto3,oneof"`
}

type Value_Uint64Value 

type Value_Uint64Value struct {
	Uint64Value uint64 `protobuf:"varint,9,opt,name=uint64_value,json=uint64Value,proto3,oneof"`
}

type Value_Uint8Value 

type Value_Uint8Value struct {
	Uint8Value uint32 `protobuf:"varint,12,opt,name=uint8_value,json=uint8Value,proto3,oneof"`
}

type Value_VarbinaryValue 

type Value_VarbinaryValue struct {
	VarbinaryValue []byte `protobuf:"bytes,14,opt,name=varbinary_value,json=varbinaryValue,proto3,oneof"`
}

type WriteEntry 

type WriteEntry struct {
	Tags        []*Tag        `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	FieldGroups []*FieldGroup `protobuf:"bytes,2,rep,name=field_groups,json=fieldGroups,proto3" json:"field_groups,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteEntry) Descriptor deprecated 

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

Deprecated: Use WriteEntry.ProtoReflect.Descriptor instead.

func (*WriteEntry) GetFieldGroups 

func (x *WriteEntry) GetFieldGroups() []*FieldGroup

func (*WriteEntry) GetTags 

func (x *WriteEntry) GetTags() []*Tag

func (*WriteEntry) ProtoMessage 

func (*WriteEntry) ProtoMessage()

func (*WriteEntry) ProtoReflect 

func (x *WriteEntry) ProtoReflect() protoreflect.Message

func (*WriteEntry) Reset 

func (x *WriteEntry) Reset()

func (*WriteEntry) String 

func (x *WriteEntry) String() string

type WriteMetric 

type WriteMetric struct {
	Metric     string        `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	TagNames   []string      `protobuf:"bytes,2,rep,name=tag_names,json=tagNames,proto3" json:"tag_names,omitempty"`
	FieldNames []string      `protobuf:"bytes,3,rep,name=field_names,json=fieldNames,proto3" json:"field_names,omitempty"`
	Entries    []*WriteEntry `protobuf:"bytes,4,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteMetric) Descriptor deprecated 

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

Deprecated: Use WriteMetric.ProtoReflect.Descriptor instead.

func (*WriteMetric) GetEntries 

func (x *WriteMetric) GetEntries() []*WriteEntry

func (*WriteMetric) GetFieldNames 

func (x *WriteMetric) GetFieldNames() []string

func (*WriteMetric) GetMetric 

func (x *WriteMetric) GetMetric() string

func (*WriteMetric) GetTagNames 

func (x *WriteMetric) GetTagNames() []string

func (*WriteMetric) ProtoMessage 

func (*WriteMetric) ProtoMessage()

func (*WriteMetric) ProtoReflect 

func (x *WriteMetric) ProtoReflect() protoreflect.Message

func (*WriteMetric) Reset 

func (x *WriteMetric) Reset()

func (*WriteMetric) String 

func (x *WriteMetric) String() string

type WriteRequest 

type WriteRequest struct {
	Metrics []*WriteMetric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRequest) Descriptor deprecated 

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

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetMetrics 

func (x *WriteRequest) GetMetrics() []*WriteMetric

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect 

func (x *WriteRequest) ProtoReflect() protoreflect.Message

func (*WriteRequest) Reset 

func (x *WriteRequest) Reset()

func (*WriteRequest) String 

func (x *WriteRequest) String() string

type WriteResponse 

type WriteResponse struct {
	Header  *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Success uint32                   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Failed  uint32                   `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteResponse) Descriptor deprecated 

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

Deprecated: Use WriteResponse.ProtoReflect.Descriptor instead.

func (*WriteResponse) GetFailed 

func (x *WriteResponse) GetFailed() uint32

func (*WriteResponse) GetHeader 

func (x *WriteResponse) GetHeader() *commonpb.ResponseHeader

func (*WriteResponse) GetSuccess 

func (x *WriteResponse) GetSuccess() uint32

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) ProtoReflect 

func (x *WriteResponse) ProtoReflect() protoreflect.Message

func (*WriteResponse) Reset 

func (x *WriteResponse) Reset()

func (*WriteResponse) String 

func (x *WriteResponse) String() string

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.