parker_pb

package
v0.0.0-...-342490f Latest Latest
Warning

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

 Go to latest Published: Oct 25, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Parker_Lookup_FullMethodName = "/parker_server.Parker/Lookup"
)

Variables

View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_parker_proto protoreflect.FileDescriptor
View Source 
var Parker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "parker_server.Parker",
	HandlerType: (*ParkerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Lookup",
			Handler:    _Parker_Lookup_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "parker.proto",
}

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

Functions

func RegisterParkerServer 

func RegisterParkerServer(s grpc.ServiceRegistrar, srv ParkerServer)

Types

type Entry 

type Entry struct {
	Key          string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Size         int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	LastModified int64  `protobuf:"varint,3,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	Etag         string `protobuf:"bytes,4,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

//////////////////////////////////////////////

func (*Entry) Descriptor deprecated 

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetEtag 

func (x *Entry) GetEtag() string

func (*Entry) GetKey 

func (x *Entry) GetKey() string

func (*Entry) GetLastModified 

func (x *Entry) GetLastModified() int64

func (*Entry) GetSize 

func (x *Entry) GetSize() int64

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect 

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

func (*Entry) Reset 

func (x *Entry) Reset()

func (*Entry) String 

func (x *Entry) String() string

type Key 

type Key struct {

	// Types that are assignable to Kind:
	//
	//	*Key_Int32Value
	//	*Key_Int64Value
	//	*Key_BytesValue
	//	*Key_StringValue
	Kind isKey_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

///////////////////////// key value definition /////////////////////////

func (*Key) Descriptor deprecated 

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

Deprecated: Use Key.ProtoReflect.Descriptor instead.

func (*Key) GetBytesValue 

func (x *Key) GetBytesValue() []byte

func (*Key) GetInt32Value 

func (x *Key) GetInt32Value() int32

func (*Key) GetInt64Value 

func (x *Key) GetInt64Value() int64

func (*Key) GetKind 

func (m *Key) GetKind() isKey_Kind

func (*Key) GetStringValue 

func (x *Key) GetStringValue() string

func (*Key) ProtoMessage 

func (*Key) ProtoMessage()

func (*Key) ProtoReflect 

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

func (*Key) Reset 

func (x *Key) Reset()

func (*Key) String 

func (x *Key) String() string

type Key_BytesValue 

type Key_BytesValue struct {
	BytesValue []byte `protobuf:"bytes,3,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type Key_Int32Value 

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

type Key_Int64Value 

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

type Key_StringValue 

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

type ListValue 

type ListValue struct {
	Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ListValue) Descriptor deprecated 

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

Deprecated: Use ListValue.ProtoReflect.Descriptor instead.

func (*ListValue) GetValues 

func (x *ListValue) GetValues() []*Value

func (*ListValue) ProtoMessage 

func (*ListValue) ProtoMessage()

func (*ListValue) ProtoReflect 

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

func (*ListValue) Reset 

func (x *ListValue) Reset()

func (*ListValue) String 

func (x *ListValue) String() string

type LookupRequest 

type LookupRequest struct {
	Account    string       `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Table      string       `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Snapshot   int64        `protobuf:"varint,4,opt,name=snapshot,proto3" json:"snapshot,omitempty"` // Optional, in case customers want previous version
	Partitions []*Partition `protobuf:"bytes,5,rep,name=partitions,proto3" json:"partitions,omitempty"`
	Key        *Key         `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	Columns    []string     `protobuf:"bytes,7,rep,name=columns,proto3" json:"columns,omitempty"` // projection
	// contains filtered or unexported fields
}

func (*LookupRequest) Descriptor deprecated 

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

Deprecated: Use LookupRequest.ProtoReflect.Descriptor instead.

func (*LookupRequest) GetAccount 

func (x *LookupRequest) GetAccount() string

func (*LookupRequest) GetColumns 

func (x *LookupRequest) GetColumns() []string

func (*LookupRequest) GetKey 

func (x *LookupRequest) GetKey() *Key

func (*LookupRequest) GetPartitions 

func (x *LookupRequest) GetPartitions() []*Partition

func (*LookupRequest) GetSnapshot 

func (x *LookupRequest) GetSnapshot() int64

func (*LookupRequest) GetTable 

func (x *LookupRequest) GetTable() string

func (*LookupRequest) ProtoMessage 

func (*LookupRequest) ProtoMessage()

func (*LookupRequest) ProtoReflect 

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

func (*LookupRequest) Reset 

func (x *LookupRequest) Reset()

func (*LookupRequest) String 

func (x *LookupRequest) String() string

type LookupResponse 

type LookupResponse struct {
	Snapshot int64        `protobuf:"varint,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	Record   *RecordValue `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupResponse) Descriptor deprecated 

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

Deprecated: Use LookupResponse.ProtoReflect.Descriptor instead.

func (*LookupResponse) GetRecord 

func (x *LookupResponse) GetRecord() *RecordValue

func (*LookupResponse) GetSnapshot 

func (x *LookupResponse) GetSnapshot() int64

func (*LookupResponse) ProtoMessage 

func (*LookupResponse) ProtoMessage()

func (*LookupResponse) ProtoReflect 

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

func (*LookupResponse) Reset 

func (x *LookupResponse) Reset()

func (*LookupResponse) String 

func (x *LookupResponse) String() string

type ParkerClient 

type ParkerClient interface {
	// / Gateway => Parker
	Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error)
}

ParkerClient is the client API for Parker 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 NewParkerClient 

func NewParkerClient(cc grpc.ClientConnInterface) ParkerClient

type ParkerServer 

type ParkerServer interface {
	// / Gateway => Parker
	Lookup(context.Context, *LookupRequest) (*LookupResponse, error)
	// contains filtered or unexported methods
}

ParkerServer is the server API for Parker service. All implementations must embed UnimplementedParkerServer for forward compatibility.

type Partition 

type Partition struct {
	PartitionKey   string `protobuf:"bytes,1,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	PartitionValue string `protobuf:"bytes,2,opt,name=partition_value,json=partitionValue,proto3" json:"partition_value,omitempty"`
	// contains filtered or unexported fields
}

func (*Partition) Descriptor deprecated 

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

Deprecated: Use Partition.ProtoReflect.Descriptor instead.

func (*Partition) GetPartitionKey 

func (x *Partition) GetPartitionKey() string

func (*Partition) GetPartitionValue 

func (x *Partition) GetPartitionValue() string

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) ProtoReflect 

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

func (*Partition) Reset 

func (x *Partition) Reset()

func (*Partition) String 

func (x *Partition) String() string

type Range 

type Range struct {
	Partitions []*Partition `protobuf:"bytes,1,rep,name=partitions,proto3" json:"partitions,omitempty"` // any non-time partitions after time partitions
	LowerBound *Key         `protobuf:"bytes,2,opt,name=lower_bound,json=lowerBound,proto3" json:"lower_bound,omitempty"`
	UpperBound *Key         `protobuf:"bytes,3,opt,name=upper_bound,json=upperBound,proto3" json:"upper_bound,omitempty"`
	// contains filtered or unexported fields
}

//////////////////////////////////////////////

func (*Range) Descriptor deprecated 

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

Deprecated: Use Range.ProtoReflect.Descriptor instead.

func (*Range) GetLowerBound 

func (x *Range) GetLowerBound() *Key

func (*Range) GetPartitions 

func (x *Range) GetPartitions() []*Partition

func (*Range) GetUpperBound 

func (x *Range) GetUpperBound() *Key

func (*Range) ProtoMessage 

func (*Range) ProtoMessage()

func (*Range) ProtoReflect 

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

func (*Range) Reset 

func (x *Range) Reset()

func (*Range) String 

func (x *Range) String() string

type RecordValue 

type RecordValue struct {
	Fields map[string]*Value `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RecordValue) Descriptor deprecated 

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

Deprecated: Use RecordValue.ProtoReflect.Descriptor instead.

func (*RecordValue) GetFields 

func (x *RecordValue) GetFields() map[string]*Value

func (*RecordValue) ProtoMessage 

func (*RecordValue) ProtoMessage()

func (*RecordValue) ProtoReflect 

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

func (*RecordValue) Reset 

func (x *RecordValue) Reset()

func (*RecordValue) String 

func (x *RecordValue) String() string

type S3Access 

type S3Access struct {
	Bucket    string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Region    string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	AccessKey string `protobuf:"bytes,3,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey string `protobuf:"bytes,4,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	Endpoint  string `protobuf:"bytes,5,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*S3Access) Descriptor deprecated 

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

Deprecated: Use S3Access.ProtoReflect.Descriptor instead.

func (*S3Access) GetAccessKey 

func (x *S3Access) GetAccessKey() string

func (*S3Access) GetBucket 

func (x *S3Access) GetBucket() string

func (*S3Access) GetEndpoint 

func (x *S3Access) GetEndpoint() string

func (*S3Access) GetRegion 

func (x *S3Access) GetRegion() string

func (*S3Access) GetSecretKey 

func (x *S3Access) GetSecretKey() string

func (*S3Access) ProtoMessage 

func (*S3Access) ProtoMessage()

func (*S3Access) ProtoReflect 

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

func (*S3Access) Reset 

func (x *S3Access) Reset()

func (*S3Access) String 

func (x *S3Access) String() string

type UnimplementedParkerServer 

type UnimplementedParkerServer struct{}

UnimplementedParkerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedParkerServer) Lookup 

