thunderpb

package
v0.5.1 Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2020 License: MIT Imports: 10 Imported by: 0

Documentation

Overview

Package thunderpb is a generated protocol buffer package.

It is generated from these files: 

dependency.proto
federation.proto
testcustomexecutor.proto

It has these top-level messages: 

Field
SQLFilter
ExpirationTime
Selection
Fragment
SelectionSet
Query
ExecuteRequest
ExecuteResponse
CustomExecutorRequest
CustomExecutorResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDependency = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDependency   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthFederation = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFederation   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTestcustomexecutor = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTestcustomexecutor   = fmt.Errorf("proto: integer overflow")
)
View Source 
var FieldKind_name = map[int32]string{
	0: "Unknown",
	1: "Null",
	2: "Bool",
	3: "Int",
	4: "Uint",
	5: "String",
	6: "Bytes",
	7: "Float64",
	8: "Time",
}
View Source 
var FieldKind_value = map[string]int32{
	"Unknown": 0,
	"Null":    1,
	"Bool":    2,
	"Int":     3,
	"Uint":    4,
	"String":  5,
	"Bytes":   6,
	"Float64": 7,
	"Time":    8,
}

Functions

func RegisterCustomExecutorServer added in v0.5.1 

func RegisterCustomExecutorServer(s *grpc.Server, srv CustomExecutorServer)

func RegisterExecutorServer added in v0.5.1 

func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)

Types

type CustomExecutorClient added in v0.5.1 

type CustomExecutorClient interface {
	Execute(ctx context.Context, in *CustomExecutorRequest, opts ...grpc.CallOption) (*CustomExecutorResponse, error)
}

func NewCustomExecutorClient added in v0.5.1 

func NewCustomExecutorClient(cc *grpc.ClientConn) CustomExecutorClient

type CustomExecutorRequest added in v0.5.1 

type CustomExecutorRequest struct {
	Request *ExecuteRequest `protobuf:"bytes,1,opt,name=request" json:"request,omitempty"`
	Token   string          `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
}

func (*CustomExecutorRequest) Descriptor added in v0.5.1 

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

func (*CustomExecutorRequest) GetRequest added in v0.5.1 

func (m *CustomExecutorRequest) GetRequest() *ExecuteRequest

func (*CustomExecutorRequest) GetToken added in v0.5.1 

func (m *CustomExecutorRequest) GetToken() string

func (*CustomExecutorRequest) Marshal added in v0.5.1 

func (m *CustomExecutorRequest) Marshal() (dAtA []byte, err error)

func (*CustomExecutorRequest) MarshalTo added in v0.5.1 

func (m *CustomExecutorRequest) MarshalTo(dAtA []byte) (int, error)

func (*CustomExecutorRequest) ProtoMessage added in v0.5.1 

func (*CustomExecutorRequest) ProtoMessage()

func (*CustomExecutorRequest) Reset added in v0.5.1 

func (m *CustomExecutorRequest) Reset()

func (*CustomExecutorRequest) Size added in v0.5.1 

func (m *CustomExecutorRequest) Size() (n int)

func (*CustomExecutorRequest) String added in v0.5.1 

func (m *CustomExecutorRequest) String() string

func (*CustomExecutorRequest) Unmarshal added in v0.5.1 

func (m *CustomExecutorRequest) Unmarshal(dAtA []byte) error

type CustomExecutorResponse added in v0.5.1 

type CustomExecutorResponse struct {
	Response *ExecuteResponse `protobuf:"bytes,1,opt,name=response" json:"response,omitempty"`
	Token    string           `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
}

func (*CustomExecutorResponse) Descriptor added in v0.5.1 

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

func (*CustomExecutorResponse) GetResponse added in v0.5.1 

func (m *CustomExecutorResponse) GetResponse() *ExecuteResponse

func (*CustomExecutorResponse) GetToken added in v0.5.1 

func (m *CustomExecutorResponse) GetToken() string

func (*CustomExecutorResponse) Marshal added in v0.5.1 

