persist_lib

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Jan 19, 2018 License: BSD-3-Clause Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DefaultClientStreamDeleteHandler

func DefaultClientStreamDeleteHandler(accessor SpannerClientGetter) func(context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))

func DefaultClientStreamInsertHandler

func DefaultClientStreamInsertHandler(accessor SpannerClientGetter) func(context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))

func DefaultClientStreamUpdateHandler

func DefaultClientStreamUpdateHandler(accessor SpannerClientGetter) func(context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))

func DefaultClientStreamUpdateWithHooksHandler

func DefaultClientStreamUpdateWithHooksHandler(accessor SpannerClientGetter) func(context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))

func DefaultExtraUnaryHandler

func DefaultExtraUnaryHandler(accessor SpannerClientGetter) func(context.Context, *Test_NumRowsForExtraSrv, func(*spanner.Row)) error

func DefaultNoArgsHandler

func DefaultNoArgsHandler(accessor SpannerClientGetter) func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error

func DefaultServerStreamHandler

func DefaultServerStreamHandler(accessor SpannerClientGetter) func(context.Context, *Test_NameForMySpanner, func(*spanner.Row)) error

func DefaultServerStreamWithHooksHandler

func DefaultServerStreamWithHooksHandler(accessor SpannerClientGetter) func(context.Context, *Test_NameForMySpanner, func(*spanner.Row)) error

func DefaultTestEverythingHandler

func DefaultTestEverythingHandler(accessor SpannerClientGetter) func(context.Context, *HasTimestampForMySpanner, func(*spanner.Row)) error

func DefaultTestNestHandler

func DefaultTestNestHandler(accessor SpannerClientGetter) func(context.Context, *SomethingForMySpanner, func(*spanner.Row)) error

func DefaultUniaryDeleteRangeHandler

func DefaultUniaryDeleteRangeHandler(accessor SpannerClientGetter) func(context.Context, *Test_ExampleTableRangeForMySpanner, func(*spanner.Row)) error

func DefaultUniaryDeleteSingleHandler

func DefaultUniaryDeleteSingleHandler(accessor SpannerClientGetter) func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error

func DefaultUniaryDeleteWithHooksHandler

func DefaultUniaryDeleteWithHooksHandler(accessor SpannerClientGetter) func(context.Context, *Test_ExampleTableRangeForMySpanner, func(*spanner.Row)) error

func DefaultUniaryInsertHandler

func DefaultUniaryInsertHandler(accessor SpannerClientGetter) func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error

func DefaultUniaryInsertWithHooksHandler

func DefaultUniaryInsertWithHooksHandler(accessor SpannerClientGetter) func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error

func DefaultUniarySelectHandler

func DefaultUniarySelectHandler(accessor SpannerClientGetter) func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error

func DefaultUniarySelectWithDirectivesHandler

func DefaultUniarySelectWithDirectivesHandler(accessor SpannerClientGetter) func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error

func DefaultUniarySelectWithHooksHandler

func DefaultUniarySelectWithHooksHandler(accessor SpannerClientGetter) func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error

func DefaultUniaryUpdateHandler

func DefaultUniaryUpdateHandler(accessor SpannerClientGetter) func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error

func DefaultUniaryUpdateWithHooksHandler

func DefaultUniaryUpdateWithHooksHandler(accessor SpannerClientGetter) func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error

Types

type ExtraSrvExtraUnaryQueryParams

type ExtraSrvExtraUnaryQueryParams interface {
}

type ExtraSrvMethodReceiver

type ExtraSrvMethodReceiver struct {
	Handlers ExtraSrvQueryHandlers
}

func (*ExtraSrvMethodReceiver) ExtraUnary

func (p *ExtraSrvMethodReceiver) ExtraUnary(ctx context.Context, params *Test_NumRowsForExtraSrv, next func(*spanner.Row)) error

next must be called on each result row

type ExtraSrvQueryHandlers

type ExtraSrvQueryHandlers struct {
	ExtraUnaryHandler func(context.Context, *Test_NumRowsForExtraSrv, func(*spanner.Row)) error
}

type HasTimestampForMySpanner

type HasTimestampForMySpanner struct {
	Time   interface{}
	Some   []byte
	Str    string
	Table  []byte
	Strs   []string
	Tables [][]byte
	Somes  [][]byte
	Times  [][]byte
}

func (*HasTimestampForMySpanner) GetSome

func (p *HasTimestampForMySpanner) GetSome() []byte

func (*HasTimestampForMySpanner) GetSomes

func (p *HasTimestampForMySpanner) GetSomes() [][]byte

func (*HasTimestampForMySpanner) GetStr

func (p *HasTimestampForMySpanner) GetStr() string

func (*HasTimestampForMySpanner) GetStrs

func (p *HasTimestampForMySpanner) GetStrs() []string

func (*HasTimestampForMySpanner) GetTable

