import_tests

Documentation

Overview

Package import_tests is a generated protocol buffer package.

It is generated from these files:

examples/spanner/import_tests/persist_and_go.proto

It has these top-level messages:

ExampleTable
AggExampleTables

Index

• func RegisterMySpannerServer(s *grpc.Server, srv MySpannerServer)
• type AggExampleTables
  • func (*AggExampleTables) Descriptor() ([]byte, []int)
  • func (m *AggExampleTables) GetExampleTables() []*ExampleTable
  • func (*AggExampleTables) ProtoMessage()
  • func (m *AggExampleTables) Reset()
  • func (m *AggExampleTables) String() string
• type ExampleTable
  • func (*ExampleTable) Descriptor() ([]byte, []int)
  • func (m *ExampleTable) GetId() int64
  • func (m *ExampleTable) GetName() string
  • func (m *ExampleTable) GetStartTime() *google_protobuf1.Timestamp
  • func (*ExampleTable) ProtoMessage()
  • func (m *ExampleTable) Reset()
  • func (m *ExampleTable) String() string
• type MySpannerClient
  • func NewMySpannerClient(cc *grpc.ClientConn) MySpannerClient
• type MySpannerServer
• type MySpanner_ClientStreamClient
• type MySpanner_ClientStreamServer
• type MySpanner_ServerStreamClient
• type MySpanner_ServerStreamServer

Functions

func RegisterMySpannerServer

func RegisterMySpannerServer(s *grpc.Server, srv MySpannerServer)

Types

type AggExampleTables

type AggExampleTables struct {
	ExampleTables []*ExampleTable `protobuf:"bytes,1,rep,name=example_tables,json=exampleTables" json:"example_tables,omitempty"`
}

func (*AggExampleTables) Descriptor

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

func (*AggExampleTables) GetExampleTables

func (m *AggExampleTables) GetExampleTables() []*ExampleTable

func (*AggExampleTables) ProtoMessage

func (*AggExampleTables) ProtoMessage()

func (*AggExampleTables) Reset

func (m *AggExampleTables) Reset()

func (*AggExampleTables) String

func (m *AggExampleTables) String() string

type ExampleTable

type ExampleTable struct {
	Id        int64                       `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	StartTime *google_protobuf1.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime" json:"start_time,omitempty"`
	Name      string                      `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
}

func (*ExampleTable) Descriptor

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

func (*ExampleTable) GetId

func (m *ExampleTable) GetId() int64

func (*ExampleTable) GetName

func (m *ExampleTable) GetName() string

func (*ExampleTable) GetStartTime

func (m *ExampleTable) GetStartTime() *google_protobuf1.Timestamp

func (*ExampleTable) ProtoMessage

func (*ExampleTable) ProtoMessage()

func (*ExampleTable) Reset

func (m *ExampleTable) Reset()

func (*ExampleTable) String

func (m *ExampleTable) String() string

type MySpannerClient

type MySpannerClient interface {
	UniaryInsert(ctx context.Context, in *examples_test.ExampleTable, opts ...grpc.CallOption) (*ExampleTable, error)
	ServerStream(ctx context.Context, in *examples_test.ExampleTable, opts ...grpc.CallOption) (MySpanner_ServerStreamClient, error)
	ClientStream(ctx context.Context, opts ...grpc.CallOption) (MySpanner_ClientStreamClient, error)
}

func NewMySpannerClient

func NewMySpannerClient(cc *grpc.ClientConn) MySpannerClient

type MySpannerServer

type MySpannerServer interface {
	UniaryInsert(context.Context, *examples_test.ExampleTable) (*ExampleTable, error)
	ServerStream(*examples_test.ExampleTable, MySpanner_ServerStreamServer) error
	ClientStream(MySpanner_ClientStreamServer) error
}

type MySpanner_ClientStreamClient

type MySpanner_ClientStreamClient interface {
	Send(*examples_test.ExampleTable) error
	CloseAndRecv() (*AggExampleTables, error)
	grpc.ClientStream
}

type MySpanner_ClientStreamServer

type MySpanner_ClientStreamServer interface {
	SendAndClose(*AggExampleTables) error
	Recv() (*examples_test.ExampleTable, error)
	grpc.ServerStream
}

type MySpanner_ServerStreamClient

type MySpanner_ServerStreamClient interface {
	Recv() (*ExampleTable, error)
	grpc.ClientStream
}

type MySpanner_ServerStreamServer

type MySpanner_ServerStreamServer interface {
	Send(*ExampleTable) error
	grpc.ServerStream
}