Documentation
¶
Overview ¶
Package pb is a generated protocol buffer package.
It is generated from these files:
pb/user.proto
It has these top-level messages:
User Friends Empty
This file is generated by protoc-gen-persist Source File: pb/user.proto DO NOT EDIT !
Index ¶
- func EmptyToUServPersistType(req *Empty) (*persist_lib.EmptyForUServ, error)
- func FriendsToUServPersistType(req *Friends) (*persist_lib.FriendsForUServ, error)
- func IterUServEmptyProto(iter *spanner.RowIterator, next func(i *Empty) error) error
- func IterUServUserProto(iter *spanner.RowIterator, next func(i *User) error) error
- func RegisterUServServer(s *grpc.Server, srv UServServer)
- func UserToUServPersistType(req *User) (*persist_lib.UserForUServ, error)
- type Empty
- type Friends
- type RestOfUServHandlers
- type TimeString
- type UServClient
- type UServImpl
- func (s *UServImpl) GetAllUsers(req *Empty, stream UServ_GetAllUsersServer) error
- func (s *UServImpl) GetFriends(req *Friends, stream UServ_GetFriendsServer) error
- func (s *UServImpl) InsertUsers(stream UServ_InsertUsersServer) error
- func (s *UServImpl) SelectUserById(ctx context.Context, req *User) (*User, error)
- func (s *UServImpl) UpdateAllNames(req *Empty, stream UServ_UpdateAllNamesServer) error
- func (s *UServImpl) UpdateNameToFoo(ctx context.Context, req *User) (*Empty, error)
- func (s *UServImpl) UpdateUserNames(stream UServ_UpdateUserNamesServer) error
- type UServImplBuilder
- func (b *UServImplBuilder) Build() (*UServImpl, error)
- func (b *UServImplBuilder) MustBuild() *UServImpl
- func (b *UServImplBuilder) WithDefaultQueryHandlers() *UServImplBuilder
- func (b *UServImplBuilder) WithNilAsDefaultQueryHandlers(p *persist_lib.UServQueryHandlers) *UServImplBuilder
- func (b *UServImplBuilder) WithPersistQueryHandlers(p *persist_lib.UServQueryHandlers) *UServImplBuilder
- func (b *UServImplBuilder) WithRestOfGrpcHandlers(r RestOfUServHandlers) *UServImplBuilder
- func (b *UServImplBuilder) WithSpannerClient(c *spanner.Client) *UServImplBuilder
- func (b *UServImplBuilder) WithSpannerURI(ctx context.Context, uri string) *UServImplBuilder
- type UServServer
- type UServ_GetAllUsersClient
- type UServ_GetAllUsersServer
- type UServ_GetFriendsClient
- type UServ_GetFriendsServer
- type UServ_InsertUsersClient
- type UServ_InsertUsersServer
- type UServ_UpdateAllNamesClient
- type UServ_UpdateAllNamesServer
- type UServ_UpdateUserNamesClient
- type UServ_UpdateUserNamesServer
- type User
- func (*User) Descriptor() ([]byte, []int)
- func (m *User) GetCreatedOn() *google_protobuf1.Timestamp
- func (m *User) GetFavoriteNumbers() []int64
- func (m *User) GetFriends() *Friends
- func (m *User) GetId() int64
- func (m *User) GetName() string
- func (*User) ProtoMessage()
- func (m *User) Reset()
- func (m *User) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EmptyToUServPersistType ¶
func EmptyToUServPersistType(req *Empty) (*persist_lib.EmptyForUServ, error)
func FriendsToUServPersistType ¶
func FriendsToUServPersistType(req *Friends) (*persist_lib.FriendsForUServ, error)
func IterUServEmptyProto ¶
func IterUServEmptyProto(iter *spanner.RowIterator, next func(i *Empty) error) error
func IterUServUserProto ¶
func IterUServUserProto(iter *spanner.RowIterator, next func(i *User) error) error
func RegisterUServServer ¶
func RegisterUServServer(s *grpc.Server, srv UServServer)
func UserToUServPersistType ¶
func UserToUServPersistType(req *User) (*persist_lib.UserForUServ, error)
Types ¶
type Empty ¶
type Empty struct {
}
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
type Friends ¶
type Friends struct {
Names []string `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
}
func (*Friends) Descriptor ¶
func (*Friends) ProtoMessage ¶
func (*Friends) ProtoMessage()
type RestOfUServHandlers ¶
type RestOfUServHandlers interface {
UpdateAllNames(req *Empty, stream UServ_UpdateAllNamesServer) error
}
type TimeString ¶
type TimeString struct {
// contains filtered or unexported fields
}
func (*TimeString) SpannerScan ¶
func (t *TimeString) SpannerScan(src *spanner.GenericColumnValue) error
func (*TimeString) SpannerValue ¶
func (t *TimeString) SpannerValue() (interface{}, error)
func (TimeString) ToProto ¶
func (ts TimeString) ToProto() *timestamp.Timestamp
func (TimeString) ToSpanner ¶
func (ts TimeString) ToSpanner(t *timestamp.Timestamp) *TimeString
type UServClient ¶
type UServClient interface {
InsertUsers(ctx context.Context, opts ...grpc.CallOption) (UServ_InsertUsersClient, error)
GetAllUsers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (UServ_GetAllUsersClient, error)
SelectUserById(ctx context.Context, in *User, opts ...grpc.CallOption) (*User, error)
UpdateUserNames(ctx context.Context, opts ...grpc.CallOption) (UServ_UpdateUserNamesClient, error)
UpdateNameToFoo(ctx context.Context, in *User, opts ...grpc.CallOption) (*Empty, error)
UpdateAllNames(ctx context.Context, in *Empty, opts ...grpc.CallOption) (UServ_UpdateAllNamesClient, error)
GetFriends(ctx context.Context, in *Friends, opts ...grpc.CallOption) (UServ_GetFriendsClient, error)
}
func NewUServClient ¶
func NewUServClient(cc *grpc.ClientConn) UServClient
type UServImpl ¶
type UServImpl struct {
PERSIST *persist_lib.UServMethodReceiver
FORWARDED RestOfUServHandlers
}
func (*UServImpl) GetAllUsers ¶
func (s *UServImpl) GetAllUsers(req *Empty, stream UServ_GetAllUsersServer) error
func (*UServImpl) GetFriends ¶
func (s *UServImpl) GetFriends(req *Friends, stream UServ_GetFriendsServer) error
func (*UServImpl) InsertUsers ¶
func (s *UServImpl) InsertUsers(stream UServ_InsertUsersServer) error
func (*UServImpl) SelectUserById ¶
func (*UServImpl) UpdateAllNames ¶
func (s *UServImpl) UpdateAllNames(req *Empty, stream UServ_UpdateAllNamesServer) error
func (*UServImpl) UpdateNameToFoo ¶
func (*UServImpl) UpdateUserNames ¶
func (s *UServImpl) UpdateUserNames(stream UServ_UpdateUserNamesServer) error
type UServImplBuilder ¶
type UServImplBuilder struct {
// contains filtered or unexported fields
}
func NewUServBuilder ¶
func NewUServBuilder() *UServImplBuilder
func (*UServImplBuilder) Build ¶
func (b *UServImplBuilder) Build() (*UServImpl, error)
func (*UServImplBuilder) MustBuild ¶
func (b *UServImplBuilder) MustBuild() *UServImpl
func (*UServImplBuilder) WithDefaultQueryHandlers ¶
func (b *UServImplBuilder) WithDefaultQueryHandlers() *UServImplBuilder
func (*UServImplBuilder) WithNilAsDefaultQueryHandlers ¶
func (b *UServImplBuilder) WithNilAsDefaultQueryHandlers(p *persist_lib.UServQueryHandlers) *UServImplBuilder
set the custom handlers you want to use in the handlers this method will make sure to use a default handler if the handler is nil.
func (*UServImplBuilder) WithPersistQueryHandlers ¶
func (b *UServImplBuilder) WithPersistQueryHandlers(p *persist_lib.UServQueryHandlers) *UServImplBuilder
func (*UServImplBuilder) WithRestOfGrpcHandlers ¶
func (b *UServImplBuilder) WithRestOfGrpcHandlers(r RestOfUServHandlers) *UServImplBuilder
func (*UServImplBuilder) WithSpannerClient ¶
func (b *UServImplBuilder) WithSpannerClient(c *spanner.Client) *UServImplBuilder
func (*UServImplBuilder) WithSpannerURI ¶
func (b *UServImplBuilder) WithSpannerURI(ctx context.Context, uri string) *UServImplBuilder
type UServServer ¶
type UServServer interface {
InsertUsers(UServ_InsertUsersServer) error
GetAllUsers(*Empty, UServ_GetAllUsersServer) error
SelectUserById(context.Context, *User) (*User, error)
UpdateUserNames(UServ_UpdateUserNamesServer) error
UpdateNameToFoo(context.Context, *User) (*Empty, error)
UpdateAllNames(*Empty, UServ_UpdateAllNamesServer) error
GetFriends(*Friends, UServ_GetFriendsServer) error
}
type UServ_GetAllUsersClient ¶
type UServ_GetAllUsersClient interface {
Recv() (*User, error)
grpc.ClientStream
}
type UServ_GetAllUsersServer ¶
type UServ_GetAllUsersServer interface {
Send(*User) error
grpc.ServerStream
}
type UServ_GetFriendsClient ¶
type UServ_GetFriendsClient interface {
Recv() (*User, error)
grpc.ClientStream
}
type UServ_GetFriendsServer ¶
type UServ_GetFriendsServer interface {
Send(*User) error
grpc.ServerStream
}
type UServ_InsertUsersClient ¶
type UServ_InsertUsersServer ¶
type UServ_UpdateAllNamesClient ¶
type UServ_UpdateAllNamesClient interface {
Recv() (*User, error)
grpc.ClientStream
}
type UServ_UpdateAllNamesServer ¶
type UServ_UpdateAllNamesServer interface {
Send(*User) error
grpc.ServerStream
}
type User ¶
type User struct {
Id int64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
Friends *Friends `protobuf:"bytes,3,opt,name=friends" json:"friends,omitempty"`
CreatedOn *google_protobuf1.Timestamp `protobuf:"bytes,4,opt,name=created_on,json=createdOn" json:"created_on,omitempty"`
FavoriteNumbers []int64 `protobuf:"varint,5,rep,packed,name=favorite_numbers,json=favoriteNumbers" json:"favorite_numbers,omitempty"`
}
func (*User) Descriptor ¶
func (*User) GetCreatedOn ¶
func (m *User) GetCreatedOn() *google_protobuf1.Timestamp
func (*User) GetFavoriteNumbers ¶
func (*User) GetFriends ¶
func (*User) ProtoMessage ¶
func (*User) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.