func (UnimplementedParkerServer) Lookup(context.Context, *LookupRequest) (*LookupResponse, error)

type UnsafeParkerServer 

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

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

type Value 

type Value struct {

	// Types that are assignable to Kind:
	//
	//	*Value_BoolValue
	//	*Value_Int32Value
	//	*Value_Int64Value
	//	*Value_FloatValue
	//	*Value_DoubleValue
	//	*Value_BytesValue
	//	*Value_StringValue
	//	*Value_ListValue
	//	*Value_RecordValue
	Kind isValue_Kind `protobuf_oneof:"kind"`
	// 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) GetBytesValue 

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

func (*Value) GetDoubleValue 

func (x *Value) GetDoubleValue() float64

func (*Value) GetFloatValue 

func (x *Value) GetFloatValue() float32

func (*Value) GetInt32Value 

func (x *Value) GetInt32Value() int32

func (*Value) GetInt64Value 

func (x *Value) GetInt64Value() int64

func (*Value) GetKind 

func (m *Value) GetKind() isValue_Kind

func (*Value) GetListValue 

func (x *Value) GetListValue() *ListValue

func (*Value) GetRecordValue 

func (x *Value) GetRecordValue() *RecordValue

func (*Value) GetStringValue 

func (x *Value) GetStringValue() string

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,1,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type Value_BytesValue 

type Value_BytesValue struct {
	BytesValue []byte `protobuf:"bytes,6,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type Value_DoubleValue 

type Value_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,5,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type Value_FloatValue 

type Value_FloatValue struct {
	FloatValue float32 `protobuf:"fixed32,4,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type Value_Int32Value 

type Value_Int32Value struct {
	Int32Value int32 `protobuf:"varint,2,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_ListValue 

type Value_ListValue struct {
	ListValue *ListValue `protobuf:"bytes,14,opt,name=list_value,json=listValue,proto3,oneof"`
}

type Value_RecordValue 

type Value_RecordValue struct {
	RecordValue *RecordValue `protobuf:"bytes,15,opt,name=record_value,json=recordValue,proto3,oneof"`
}

type Value_StringValue 

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

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.