func (p *HasTimestampForMySpanner) GetTable() []byte

func (*HasTimestampForMySpanner) GetTables

func (p *HasTimestampForMySpanner) GetTables() [][]byte

func (*HasTimestampForMySpanner) GetTime

func (p *HasTimestampForMySpanner) GetTime() interface{}

this could be used in a query, so generate the getters/setters

func (*HasTimestampForMySpanner) GetTimes

func (p *HasTimestampForMySpanner) GetTimes() [][]byte

func (*HasTimestampForMySpanner) SetSome

func (p *HasTimestampForMySpanner) SetSome(param []byte)

func (*HasTimestampForMySpanner) SetSomes

func (p *HasTimestampForMySpanner) SetSomes(param [][]byte)

func (*HasTimestampForMySpanner) SetStr

func (p *HasTimestampForMySpanner) SetStr(param string)

func (*HasTimestampForMySpanner) SetStrs

func (p *HasTimestampForMySpanner) SetStrs(param []string)

func (*HasTimestampForMySpanner) SetTable

func (p *HasTimestampForMySpanner) SetTable(param []byte)

func (*HasTimestampForMySpanner) SetTables

func (p *HasTimestampForMySpanner) SetTables(param [][]byte)

func (*HasTimestampForMySpanner) SetTime

func (p *HasTimestampForMySpanner) SetTime(param interface{})

func (*HasTimestampForMySpanner) SetTimes

func (p *HasTimestampForMySpanner) SetTimes(param [][]byte)

type MySpannerClientStreamDeleteQueryParams

type MySpannerClientStreamDeleteQueryParams interface {
	GetId() int64
}

type MySpannerClientStreamInsertQueryParams

type MySpannerClientStreamInsertQueryParams interface {
	GetId() int64
	GetStartTime() interface{}
	GetName() string
}

type MySpannerClientStreamUpdateQueryParams

type MySpannerClientStreamUpdateQueryParams interface {
	GetName() string
	GetId() int64
	GetStartTime() interface{}
}

type MySpannerClientStreamUpdateWithHooksQueryParams

type MySpannerClientStreamUpdateWithHooksQueryParams interface {
	GetName() string
	GetId() int64
}

type MySpannerMethodReceiver

type MySpannerMethodReceiver struct {
	Handlers MySpannerQueryHandlers
}

func (*MySpannerMethodReceiver) ClientStreamDelete

func (p *MySpannerMethodReceiver) ClientStreamDelete(ctx context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))

given a context, returns two functions. (feed, stop) feed will be called once for every row recieved by the handler stop will be called when the client is done streaming. it expects a row to be returned, or nil.

func (*MySpannerMethodReceiver) ClientStreamInsert

func (p *MySpannerMethodReceiver) ClientStreamInsert(ctx context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))

given a context, returns two functions. (feed, stop) feed will be called once for every row recieved by the handler stop will be called when the client is done streaming. it expects a row to be returned, or nil.

func (*MySpannerMethodReceiver) ClientStreamUpdate

func (p *MySpannerMethodReceiver) ClientStreamUpdate(ctx context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))

given a context, returns two functions. (feed, stop) feed will be called once for every row recieved by the handler stop will be called when the client is done streaming. it expects a row to be returned, or nil.

func (*MySpannerMethodReceiver) ClientStreamUpdateWithHooks

func (p *MySpannerMethodReceiver) ClientStreamUpdateWithHooks(ctx context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))

given a context, returns two functions. (feed, stop) feed will be called once for every row recieved by the handler stop will be called when the client is done streaming. it expects a row to be returned, or nil.

func (*MySpannerMethodReceiver) NoArgs

next must be called on each result row

func (*MySpannerMethodReceiver) ServerStream

func (p *MySpannerMethodReceiver) ServerStream(ctx context.Context, params *Test_NameForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) ServerStreamWithHooks

func (p *MySpannerMethodReceiver) ServerStreamWithHooks(ctx context.Context, params *Test_NameForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) TestEverything

func (p *MySpannerMethodReceiver) TestEverything(ctx context.Context, params *HasTimestampForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) TestNest

func (p *MySpannerMethodReceiver) TestNest(ctx context.Context, params *SomethingForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) UniaryDeleteRange

func (p *MySpannerMethodReceiver) UniaryDeleteRange(ctx context.Context, params *Test_ExampleTableRangeForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) UniaryDeleteSingle

func (p *MySpannerMethodReceiver) UniaryDeleteSingle(ctx context.Context, params *Test_ExampleTableForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) UniaryDeleteWithHooks

func (p *MySpannerMethodReceiver) UniaryDeleteWithHooks(ctx context.Context, params *Test_ExampleTableRangeForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) UniaryInsert

func (p *MySpannerMethodReceiver) UniaryInsert(ctx context.Context, params *Test_ExampleTableForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) UniaryInsertWithHooks