func (m *CustomExecutorResponse) Marshal() (dAtA []byte, err error)

func (*CustomExecutorResponse) MarshalTo added in v0.5.1 

func (m *CustomExecutorResponse) MarshalTo(dAtA []byte) (int, error)

func (*CustomExecutorResponse) ProtoMessage added in v0.5.1 

func (*CustomExecutorResponse) ProtoMessage()

func (*CustomExecutorResponse) Reset added in v0.5.1 

func (m *CustomExecutorResponse) Reset()

func (*CustomExecutorResponse) Size added in v0.5.1 

func (m *CustomExecutorResponse) Size() (n int)

func (*CustomExecutorResponse) String added in v0.5.1 

func (m *CustomExecutorResponse) String() string

func (*CustomExecutorResponse) Unmarshal added in v0.5.1 

func (m *CustomExecutorResponse) Unmarshal(dAtA []byte) error

type CustomExecutorServer added in v0.5.1 

type CustomExecutorServer interface {
	Execute(context.Context, *CustomExecutorRequest) (*CustomExecutorResponse, error)
}

type ExecuteRequest added in v0.5.1 

type ExecuteRequest struct {
	Query *Query `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
}

func (*ExecuteRequest) Descriptor added in v0.5.1 

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

func (*ExecuteRequest) GetQuery added in v0.5.1 

func (m *ExecuteRequest) GetQuery() *Query

func (*ExecuteRequest) Marshal added in v0.5.1 

func (m *ExecuteRequest) Marshal() (dAtA []byte, err error)

func (*ExecuteRequest) MarshalTo added in v0.5.1 

func (m *ExecuteRequest) MarshalTo(dAtA []byte) (int, error)

func (*ExecuteRequest) ProtoMessage added in v0.5.1 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) Reset added in v0.5.1 

func (m *ExecuteRequest) Reset()

func (*ExecuteRequest) Size added in v0.5.1 

func (m *ExecuteRequest) Size() (n int)

func (*ExecuteRequest) String added in v0.5.1 

func (m *ExecuteRequest) String() string

func (*ExecuteRequest) Unmarshal added in v0.5.1 

func (m *ExecuteRequest) Unmarshal(dAtA []byte) error

type ExecuteResponse added in v0.5.1 

type ExecuteResponse struct {
	Result []byte `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*ExecuteResponse) Descriptor added in v0.5.1 

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

func (*ExecuteResponse) GetResult added in v0.5.1 

func (m *ExecuteResponse) GetResult() []byte

func (*ExecuteResponse) Marshal added in v0.5.1 

func (m *ExecuteResponse) Marshal() (dAtA []byte, err error)

func (*ExecuteResponse) MarshalTo added in v0.5.1 

func (m *ExecuteResponse) MarshalTo(dAtA []byte) (int, error)

func (*ExecuteResponse) ProtoMessage added in v0.5.1 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) Reset added in v0.5.1 

func (m *ExecuteResponse) Reset()

func (*ExecuteResponse) Size added in v0.5.1 

func (m *ExecuteResponse) Size() (n int)

func (*ExecuteResponse) String added in v0.5.1 

func (m *ExecuteResponse) String() string

func (*ExecuteResponse) Unmarshal added in v0.5.1 

func (m *ExecuteResponse) Unmarshal(dAtA []byte) error

type ExecutorClient added in v0.5.1 

type ExecutorClient interface {
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
}

func NewExecutorClient added in v0.5.1 

func NewExecutorClient(cc *grpc.ClientConn) ExecutorClient

type ExecutorServer added in v0.5.1 

type ExecutorServer interface {
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
}

type ExpirationTime 

type ExpirationTime struct {
	Time time.Time `protobuf:"bytes,1,opt,name=time,stdtime" json:"time"`
}

func (*ExpirationTime) Descriptor 

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

func (*ExpirationTime) GetTime 

func (m *ExpirationTime) GetTime() time.Time

func (*ExpirationTime) Marshal 

func (m *ExpirationTime) Marshal() (dAtA []byte, err error)

