little_of_everything

package
v5.0.5+incompatible Latest Latest
Warning

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

 Go to latest Published: Aug 25, 2021 License: BSD-3-Clause Imports: 15 Imported by: 0

Documentation

Overview

This file is generated by protoc-gen-persist Source File: tests/sql/little_of_everything/little_of_everything.proto DO NOT EDIT !

Index

Constants

This section is empty.

Variables

View Source 
var ExampleTable1_InnerEnum_name = map[int32]string{
	0: "OP_0",
	1: "OP_1",
}
View Source 
var ExampleTable1_InnerEnum_value = map[string]int32{
	"OP_0": 0,
	"OP_1": 1,
}
View Source 
var MappedEnum_name = map[int32]string{
	0: "OPT_0",
	1: "OPT_1",
}
View Source 
var MappedEnum_value = map[string]int32{
	"OPT_0": 0,
	"OPT_1": 1,
}
View Source 
var MyEnum_name = map[int32]string{
	0: "OPTION_0",
	1: "OPTION_1",
}
View Source 
var MyEnum_value = map[string]int32{
	"OPTION_0": 0,
	"OPTION_1": 1,
}

Functions

func DefaultBidiStreamingPersistTx 

func DefaultBidiStreamingPersistTx(ctx context.Context, db *sql.DB) (persist.PersistTx, error)

func DefaultClientStreamingPersistTx 

func DefaultClientStreamingPersistTx(ctx context.Context, db *sql.DB) (persist.PersistTx, error)

func DefaultServerStreamingPersistTx 

func DefaultServerStreamingPersistTx(ctx context.Context, db *sql.DB) (persist.PersistTx, error)

func DefaultUnaryPersistTx 

func DefaultUnaryPersistTx(ctx context.Context, db *sql.DB) (persist.PersistTx, error)

func NopPersistTx 

func NopPersistTx(r persist.Runnable) (persist.PersistTx, error)

func RegisterNotEnabledServiceServer 

func RegisterNotEnabledServiceServer(s *grpc.Server, srv NotEnabledServiceServer)

func RegisterTestservice1Server 

func RegisterTestservice1Server(s *grpc.Server, srv Testservice1Server)

Types

type CountRows 

type CountRows struct {
	Count                int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountRows) Descriptor 

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

func (*CountRows) GetCount 

func (m *CountRows) GetCount() int64

func (*CountRows) ProtoMessage 

func (*CountRows) ProtoMessage()

func (*CountRows) Reset 

func (m *CountRows) Reset()

func (*CountRows) String 

func (m *CountRows) String() string

func (*CountRows) XXX_DiscardUnknown 

func (m *CountRows) XXX_DiscardUnknown()

func (*CountRows) XXX_Marshal 

func (m *CountRows) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountRows) XXX_Merge 

func (m *CountRows) XXX_Merge(src proto.Message)

func (*CountRows) XXX_Size 

func (m *CountRows) XXX_Size() int

func (*CountRows) XXX_Unmarshal 

func (m *CountRows) XXX_Unmarshal(b []byte) error

type DefaultHooks_NotEnabledService 

type DefaultHooks_NotEnabledService struct{}

type DefaultHooks_Testservice1 

type DefaultHooks_Testservice1 struct{}

type DefaultMappingImpl_Testservice1_MappedEnum 

type DefaultMappingImpl_Testservice1_MappedEnum struct{}

func (*DefaultMappingImpl_Testservice1_MappedEnum) Scan 

func (this *DefaultMappingImpl_Testservice1_MappedEnum) Scan(interface{}) error

func (*DefaultMappingImpl_Testservice1_MappedEnum) ToProto 

func (this *DefaultMappingImpl_Testservice1_MappedEnum) ToProto(**MappedEnum) error

func (*DefaultMappingImpl_Testservice1_MappedEnum) ToSql 

func (this *DefaultMappingImpl_Testservice1_MappedEnum) ToSql(*MappedEnum) sql.Scanner

func (*DefaultMappingImpl_Testservice1_MappedEnum) Value 

func (this *DefaultMappingImpl_Testservice1_MappedEnum) Value() (driver.Value, error)

type DefaultMappingImpl_Testservice1_TimestampTimestamp 

type DefaultMappingImpl_Testservice1_TimestampTimestamp struct{}

func (*DefaultMappingImpl_Testservice1_TimestampTimestamp) Scan 

func (this *DefaultMappingImpl_Testservice1_TimestampTimestamp) Scan(interface{}) error

func (*DefaultMappingImpl_Testservice1_TimestampTimestamp) ToProto 

func (this *DefaultMappingImpl_Testservice1_TimestampTimestamp) ToProto(**timestamp.Timestamp) error

func (*DefaultMappingImpl_Testservice1_TimestampTimestamp) ToSql 

func (this *DefaultMappingImpl_Testservice1_TimestampTimestamp) ToSql(*timestamp.Timestamp) sql.Scanner

func (*DefaultMappingImpl_Testservice1_TimestampTimestamp) Value 

func (this *DefaultMappingImpl_Testservice1_TimestampTimestamp) Value() (driver.Value, error)

type DefaultTypeMappings_NotEnabledService 

type DefaultTypeMappings_NotEnabledService struct{}

type DefaultTypeMappings_Testservice1 

type DefaultTypeMappings_Testservice1 struct{}