func (p *MySpannerMethodReceiver) UniaryInsertWithHooks(ctx context.Context, params *Test_ExampleTableForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) UniarySelect

func (p *MySpannerMethodReceiver) UniarySelect(ctx context.Context, params *Test_ExampleTableForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) UniarySelectWithDirectives

func (p *MySpannerMethodReceiver) UniarySelectWithDirectives(ctx context.Context, params *Test_ExampleTableForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) UniarySelectWithHooks

func (p *MySpannerMethodReceiver) UniarySelectWithHooks(ctx context.Context, params *Test_ExampleTableForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) UniaryUpdate

func (p *MySpannerMethodReceiver) UniaryUpdate(ctx context.Context, params *Test_ExampleTableForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

func (*MySpannerMethodReceiver) UniaryUpdateWithHooks

func (p *MySpannerMethodReceiver) UniaryUpdateWithHooks(ctx context.Context, params *Test_ExampleTableForMySpanner, next func(*spanner.Row)) error

next must be called on each result row

type MySpannerNoArgsQueryParams

type MySpannerNoArgsQueryParams interface {
}

type MySpannerQueryHandlers

type MySpannerQueryHandlers struct {
	UniaryInsertHandler                func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error
	UniarySelectHandler                func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error
	TestNestHandler                    func(context.Context, *SomethingForMySpanner, func(*spanner.Row)) error
	TestEverythingHandler              func(context.Context, *HasTimestampForMySpanner, func(*spanner.Row)) error
	UniarySelectWithDirectivesHandler  func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error
	UniaryUpdateHandler                func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error
	UniaryDeleteRangeHandler           func(context.Context, *Test_ExampleTableRangeForMySpanner, func(*spanner.Row)) error
	UniaryDeleteSingleHandler          func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error
	NoArgsHandler                      func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error
	ServerStreamHandler                func(context.Context, *Test_NameForMySpanner, func(*spanner.Row)) error
	ClientStreamInsertHandler          func(context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))
	ClientStreamDeleteHandler          func(context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))
	ClientStreamUpdateHandler          func(context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))
	UniaryInsertWithHooksHandler       func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error
	UniarySelectWithHooksHandler       func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error
	UniaryUpdateWithHooksHandler       func(context.Context, *Test_ExampleTableForMySpanner, func(*spanner.Row)) error
	UniaryDeleteWithHooksHandler       func(context.Context, *Test_ExampleTableRangeForMySpanner, func(*spanner.Row)) error
	ServerStreamWithHooksHandler       func(context.Context, *Test_NameForMySpanner, func(*spanner.Row)) error
	ClientStreamUpdateWithHooksHandler func(context.Context) (func(*Test_ExampleTableForMySpanner), func() (*spanner.Row, error))
}

type MySpannerServerStreamQueryParams

type MySpannerServerStreamQueryParams interface {
}

type MySpannerServerStreamWithHooksQueryParams

type MySpannerServerStreamWithHooksQueryParams interface {
}

type MySpannerTestEverythingQueryParams

type MySpannerTestEverythingQueryParams interface {
	GetTables() [][]byte
	GetTime() interface{}
	GetSome() []byte
	GetStr() string
	GetTable() []byte
	GetTimes() [][]byte
	GetSomes() [][]byte
	GetStrs() []string
}

type MySpannerTestNestQueryParams

type MySpannerTestNestQueryParams interface {
	GetThing() []byte
}

type MySpannerUniaryDeleteRangeQueryParams

type MySpannerUniaryDeleteRangeQueryParams interface {
	GetStartId() int64
	GetEndId() int64
}

type MySpannerUniaryDeleteSingleQueryParams

type MySpannerUniaryDeleteSingleQueryParams interface {
	GetId() int64
}

type MySpannerUniaryDeleteWithHooksQueryParams

type MySpannerUniaryDeleteWithHooksQueryParams interface {
	GetStartId() int64
	GetEndId() int64
}

type MySpannerUniaryInsertQueryParams

type MySpannerUniaryInsertQueryParams interface {
	GetId() int64
	GetStartTime() interface{}
	GetName() string
}

type MySpannerUniaryInsertWithHooksQueryParams

type MySpannerUniaryInsertWithHooksQueryParams interface {
	GetId() int64
	GetStartTime() interface{}
	GetName() string
}

type MySpannerUniarySelectQueryParams

type MySpannerUniarySelectQueryParams interface {
	GetId() int64
	GetName() string
}

type MySpannerUniarySelectWithDirectivesQueryParams

type MySpannerUniarySelectWithDirectivesQueryParams interface {
	GetId() int64
	GetName() string
}

type MySpannerUniarySelectWithHooksQueryParams

type MySpannerUniarySelectWithHooksQueryParams interface {
	GetId() int64
}