func (*ExpirationTime) MarshalTo 

func (m *ExpirationTime) MarshalTo(dAtA []byte) (int, error)

func (*ExpirationTime) ProtoMessage 

func (*ExpirationTime) ProtoMessage()

func (*ExpirationTime) Reset 

func (m *ExpirationTime) Reset()

func (*ExpirationTime) Size 

func (m *ExpirationTime) Size() (n int)

func (*ExpirationTime) String 

func (m *ExpirationTime) String() string

func (*ExpirationTime) Unmarshal 

func (m *ExpirationTime) Unmarshal(dAtA []byte) error

type Field 

type Field struct {
	Kind FieldKind `protobuf:"varint,1,opt,name=kind,proto3,enum=thunderpb.FieldKind" json:"kind,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*Field_Bool
	//	*Field_Int
	//	*Field_Uint
	//	*Field_String_
	//	*Field_Bytes
	//	*Field_Float64
	//	*Field_Time
	Value isField_Value `protobuf_oneof:"value"`
}

func (*Field) Descriptor 

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

func (*Field) GetBool 

func (m *Field) GetBool() bool

func (*Field) GetBytes 

func (m *Field) GetBytes() []byte

func (*Field) GetFloat64 

func (m *Field) GetFloat64() float64

func (*Field) GetInt 

func (m *Field) GetInt() int64

func (*Field) GetKind 

func (m *Field) GetKind() FieldKind

func (*Field) GetString_ 

func (m *Field) GetString_() string

func (*Field) GetTime 

func (m *Field) GetTime() *time.Time

func (*Field) GetUint 

func (m *Field) GetUint() uint64

func (*Field) GetValue 

func (m *Field) GetValue() isField_Value

func (*Field) Marshal 

func (m *Field) Marshal() (dAtA []byte, err error)

func (*Field) MarshalTo 

func (m *Field) MarshalTo(dAtA []byte) (int, error)

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) Reset 

func (m *Field) Reset()

func (*Field) Size 

func (m *Field) Size() (n int)

func (*Field) String 

func (m *Field) String() string

func (*Field) Unmarshal 

func (m *Field) Unmarshal(dAtA []byte) error

func (*Field) XXX_OneofFuncs 

func (*Field) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type FieldKind 

type FieldKind int32
const (
	FieldKind_Unknown FieldKind = 0
	FieldKind_Null    FieldKind = 1
	FieldKind_Bool    FieldKind = 2
	FieldKind_Int     FieldKind = 3
	FieldKind_Uint    FieldKind = 4
	FieldKind_String  FieldKind = 5
	FieldKind_Bytes   FieldKind = 6
	FieldKind_Float64 FieldKind = 7
	FieldKind_Time    FieldKind = 8
)

func (FieldKind) EnumDescriptor 

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

func (FieldKind) String 

func (x FieldKind) String() string

type Field_Bool 

type Field_Bool struct {
	Bool bool `protobuf:"varint,2,opt,name=bool,proto3,oneof"`
}

func (*Field_Bool) MarshalTo 

func (m *Field_Bool) MarshalTo(dAtA []byte) (int, error)

func (*Field_Bool) Size 

func (m *Field_Bool) Size() (n int)

type Field_Bytes 

type Field_Bytes struct {
	Bytes []byte `protobuf:"bytes,6,opt,name=bytes,proto3,oneof"`
}

func (*Field_Bytes) MarshalTo 

func (m *Field_Bytes) MarshalTo(dAtA []byte) (int, error)

func (*Field_Bytes) Size 

func (m *Field_Bytes) Size() (n int)

type Field_Float64 

type Field_Float64 struct {
	Float64 float64 `protobuf:"fixed64,7,opt,name=float64,proto3,oneof"`
}

func (*Field_Float64) MarshalTo 

func (m *Field_Float64) MarshalTo(dAtA []byte) (int, error)

func (*Field_Float64) Size 

func (m *Field_Float64) Size() (n int)

type Field_Int 

type Field_Int struct {
	Int int64 `protobuf:"zigzag64,3,opt,name=int,proto3,oneof"`
}

func (*Field_Int) MarshalTo 

func (m *Field_Int) MarshalTo(dAtA []byte) (int, error)

func (*Field_Int) Size 

func (m *Field_Int) Size() (n int)

type Field_String_ 

type Field_String_ struct {
	String_ string `protobuf:"bytes,5,opt,name=string,proto3,oneof"`
}

func (*Field_String_) MarshalTo 

func (m *Field_String_) MarshalTo(dAtA []byte) (int, error)

func (*Field_String_) Size 

func (m *Field_String_) Size() (n int)

type Field_Time 

type Field_Time struct {
	Time *time.Time `protobuf:"bytes,8,opt,name=time,oneof,stdtime"`
}

func (*Field_Time) MarshalTo 

func (m *Field_Time) MarshalTo(dAtA []byte) (int, error)

func (*Field_Time) Size 

func (m *Field_Time) Size() (n int)

type Field_Uint 

type Field_Uint struct {
	Uint uint64 `protobuf:"varint,4,opt,name=uint,proto3,oneof"`
}

func (*Field_Uint) MarshalTo 

func (m *Field_Uint) MarshalTo(dAtA []byte) (int, error)

func (*Field_Uint) Size 

func (m *Field_Uint) Size() (n int)

type Fragment added in v0.5.1 

type Fragment struct {
	On           string        `protobuf:"bytes,1,opt,name=on,proto3" json:"on,omitempty"`
	SelectionSet *SelectionSet `protobuf:"bytes,2,opt,name=selection_set,json=selectionSet" json:"selection_set,omitempty"`
}

func (*Fragment) Descriptor added in v0.5.1 

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

func (*Fragment) GetOn added in v0.5.1 

func (m *Fragment) GetOn() string

func (*Fragment) GetSelectionSet added in v0.5.1 

func (m *Fragment) GetSelectionSet() *SelectionSet

func (*Fragment) Marshal added in v0.5.1 

func (m *Fragment) Marshal() (dAtA []byte, err error)

func (*Fragment) MarshalTo added in v0.5.1 

func (m *Fragment) MarshalTo(dAtA []byte) (int, error)

func (*Fragment) ProtoMessage added in v0.5.1 

func (*Fragment) ProtoMessage()

func (*Fragment) Reset added in v0.5.1 

func (m *Fragment) Reset()

func (*Fragment) Size added in v0.5.1 

func (m *Fragment) Size() (n int)

func (*Fragment) String added in v0.5.1 

func (m *Fragment) String() string

func (*Fragment) Unmarshal added in v0.5.1 

func (m *Fragment) Unmarshal(dAtA []byte) error

type Query added in v0.5.1 

type Query struct {
	Kind         string        `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Name         string        `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	SelectionSet *SelectionSet `protobuf:"bytes,3,opt,name=selection_set,json=selectionSet" json:"selection_set,omitempty"`
}

func (*Query) Descriptor added in v0.5.1 

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

func (*Query) GetKind added in v0.5.1 

func (m *Query) GetKind() string

func (*Query) GetName added in v0.5.1 

func (m *Query) GetName() string

func (*Query) GetSelectionSet added in v0.5.1 

func (m *Query) GetSelectionSet() *SelectionSet

func (*Query) Marshal added in v0.5.1 

func (m *Query) Marshal() (dAtA []byte, err error)

func (*Query) MarshalTo added in v0.5.1 

func (m *Query) MarshalTo(dAtA []byte) (int, error)

func (*Query) ProtoMessage added in v0.5.1 

func (*Query) ProtoMessage()

func (*Query) Reset added in v0.5.1 

func (m *Query) Reset()

func (*Query) Size added in v0.5.1 

func (m *Query) Size() (n int)

func (*Query) String added in v0.5.1 

func (m *Query) String() string

func (*Query) Unmarshal added in v0.5.1 

func (m *Query) Unmarshal(dAtA []byte) error

type SQLFilter 

type SQLFilter struct {
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// Map of column name to field value.
	Fields map[string]*Field `` /* 139-byte string literal not displayed */
}

func (*SQLFilter) Descriptor 

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

func (*SQLFilter) GetFields 

func (m *SQLFilter) GetFields() map[string]*Field

func (*SQLFilter) GetTable 

func (m *SQLFilter) GetTable() string

func (*SQLFilter) Marshal 

func (m *SQLFilter) Marshal() (dAtA []byte, err error)

func (*SQLFilter) MarshalTo 

func (m *SQLFilter) MarshalTo(dAtA []byte) (int, error)

func (*SQLFilter) ProtoMessage 

func (*SQLFilter) ProtoMessage()

func (*SQLFilter) Reset 

func (m *SQLFilter) Reset()

func (*SQLFilter) Size 

func (m *SQLFilter) Size() (n int)

func (*SQLFilter) String 

func (m *SQLFilter) String() string

func (*SQLFilter) Unmarshal 

func (m *SQLFilter) Unmarshal(dAtA []byte) error

type Selection added in v0.5.1 

type Selection struct {
	Name         string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Alias        string        `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	SelectionSet *SelectionSet `protobuf:"bytes,3,opt,name=selection_set,json=selectionSet" json:"selection_set,omitempty"`
	Arguments    []byte        `protobuf:"bytes,4,opt,name=arguments,proto3" json:"arguments,omitempty"`
}

func (*Selection) Descriptor added in v0.5.1 

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

func (*Selection) GetAlias added in v0.5.1 

func (m *Selection) GetAlias() string

func (*Selection) GetArguments added in v0.5.1 

func (m *Selection) GetArguments() []byte

func (*Selection) GetName added in v0.5.1 

func (m *Selection) GetName() string

func (*Selection) GetSelectionSet added in v0.5.1 

func (m *Selection) GetSelectionSet() *SelectionSet

func (*Selection) Marshal added in v0.5.1 

func (m *Selection) Marshal() (dAtA []byte, err error)

func (*Selection) MarshalTo added in v0.5.1 

func (m *Selection) MarshalTo(dAtA []byte) (int, error)

func (*Selection) ProtoMessage added in v0.5.1 

func (*Selection) ProtoMessage()

func (*Selection) Reset added in v0.5.1 

func (m *Selection) Reset()

func (*Selection) Size added in v0.5.1 

func (m *Selection) Size() (n int)

func (*Selection) String added in v0.5.1 

func (m *Selection) String() string

func (*Selection) Unmarshal added in v0.5.1 

func (m *Selection) Unmarshal(dAtA []byte) error

type SelectionSet added in v0.5.1 

type SelectionSet struct {
	Selections []*Selection `protobuf:"bytes,1,rep,name=selections" json:"selections,omitempty"`
	Fragments  []*Fragment  `protobuf:"bytes,2,rep,name=fragments" json:"fragments,omitempty"`
}

func (*SelectionSet) Descriptor added in v0.5.1 

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

func (*SelectionSet) GetFragments added in v0.5.1 

func (m *SelectionSet) GetFragments() []*Fragment

func (*SelectionSet) GetSelections added in v0.5.1 

func (m *SelectionSet) GetSelections() []*Selection

func (*SelectionSet) Marshal added in v0.5.1 

func (m *SelectionSet) Marshal() (dAtA []byte, err error)

func (*SelectionSet) MarshalTo added in v0.5.1 

func (m *SelectionSet) MarshalTo(dAtA []byte) (int, error)

func (*SelectionSet) ProtoMessage added in v0.5.1 

func (*SelectionSet) ProtoMessage()

func (*SelectionSet) Reset added in v0.5.1 

func (m *SelectionSet) Reset()

func (*SelectionSet) Size added in v0.5.1 

func (m *SelectionSet) Size() (n int)

func (*SelectionSet) String added in v0.5.1 

func (m *SelectionSet) String() string

func (*SelectionSet) Unmarshal added in v0.5.1 

func (m *SelectionSet) Unmarshal(dAtA []byte) 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.