func (*DefaultTypeMappings_Testservice1) MappedEnum 

func (this *DefaultTypeMappings_Testservice1) MappedEnum() MappingImpl_Testservice1_MappedEnum

func (*DefaultTypeMappings_Testservice1) TimestampTimestamp 

func (this *DefaultTypeMappings_Testservice1) TimestampTimestamp() MappingImpl_Testservice1_TimestampTimestamp

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge 

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

func (m *Empty) XXX_Unmarshal(b []byte) error

type ExampleTable1 

type ExampleTable1 struct {
	TableId      int32                       `protobuf:"varint,1,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	Key          string                      `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value        string                      `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	InnerMessage *ExampleTable1_InnerMessage `protobuf:"bytes,4,opt,name=inner_message,json=innerMessage,proto3" json:"inner_message,omitempty"`
	InnerEnum    ExampleTable1_InnerEnum     `protobuf:"varint,5,opt,name=inner_enum,json=innerEnum,proto3,enum=tests.ExampleTable1_InnerEnum" json:"inner_enum,omitempty"`
	StringArray  []string                    `protobuf:"bytes,6,rep,name=string_array,json=stringArray,proto3" json:"string_array,omitempty"`
	BytesField   []byte                      `protobuf:"bytes,7,opt,name=bytes_field,json=bytesField,proto3" json:"bytes_field,omitempty"`
	StartTime    *timestamp.Timestamp        `protobuf:"bytes,10,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	TestField    *test.Test                  `protobuf:"bytes,100,opt,name=test_field,json=testField,proto3" json:"test_field,omitempty"`
	// Types that are valid to be assigned to SkipOneOf:
	//	*ExampleTable1_TestId
	//	*ExampleTable1_TestValue
	//	*ExampleTable1_TestOutMessage
	SkipOneOf            isExampleTable1_SkipOneOf `protobuf_oneof:"skip_one_of"`
	Myyenum              MyEnum                    `protobuf:"varint,101,opt,name=myyenum,proto3,enum=tests.MyEnum" json:"myyenum,omitempty"`
	Testsenum            test.TestEnum             `protobuf:"varint,102,opt,name=testsenum,proto3,enum=tests.test.TestEnum" json:"testsenum,omitempty"`
	Mappedenum           MappedEnum                `protobuf:"varint,103,opt,name=mappedenum,proto3,enum=tests.MappedEnum" json:"mappedenum,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ExampleTable1) Descriptor 

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

func (*ExampleTable1) GetBytesField 

func (m *ExampleTable1) GetBytesField() []byte

func (*ExampleTable1) GetInnerEnum 

func (m *ExampleTable1) GetInnerEnum() ExampleTable1_InnerEnum

func (*ExampleTable1) GetInnerMessage 

func (m *ExampleTable1) GetInnerMessage() *ExampleTable1_InnerMessage

func (*ExampleTable1) GetKey 

func (m *ExampleTable1) GetKey() string

func (*ExampleTable1) GetMappedenum 

func (m *ExampleTable1) GetMappedenum() MappedEnum

func (*ExampleTable1) GetMyyenum 

func (m *ExampleTable1) GetMyyenum() MyEnum

func (*ExampleTable1) GetSkipOneOf 

func (m *ExampleTable1) GetSkipOneOf() isExampleTable1_SkipOneOf

func (*ExampleTable1) GetStartTime 

func (m *ExampleTable1) GetStartTime() *timestamp.Timestamp

func (*ExampleTable1) GetStringArray 

func (m *ExampleTable1) GetStringArray() []string

func (*ExampleTable1) GetTableId 

func (m *ExampleTable1) GetTableId() int32

func (*ExampleTable1) GetTestField 

func (m *ExampleTable1) GetTestField() *test.Test

func (*ExampleTable1) GetTestId 

func (m *ExampleTable1) GetTestId() int32

func (*ExampleTable1) GetTestOutMessage 

func (m *ExampleTable1) GetTestOutMessage() *test.Test

func (*ExampleTable1) GetTestValue 

func (m *ExampleTable1) GetTestValue() string

func (*ExampleTable1) GetTestsenum 

func (m *ExampleTable1) GetTestsenum() test.TestEnum

func (*ExampleTable1) GetValue 

func (m *ExampleTable1) GetValue() string

func (*ExampleTable1) ProtoMessage 

func (*ExampleTable1) ProtoMessage()

func (*ExampleTable1) Reset 

func (m *ExampleTable1) Reset()

func (*ExampleTable1) String 

func (m *ExampleTable1) String() string

func (*ExampleTable1) XXX_DiscardUnknown 

func (m *ExampleTable1) XXX_DiscardUnknown()

func (*ExampleTable1) XXX_Marshal 

func (m *ExampleTable1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExampleTable1) XXX_Merge 

func (m *ExampleTable1) XXX_Merge(src proto.Message)

func (*ExampleTable1) XXX_OneofWrappers 

func (*ExampleTable1) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExampleTable1) XXX_Size 

func (m *ExampleTable1) XXX_Size() int

func (*ExampleTable1) XXX_Unmarshal 

func (m *ExampleTable1) XXX_Unmarshal(b []byte) error

type ExampleTable1_InnerEnum 

type ExampleTable1_InnerEnum int32
const (
	ExampleTable1_OP_0 ExampleTable1_InnerEnum = 0
	ExampleTable1_OP_1 ExampleTable1_InnerEnum = 1
)

func (ExampleTable1_InnerEnum) EnumDescriptor 

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

func (ExampleTable1_InnerEnum) String 

func (x ExampleTable1_InnerEnum) String() string

type ExampleTable1_InnerMessage 

type ExampleTable1_InnerMessage struct {
	Id                   int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExampleTable1_InnerMessage) Descriptor 

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

func (*ExampleTable1_InnerMessage) GetId 

func (m *ExampleTable1_InnerMessage) GetId() int32

func (*ExampleTable1_InnerMessage) ProtoMessage 

func (*ExampleTable1_InnerMessage) ProtoMessage()

func (*ExampleTable1_InnerMessage) Reset 

func (m *ExampleTable1_InnerMessage) Reset()

func (*ExampleTable1_InnerMessage) String 

func (m *ExampleTable1_InnerMessage) String() string

func (*ExampleTable1_InnerMessage) XXX_DiscardUnknown 

func (m *ExampleTable1_InnerMessage) XXX_DiscardUnknown()

func (*ExampleTable1_InnerMessage) XXX_Marshal 

func (m *ExampleTable1_InnerMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExampleTable1_InnerMessage) XXX_Merge 

func (m *ExampleTable1_InnerMessage) XXX_Merge(src proto.Message)

func (*ExampleTable1_InnerMessage) XXX_Size 

func (m *ExampleTable1_InnerMessage) XXX_Size() int

func (*ExampleTable1_InnerMessage) XXX_Unmarshal 

func (m *ExampleTable1_InnerMessage) XXX_Unmarshal(b []byte) error

type ExampleTable1_TestId 

type ExampleTable1_TestId struct {
	TestId int32 `protobuf:"varint,1001,opt,name=test_id,json=testId,proto3,oneof"`
}

type ExampleTable1_TestOutMessage 

type ExampleTable1_TestOutMessage struct {
	TestOutMessage *test.Test `protobuf:"bytes,1003,opt,name=test_out_message,json=testOutMessage,proto3,oneof"`
}

type ExampleTable1_TestValue 

type ExampleTable1_TestValue struct {
	TestValue string `protobuf:"bytes,1002,opt,name=test_value,json=testValue,proto3,oneof"`
}

type ExternalTypeTestMessage 

type ExternalTypeTestMessage struct {
	Time                 *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ExternalTypeTestMessage) Descriptor 

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

func (*ExternalTypeTestMessage) GetTime 

func (m *ExternalTypeTestMessage) GetTime() *timestamp.Timestamp

func (*ExternalTypeTestMessage) ProtoMessage 

func (*ExternalTypeTestMessage) ProtoMessage()

func (*ExternalTypeTestMessage) Reset 

func (m *ExternalTypeTestMessage) Reset()

func (*ExternalTypeTestMessage) String 

func (m *ExternalTypeTestMessage) String() string

func (*ExternalTypeTestMessage) XXX_DiscardUnknown 

func (m *ExternalTypeTestMessage) XXX_DiscardUnknown()

func (*ExternalTypeTestMessage) XXX_Marshal 

func (m *ExternalTypeTestMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExternalTypeTestMessage) XXX_Merge 

func (m *ExternalTypeTestMessage) XXX_Merge(src proto.Message)

func (*ExternalTypeTestMessage) XXX_Size 

func (m *ExternalTypeTestMessage) XXX_Size() int

func (*ExternalTypeTestMessage) XXX_Unmarshal 

func (m *ExternalTypeTestMessage) XXX_Unmarshal(b []byte) error

type Hooks_NotEnabledService 

type Hooks_NotEnabledService interface {
}

type Hooks_Testservice1 

type Hooks_Testservice1 interface {
}

type Impl_NotEnabledService 

type Impl_NotEnabledService struct {
	QUERIES  *Queries_NotEnabledService
	HANDLERS RestOfHandlers_NotEnabledService
	DB       *sql.DB
	// contains filtered or unexported fields
}

func ImplNotEnabledService 

func ImplNotEnabledService(db *sql.DB, handlers RestOfHandlers_NotEnabledService, opts ...Opts_NotEnabledService) *Impl_NotEnabledService

type Impl_Testservice1 

type Impl_Testservice1 struct {
	QUERIES  *Queries_Testservice1
	HANDLERS RestOfHandlers_Testservice1
	DB       *sql.DB
	// contains filtered or unexported fields
}

func ImplTestservice1 

func ImplTestservice1(db *sql.DB, handlers RestOfHandlers_Testservice1, opts ...Opts_Testservice1) *Impl_Testservice1

func (*Impl_Testservice1) ClientStreamingExample 

func (this *Impl_Testservice1) ClientStreamingExample(stream Testservice1_ClientStreamingExampleServer) error

func (*Impl_Testservice1) ClientStreamingExampleTx 

func (this *Impl_Testservice1) ClientStreamingExampleTx(stream Testservice1_ClientStreamingExampleServer, tx persist.PersistTx) error

func (*Impl_Testservice1) ServerStreamSelect 

func (this *Impl_Testservice1) ServerStreamSelect(req *ExampleTable1, stream Testservice1_ServerStreamSelectServer) error

func (*Impl_Testservice1) ServerStreamSelectTx 

func (this *Impl_Testservice1) ServerStreamSelectTx(req *ExampleTable1, stream Testservice1_ServerStreamSelectServer, tx persist.PersistTx) error

func (*Impl_Testservice1) UnaryExample1 

func (this *Impl_Testservice1) UnaryExample1(ctx context.Context, req *ExampleTable1) (*ExampleTable1, error)

func (*Impl_Testservice1) UnaryExample2 

func (this *Impl_Testservice1) UnaryExample2(ctx context.Context, req *test.Test) (*ExampleTable1, error)

type In_Testservice1_ClientStreamingExample 

type In_Testservice1_ClientStreamingExample interface {
	GetTableId() int32
	GetKey() string
	GetValue() string
	GetInnerMessage() *ExampleTable1_InnerMessage
	GetInnerEnum() ExampleTable1_InnerEnum
	GetStringArray() []string
	GetBytesField() []byte
	GetStartTime() *timestamp.Timestamp
	GetTestField() *test.Test
	GetMyyenum() MyEnum
	GetTestsenum() test.TestEnum
	GetMappedenum() MappedEnum
}

type In_Testservice1_ServerStreamSelect 

type In_Testservice1_ServerStreamSelect interface {
	GetTableId() int32
	GetKey() string
	GetValue() string
	GetInnerMessage() *ExampleTable1_InnerMessage
	GetInnerEnum() ExampleTable1_InnerEnum
	GetStringArray() []string
	GetBytesField() []byte
	GetStartTime() *timestamp.Timestamp
	GetTestField() *test.Test
	GetMyyenum() MyEnum
	GetTestsenum() test.TestEnum
	GetMappedenum() MappedEnum
}

type In_Testservice1_UnaryExample1 

type In_Testservice1_UnaryExample1 interface {
	GetTableId() int32
	GetKey() string
	GetValue() string
	GetInnerMessage() *ExampleTable1_InnerMessage
	GetInnerEnum() ExampleTable1_InnerEnum
	GetStringArray() []string
	GetBytesField() []byte
	GetStartTime() *timestamp.Timestamp
	GetTestField() *test.Test
	GetMyyenum() MyEnum
	GetTestsenum() test.TestEnum
	GetMappedenum() MappedEnum
}

type In_Testservice1_UnaryExample2 

type In_Testservice1_UnaryExample2 interface {
	GetId() int32
	GetName() string
}

type Iter_Testservice1_ClientStreamingExample 

type Iter_Testservice1_ClientStreamingExample struct {
	// contains filtered or unexported fields
}

func (*Iter_Testservice1_ClientStreamingExample) Columns 

func (r *Iter_Testservice1_ClientStreamingExample) Columns() ([]string, error)

returns the known columns for this result

func (*Iter_Testservice1_ClientStreamingExample) Each 

func (this *Iter_Testservice1_ClientStreamingExample) Each(fun func(*Row_Testservice1_ClientStreamingExample) error) error

Each performs 'fun' on each row in the result set. Each respects the context passed to it. It will stop iteration, and returns this.ctx.Err() if encountered.

func (*Iter_Testservice1_ClientStreamingExample) IterInTypeExampleTable1 

func (this *Iter_Testservice1_ClientStreamingExample) IterInTypeExampleTable1()

func (*Iter_Testservice1_ClientStreamingExample) IterOutTypeEmpty 

func (this *Iter_Testservice1_ClientStreamingExample) IterOutTypeEmpty()

func (*Iter_Testservice1_ClientStreamingExample) Next 

func (this *Iter_Testservice1_ClientStreamingExample) Next() (*Row_Testservice1_ClientStreamingExample, bool)

Next returns the next scanned row out of the database, or (nil, false) if there are no more rows

func (*Iter_Testservice1_ClientStreamingExample) One 

func (this *Iter_Testservice1_ClientStreamingExample) One() *Row_Testservice1_ClientStreamingExample

One returns the sole row, or ensures an error if there was not one result when this row is converted

func (*Iter_Testservice1_ClientStreamingExample) Slice 

func (this *Iter_Testservice1_ClientStreamingExample) Slice() []*Row_Testservice1_ClientStreamingExample

Slice returns all rows found in the iterator as a Slice.

func (*Iter_Testservice1_ClientStreamingExample) Zero 

func (this *Iter_Testservice1_ClientStreamingExample) Zero() error

Zero returns an error if there were any rows in the result

type Iter_Testservice1_ServerStreamSelect 

type Iter_Testservice1_ServerStreamSelect struct {
	// contains filtered or unexported fields
}

func (*Iter_Testservice1_ServerStreamSelect) Columns 

func (r *Iter_Testservice1_ServerStreamSelect) Columns() ([]string, error)

returns the known columns for this result

func (*Iter_Testservice1_ServerStreamSelect) Each 

func (this *Iter_Testservice1_ServerStreamSelect) Each(fun func(*Row_Testservice1_ServerStreamSelect) error) error

Each performs 'fun' on each row in the result set. Each respects the context passed to it. It will stop iteration, and returns this.ctx.Err() if encountered.

func (*Iter_Testservice1_ServerStreamSelect) IterInTypeExampleTable1 

func (this *Iter_Testservice1_ServerStreamSelect) IterInTypeExampleTable1()

func (*Iter_Testservice1_ServerStreamSelect) IterOutTypeExampleTable1 

func (this *Iter_Testservice1_ServerStreamSelect) IterOutTypeExampleTable1()

func (*Iter_Testservice1_ServerStreamSelect) Next 

func (this *Iter_Testservice1_ServerStreamSelect) Next() (*Row_Testservice1_ServerStreamSelect, bool)

Next returns the next scanned row out of the database, or (nil, false) if there are no more rows

func (*Iter_Testservice1_ServerStreamSelect) One 

func (this *Iter_Testservice1_ServerStreamSelect) One() *Row_Testservice1_ServerStreamSelect

One returns the sole row, or ensures an error if there was not one result when this row is converted

func (*Iter_Testservice1_ServerStreamSelect) Slice 

func (this *Iter_Testservice1_ServerStreamSelect) Slice() []*Row_Testservice1_ServerStreamSelect

Slice returns all rows found in the iterator as a Slice.

func (*Iter_Testservice1_ServerStreamSelect) Zero 

func (this *Iter_Testservice1_ServerStreamSelect) Zero() error

Zero returns an error if there were any rows in the result

type Iter_Testservice1_UnaryExample1 

type Iter_Testservice1_UnaryExample1 struct {
	// contains filtered or unexported fields
}

func (*Iter_Testservice1_UnaryExample1) Columns 

func (r *Iter_Testservice1_UnaryExample1) Columns() ([]string, error)

returns the known columns for this result

func (*Iter_Testservice1_UnaryExample1) Each 

func (this *Iter_Testservice1_UnaryExample1) Each(fun func(*Row_Testservice1_UnaryExample1) error) error

Each performs 'fun' on each row in the result set. Each respects the context passed to it. It will stop iteration, and returns this.ctx.Err() if encountered.

func (*Iter_Testservice1_UnaryExample1) IterInTypeExampleTable1 

func (this *Iter_Testservice1_UnaryExample1) IterInTypeExampleTable1()

func (*Iter_Testservice1_UnaryExample1) IterOutTypeExampleTable1 

func (this *Iter_Testservice1_UnaryExample1) IterOutTypeExampleTable1()

func (*Iter_Testservice1_UnaryExample1) Next 

func (this *Iter_Testservice1_UnaryExample1) Next() (*Row_Testservice1_UnaryExample1, bool)

Next returns the next scanned row out of the database, or (nil, false) if there are no more rows

func (*Iter_Testservice1_UnaryExample1) One 

func (this *Iter_Testservice1_UnaryExample1) One() *Row_Testservice1_UnaryExample1

One returns the sole row, or ensures an error if there was not one result when this row is converted

func (*Iter_Testservice1_UnaryExample1) Slice 

func (this *Iter_Testservice1_UnaryExample1) Slice() []*Row_Testservice1_UnaryExample1

Slice returns all rows found in the iterator as a Slice.

func (*Iter_Testservice1_UnaryExample1) Zero 

func (this *Iter_Testservice1_UnaryExample1) Zero() error

Zero returns an error if there were any rows in the result

type Iter_Testservice1_UnaryExample2 

type Iter_Testservice1_UnaryExample2 struct {
	// contains filtered or unexported fields
}

func (*Iter_Testservice1_UnaryExample2) Columns 

func (r *Iter_Testservice1_UnaryExample2) Columns() ([]string, error)

returns the known columns for this result

func (*Iter_Testservice1_UnaryExample2) Each 

func (this *Iter_Testservice1_UnaryExample2) Each(fun func(*Row_Testservice1_UnaryExample2) error) error

Each performs 'fun' on each row in the result set. Each respects the context passed to it. It will stop iteration, and returns this.ctx.Err() if encountered.

func (*Iter_Testservice1_UnaryExample2) IterInTypeTestTest 

func (this *Iter_Testservice1_UnaryExample2) IterInTypeTestTest()

func (*Iter_Testservice1_UnaryExample2) IterOutTypeExampleTable1 

func (this *Iter_Testservice1_UnaryExample2) IterOutTypeExampleTable1()

func (*Iter_Testservice1_UnaryExample2) Next 

func (this *Iter_Testservice1_UnaryExample2) Next() (*Row_Testservice1_UnaryExample2, bool)

Next returns the next scanned row out of the database, or (nil, false) if there are no more rows

func (*Iter_Testservice1_UnaryExample2) One 

func (this *Iter_Testservice1_UnaryExample2) One() *Row_Testservice1_UnaryExample2

One returns the sole row, or ensures an error if there was not one result when this row is converted

func (*Iter_Testservice1_UnaryExample2) Slice 

func (this *Iter_Testservice1_UnaryExample2) Slice() []*Row_Testservice1_UnaryExample2

Slice returns all rows found in the iterator as a Slice.

func (*Iter_Testservice1_UnaryExample2) Zero 

func (this *Iter_Testservice1_UnaryExample2) Zero() error

Zero returns an error if there were any rows in the result

type MappedEnum 

type MappedEnum int32
const (
	MappedEnum_OPT_0 MappedEnum = 0
	MappedEnum_OPT_1 MappedEnum = 1
)

func (MappedEnum) EnumDescriptor 

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

func (MappedEnum) String 

func (x MappedEnum) String() string

type MappingImpl_Testservice1_MappedEnum 

type MappingImpl_Testservice1_MappedEnum interface {
	ToProto(**MappedEnum) error
	ToSql(*MappedEnum) sql.Scanner
	sql.Scanner
	driver.Valuer
}

type MappingImpl_Testservice1_TimestampTimestamp 

type MappingImpl_Testservice1_TimestampTimestamp interface {
	ToProto(**timestamp.Timestamp) error
	ToSql(*timestamp.Timestamp) sql.Scanner
	sql.Scanner
	driver.Valuer
}

type MyEnum 

type MyEnum int32
const (
	MyEnum_OPTION_0 MyEnum = 0
	MyEnum_OPTION_1 MyEnum = 1
)

func (MyEnum) EnumDescriptor 

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

func (MyEnum) String 

func (x MyEnum) String() string

type MyMappedEnum 

type MyMappedEnum struct {
	Status int32
}

func (*MyMappedEnum) Scan 

func (t *MyMappedEnum) Scan(src interface{}) error

func (MyMappedEnum) ToProto 

func (t MyMappedEnum) ToProto() MappedEnum

func (MyMappedEnum) ToSql 

func (t MyMappedEnum) ToSql(src MappedEnum) *MyMappedEnum

func (*MyMappedEnum) Value 

func (t *MyMappedEnum) Value() (driver.Value, error)

type NotEnabledServiceClient 

type NotEnabledServiceClient interface {
}

NotEnabledServiceClient is the client API for NotEnabledService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNotEnabledServiceClient 

func NewNotEnabledServiceClient(cc *grpc.ClientConn) NotEnabledServiceClient

type NotEnabledServiceServer 

type NotEnabledServiceServer interface {
}

NotEnabledServiceServer is the server API for NotEnabledService service.

type Opts_NotEnabledService 

type Opts_NotEnabledService struct {
	MAPPINGS TypeMappings_NotEnabledService
	HOOKS    Hooks_NotEnabledService
}

func OptsNotEnabledService 

func OptsNotEnabledService(hooks Hooks_NotEnabledService, mappings TypeMappings_NotEnabledService) Opts_NotEnabledService

type Opts_Testservice1 

type Opts_Testservice1 struct {
	MAPPINGS TypeMappings_Testservice1
	HOOKS    Hooks_Testservice1
}

func OptsTestservice1 

func OptsTestservice1(hooks Hooks_Testservice1, mappings TypeMappings_Testservice1) Opts_Testservice1

type Out_Testservice1_ClientStreamingExample 

type Out_Testservice1_ClientStreamingExample interface {
}

type Out_Testservice1_ServerStreamSelect 

type Out_Testservice1_ServerStreamSelect interface {
	GetTableId() int32
	GetKey() string
	GetValue() string
	GetInnerMessage() *ExampleTable1_InnerMessage
	GetInnerEnum() ExampleTable1_InnerEnum
	GetStringArray() []string
	GetBytesField() []byte
	GetStartTime() *timestamp.Timestamp
	GetTestField() *test.Test
	GetMyyenum() MyEnum
	GetTestsenum() test.TestEnum
	GetMappedenum() MappedEnum
}

type Out_Testservice1_UnaryExample1 

type Out_Testservice1_UnaryExample1 interface {
	GetTableId() int32
	GetKey() string
	GetValue() string
	GetInnerMessage() *ExampleTable1_InnerMessage
	GetInnerEnum() ExampleTable1_InnerEnum
	GetStringArray() []string
	GetBytesField() []byte
	GetStartTime() *timestamp.Timestamp
	GetTestField() *test.Test
	GetMyyenum() MyEnum
	GetTestsenum() test.TestEnum
	GetMappedenum() MappedEnum
}

type Out_Testservice1_UnaryExample2 

type Out_Testservice1_UnaryExample2 interface {
	GetTableId() int32
	GetKey() string
	GetValue() string
	GetInnerMessage() *ExampleTable1_InnerMessage
	GetInnerEnum() ExampleTable1_InnerEnum
	GetStringArray() []string
	GetBytesField() []byte
	GetStartTime() *timestamp.Timestamp
	GetTestField() *test.Test
	GetMyyenum() MyEnum
	GetTestsenum() test.TestEnum
	GetMappedenum() MappedEnum
}

type Queries_NotEnabledService 

type Queries_NotEnabledService struct {
	// contains filtered or unexported fields
}

Queries_NotEnabledService holds all the queries found the proto service option as methods

func QueriesNotEnabledService 

func QueriesNotEnabledService(opts ...Opts_NotEnabledService) *Queries_NotEnabledService

QueriesNotEnabledService returns all the known 'SQL' queires for the 'NotEnabledService' service. If no opts are provided default implementations are used.

type Queries_Testservice1 

type Queries_Testservice1 struct {
	// contains filtered or unexported fields
}

Queries_Testservice1 holds all the queries found the proto service option as methods

func QueriesTestservice1 

func QueriesTestservice1(opts ...Opts_Testservice1) *Queries_Testservice1

QueriesTestservice1 returns all the known 'SQL' queires for the 'Testservice1' service. If no opts are provided default implementations are used.

func (*Queries_Testservice1) ClientStreamingExample 

func (this *Queries_Testservice1) ClientStreamingExample(ctx context.Context, db persist.Runnable) *Query_Testservice1_ClientStreamingExample

ClientStreamingExample returns a struct that will perform the 'client_streaming_example' query. When Execute is called, it will use the following fields: [table_id]

func (*Queries_Testservice1) ServerStreamSelect 

func (this *Queries_Testservice1) ServerStreamSelect(ctx context.Context, db persist.Runnable) *Query_Testservice1_ServerStreamSelect

ServerStreamSelect returns a struct that will perform the 'server_stream_select' query. When Execute is called, it will use the following fields: [table_id]

func (*Queries_Testservice1) UnaryExample1 

func (this *Queries_Testservice1) UnaryExample1(ctx context.Context, db persist.Runnable) *Query_Testservice1_UnaryExample1

UnaryExample1 returns a struct that will perform the 'unary_example1' query. When Execute is called, it will use the following fields: [table_id]

func (*Queries_Testservice1) UnaryExample2 

func (this *Queries_Testservice1) UnaryExample2(ctx context.Context, db persist.Runnable) *Query_Testservice1_UnaryExample2

UnaryExample2 returns a struct that will perform the 'unary_example2' query. When Execute is called, it will use the following fields: [id]

type Query_Testservice1_ClientStreamingExample 

type Query_Testservice1_ClientStreamingExample struct {
	// contains filtered or unexported fields
}

Query_Testservice1_ClientStreamingExample (future doc string needed)

func (*Query_Testservice1_ClientStreamingExample) Execute 

func (this *Query_Testservice1_ClientStreamingExample) Execute(x In_Testservice1_ClientStreamingExample) *Iter_Testservice1_ClientStreamingExample

Executes the query 'client_streaming_example' with parameters retrieved from x. Fields used: [table_id]

func (*Query_Testservice1_ClientStreamingExample) QueryInType_ExampleTable1 

func (this *Query_Testservice1_ClientStreamingExample) QueryInType_ExampleTable1()

func (*Query_Testservice1_ClientStreamingExample) QueryOutType_Empty 

func (this *Query_Testservice1_ClientStreamingExample) QueryOutType_Empty()

type Query_Testservice1_ServerStreamSelect 

type Query_Testservice1_ServerStreamSelect struct {
	// contains filtered or unexported fields
}

Query_Testservice1_ServerStreamSelect (future doc string needed)

func (*Query_Testservice1_ServerStreamSelect) Execute 

func (this *Query_Testservice1_ServerStreamSelect) Execute(x In_Testservice1_ServerStreamSelect) *Iter_Testservice1_ServerStreamSelect

Executes the query 'server_stream_select' with parameters retrieved from x. Fields used: [table_id]

func (*Query_Testservice1_ServerStreamSelect) QueryInType_ExampleTable1 

func (this *Query_Testservice1_ServerStreamSelect) QueryInType_ExampleTable1()

func (*Query_Testservice1_ServerStreamSelect) QueryOutType_ExampleTable1 

func (this *Query_Testservice1_ServerStreamSelect) QueryOutType_ExampleTable1()

type Query_Testservice1_UnaryExample1 

type Query_Testservice1_UnaryExample1 struct {
	// contains filtered or unexported fields
}

Query_Testservice1_UnaryExample1 (future doc string needed)

func (*Query_Testservice1_UnaryExample1) Execute 

func (this *Query_Testservice1_UnaryExample1) Execute(x In_Testservice1_UnaryExample1) *Iter_Testservice1_UnaryExample1

Executes the query 'unary_example1' with parameters retrieved from x. Fields used: [table_id]

func (*Query_Testservice1_UnaryExample1) QueryInType_ExampleTable1 

func (this *Query_Testservice1_UnaryExample1) QueryInType_ExampleTable1()

func (*Query_Testservice1_UnaryExample1) QueryOutType_ExampleTable1 

func (this *Query_Testservice1_UnaryExample1) QueryOutType_ExampleTable1()

type Query_Testservice1_UnaryExample2 

type Query_Testservice1_UnaryExample2 struct {
	// contains filtered or unexported fields
}

Query_Testservice1_UnaryExample2 (future doc string needed)

func (*Query_Testservice1_UnaryExample2) Execute 

func (this *Query_Testservice1_UnaryExample2) Execute(x In_Testservice1_UnaryExample2) *Iter_Testservice1_UnaryExample2

Executes the query 'unary_example2' with parameters retrieved from x. Fields used: [id]

func (*Query_Testservice1_UnaryExample2) QueryInType_Test 

func (this *Query_Testservice1_UnaryExample2) QueryInType_Test()

func (*Query_Testservice1_UnaryExample2) QueryOutType_ExampleTable1 

func (this *Query_Testservice1_UnaryExample2) QueryOutType_ExampleTable1()

type RestOfHandlers_NotEnabledService 

type RestOfHandlers_NotEnabledService interface {
}

type RestOfHandlers_Testservice1 

type RestOfHandlers_Testservice1 interface {
}

type Row_Testservice1_ClientStreamingExample 

type Row_Testservice1_ClientStreamingExample struct {
	// contains filtered or unexported fields
}

func (*Row_Testservice1_ClientStreamingExample) CountRows 

func (this *Row_Testservice1_ClientStreamingExample) CountRows() (*CountRows, error)

func (*Row_Testservice1_ClientStreamingExample) Empty 

func (this *Row_Testservice1_ClientStreamingExample) Empty() (*Empty, error)

func (*Row_Testservice1_ClientStreamingExample) Proto 

func (this *Row_Testservice1_ClientStreamingExample) Proto() (*Empty, error)

func (*Row_Testservice1_ClientStreamingExample) Unwrap 

func (this *Row_Testservice1_ClientStreamingExample) Unwrap(pointerToMsg proto.Message) error

Unwrap takes an address to a proto.Message as its only parameter Unwrap can only set into output protos of that match method return types + the out option on the query itself

type Row_Testservice1_ServerStreamSelect 

type Row_Testservice1_ServerStreamSelect struct {
	// contains filtered or unexported fields
}

func (*Row_Testservice1_ServerStreamSelect) ExampleTable1 

func (this *Row_Testservice1_ServerStreamSelect) ExampleTable1() (*ExampleTable1, error)

func (*Row_Testservice1_ServerStreamSelect) Proto 

func (this *Row_Testservice1_ServerStreamSelect) Proto() (*ExampleTable1, error)

func (*Row_Testservice1_ServerStreamSelect) Unwrap 

func (this *Row_Testservice1_ServerStreamSelect) Unwrap(pointerToMsg proto.Message) error

Unwrap takes an address to a proto.Message as its only parameter Unwrap can only set into output protos of that match method return types + the out option on the query itself

type Row_Testservice1_UnaryExample1 

type Row_Testservice1_UnaryExample1 struct {
	// contains filtered or unexported fields
}

func (*Row_Testservice1_UnaryExample1) ExampleTable1 

func (this *Row_Testservice1_UnaryExample1) ExampleTable1() (*ExampleTable1, error)

func (*Row_Testservice1_UnaryExample1) Proto 

func (this *Row_Testservice1_UnaryExample1) Proto() (*ExampleTable1, error)

func (*Row_Testservice1_UnaryExample1) Unwrap 

func (this *Row_Testservice1_UnaryExample1) Unwrap(pointerToMsg proto.Message) error

Unwrap takes an address to a proto.Message as its only parameter Unwrap can only set into output protos of that match method return types + the out option on the query itself

type Row_Testservice1_UnaryExample2 

type Row_Testservice1_UnaryExample2 struct {
	// contains filtered or unexported fields
}

func (*Row_Testservice1_UnaryExample2) ExampleTable1 

func (this *Row_Testservice1_UnaryExample2) ExampleTable1() (*ExampleTable1, error)

func (*Row_Testservice1_UnaryExample2) Proto 

func (this *Row_Testservice1_UnaryExample2) Proto() (*ExampleTable1, error)

func (*Row_Testservice1_UnaryExample2) Unwrap 

func (this *Row_Testservice1_UnaryExample2) Unwrap(pointerToMsg proto.Message) error

Unwrap takes an address to a proto.Message as its only parameter Unwrap can only set into output protos of that match method return types + the out option on the query itself

type Runnable 

type Runnable interface {
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
}

type Testservice1Client 

type Testservice1Client interface {
	UnaryExample1(ctx context.Context, in *ExampleTable1, opts ...grpc.CallOption) (*ExampleTable1, error)
	UnaryExample2(ctx context.Context, in *test.Test, opts ...grpc.CallOption) (*ExampleTable1, error)
	ServerStreamSelect(ctx context.Context, in *ExampleTable1, opts ...grpc.CallOption) (Testservice1_ServerStreamSelectClient, error)
	ClientStreamingExample(ctx context.Context, opts ...grpc.CallOption) (Testservice1_ClientStreamingExampleClient, error)
}

Testservice1Client is the client API for Testservice1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTestservice1Client 

func NewTestservice1Client(cc *grpc.ClientConn) Testservice1Client

type Testservice1Server 

type Testservice1Server interface {
	UnaryExample1(context.Context, *ExampleTable1) (*ExampleTable1, error)
	UnaryExample2(context.Context, *test.Test) (*ExampleTable1, error)
	ServerStreamSelect(*ExampleTable1, Testservice1_ServerStreamSelectServer) error
	ClientStreamingExample(Testservice1_ClientStreamingExampleServer) error
}

Testservice1Server is the server API for Testservice1 service.

type Testservice1_ClientStreamingExampleClient 

type Testservice1_ClientStreamingExampleClient interface {
	Send(*ExampleTable1) error
	CloseAndRecv() (*CountRows, error)
	grpc.ClientStream
}

type Testservice1_ClientStreamingExampleServer 

type Testservice1_ClientStreamingExampleServer interface {
	SendAndClose(*CountRows) error
	Recv() (*ExampleTable1, error)
	grpc.ServerStream
}

type Testservice1_ServerStreamSelectClient 

type Testservice1_ServerStreamSelectClient interface {
	Recv() (*ExampleTable1, error)
	grpc.ClientStream
}

type Testservice1_ServerStreamSelectServer 

type Testservice1_ServerStreamSelectServer interface {
	Send(*ExampleTable1) error
	grpc.ServerStream
}

type TypeMappings_NotEnabledService 

type TypeMappings_NotEnabledService interface {
}

type TypeMappings_Testservice1 

type TypeMappings_Testservice1 interface {
	TimestampTimestamp() MappingImpl_Testservice1_TimestampTimestamp
	MappedEnum() MappingImpl_Testservice1_MappedEnum
}

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.