type MySpannerUniaryUpdateQueryParams

type MySpannerUniaryUpdateQueryParams interface {
	GetStartTime() interface{}
	GetName() string
	GetId() int64
}

type MySpannerUniaryUpdateWithHooksQueryParams

type MySpannerUniaryUpdateWithHooksQueryParams interface {
	GetName() string
	GetId() int64
	GetStartTime() interface{}
}

type SomethingForMySpanner

type SomethingForMySpanner struct {
	Thing      []byte
	Myenum     int32
	Mappedenum int32
}

func (*SomethingForMySpanner) GetMappedenum

func (p *SomethingForMySpanner) GetMappedenum() int32

func (*SomethingForMySpanner) GetMyenum

func (p *SomethingForMySpanner) GetMyenum() int32

func (*SomethingForMySpanner) GetThing

func (p *SomethingForMySpanner) GetThing() []byte

this could be used in a query, so generate the getters/setters

func (*SomethingForMySpanner) SetMappedenum

func (p *SomethingForMySpanner) SetMappedenum(param int32)

func (*SomethingForMySpanner) SetMyenum

func (p *SomethingForMySpanner) SetMyenum(param int32)

func (*SomethingForMySpanner) SetThing

func (p *SomethingForMySpanner) SetThing(param []byte)

type SpannerClientGetter

type SpannerClientGetter func() (*spanner.Client, error)

func NewSpannerClientGetter

func NewSpannerClientGetter(cli *spanner.Client) SpannerClientGetter

type Test_ExampleTableForExtraSrv

type Test_ExampleTableForExtraSrv struct {
	Id        int64
	StartTime []byte
	Name      string
}

func (*Test_ExampleTableForExtraSrv) GetId

this could be used in a query, so generate the getters/setters

func (*Test_ExampleTableForExtraSrv) GetName

func (p *Test_ExampleTableForExtraSrv) GetName() string

func (*Test_ExampleTableForExtraSrv) GetStartTime

func (p *Test_ExampleTableForExtraSrv) GetStartTime() []byte

func (*Test_ExampleTableForExtraSrv) SetId

func (p *Test_ExampleTableForExtraSrv) SetId(param int64)

func (*Test_ExampleTableForExtraSrv) SetName

func (p *Test_ExampleTableForExtraSrv) SetName(param string)

func (*Test_ExampleTableForExtraSrv) SetStartTime

func (p *Test_ExampleTableForExtraSrv) SetStartTime(param []byte)

type Test_ExampleTableForMySpanner

type Test_ExampleTableForMySpanner struct {
	Id        int64
	StartTime interface{}
	Name      string
}

func (*Test_ExampleTableForMySpanner) GetId

this could be used in a query, so generate the getters/setters

func (*Test_ExampleTableForMySpanner) GetName

func (*Test_ExampleTableForMySpanner) GetStartTime

func (p *Test_ExampleTableForMySpanner) GetStartTime() interface{}

func (*Test_ExampleTableForMySpanner) SetId

func (p *Test_ExampleTableForMySpanner) SetId(param int64)

func (*Test_ExampleTableForMySpanner) SetName

func (p *Test_ExampleTableForMySpanner) SetName(param string)

func (*Test_ExampleTableForMySpanner) SetStartTime

func (p *Test_ExampleTableForMySpanner) SetStartTime(param interface{})

type Test_ExampleTableRangeForMySpanner

type Test_ExampleTableRangeForMySpanner struct {
	StartId int64
	EndId   int64
}

func (*Test_ExampleTableRangeForMySpanner) GetEndId

func (*Test_ExampleTableRangeForMySpanner) GetStartId

func (p *Test_ExampleTableRangeForMySpanner) GetStartId() int64

this could be used in a query, so generate the getters/setters

func (*Test_ExampleTableRangeForMySpanner) SetEndId

func (p *Test_ExampleTableRangeForMySpanner) SetEndId(param int64)

func (*Test_ExampleTableRangeForMySpanner) SetStartId

func (p *Test_ExampleTableRangeForMySpanner) SetStartId(param int64)

type Test_NameForMySpanner

type Test_NameForMySpanner struct {
	Name string
}

func (*Test_NameForMySpanner) GetName

func (p *Test_NameForMySpanner) GetName() string

this could be used in a query, so generate the getters/setters

func (*Test_NameForMySpanner) SetName

func (p *Test_NameForMySpanner) SetName(param string)

type Test_NumRowsForExtraSrv

type Test_NumRowsForExtraSrv struct {
	Count int64
}

func (*Test_NumRowsForExtraSrv) GetCount

func (p *Test_NumRowsForExtraSrv) GetCount() int64

this could be used in a query, so generate the getters/setters

func (*Test_NumRowsForExtraSrv) SetCount

func (p *Test_NumRowsForExtraSrv) SetCount(param int64)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL