Documentation ¶
Index ¶
- Variables
- func RegisterTweetsServer(s *grpc.Server, srv TweetsServer)
- func RegisterUsersServer(s *grpc.Server, srv UsersServer)
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)
- func (m *CreateRequest) GetDescription() string
- func (m *CreateRequest) GetFirstname() string
- func (m *CreateRequest) GetLastname() string
- func (m *CreateRequest) GetUsername() string
- func (*CreateRequest) ProtoMessage()
- func (m *CreateRequest) Reset()
- func (m *CreateRequest) String() string
- func (m *CreateRequest) XXX_DiscardUnknown()
- func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRequest) XXX_Merge(src proto.Message)
- func (m *CreateRequest) XXX_Size() int
- func (m *CreateRequest) XXX_Unmarshal(b []byte) error
- type CreateTweetRequest
- func (*CreateTweetRequest) Descriptor() ([]byte, []int)
- func (m *CreateTweetRequest) GetContent() string
- func (m *CreateTweetRequest) GetCreator() string
- func (m *CreateTweetRequest) GetParentId() int64
- func (*CreateTweetRequest) ProtoMessage()
- func (m *CreateTweetRequest) Reset()
- func (m *CreateTweetRequest) String() string
- func (m *CreateTweetRequest) XXX_DiscardUnknown()
- func (m *CreateTweetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateTweetRequest) XXX_Merge(src proto.Message)
- func (m *CreateTweetRequest) XXX_Size() int
- func (m *CreateTweetRequest) XXX_Unmarshal(b []byte) error
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRequest) GetUsername() string
- func (*DeleteRequest) ProtoMessage()
- func (m *DeleteRequest) Reset()
- func (m *DeleteRequest) String() string
- func (m *DeleteRequest) XXX_DiscardUnknown()
- func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteRequest) XXX_Merge(src proto.Message)
- func (m *DeleteRequest) XXX_Size() int
- func (m *DeleteRequest) XXX_Unmarshal(b []byte) error
- type DeleteTweetsRequest
- func (*DeleteTweetsRequest) Descriptor() ([]byte, []int)
- func (m *DeleteTweetsRequest) GetContext() DeleteTweetsRequest_Context
- func (m *DeleteTweetsRequest) GetTweets() []int64
- func (*DeleteTweetsRequest) ProtoMessage()
- func (m *DeleteTweetsRequest) Reset()
- func (m *DeleteTweetsRequest) String() string
- func (m *DeleteTweetsRequest) XXX_DiscardUnknown()
- func (m *DeleteTweetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteTweetsRequest) XXX_Merge(src proto.Message)
- func (m *DeleteTweetsRequest) XXX_Size() int
- func (m *DeleteTweetsRequest) XXX_Unmarshal(b []byte) error
- type DeleteTweetsRequest_Context
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type FollowRequest
- func (*FollowRequest) Descriptor() ([]byte, []int)
- func (m *FollowRequest) GetFollowed() string
- func (m *FollowRequest) GetFollower() string
- func (*FollowRequest) ProtoMessage()
- func (m *FollowRequest) Reset()
- func (m *FollowRequest) String() string
- func (m *FollowRequest) XXX_DiscardUnknown()
- func (m *FollowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FollowRequest) XXX_Merge(src proto.Message)
- func (m *FollowRequest) XXX_Size() int
- func (m *FollowRequest) XXX_Unmarshal(b []byte) error
- type GetSummaryReply
- func (*GetSummaryReply) Descriptor() ([]byte, []int)
- func (m *GetSummaryReply) GetDescription() string
- func (m *GetSummaryReply) GetFirstname() string
- func (m *GetSummaryReply) GetFollowersCount() int64
- func (m *GetSummaryReply) GetFollowingCount() int64
- func (m *GetSummaryReply) GetLastname() string
- func (m *GetSummaryReply) GetRegistrationTimestamp() int64
- func (m *GetSummaryReply) GetTweets() []int64
- func (m *GetSummaryReply) GetUsername() string
- func (*GetSummaryReply) ProtoMessage()
- func (m *GetSummaryReply) Reset()
- func (m *GetSummaryReply) String() string
- func (m *GetSummaryReply) XXX_DiscardUnknown()
- func (m *GetSummaryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetSummaryReply) XXX_Merge(src proto.Message)
- func (m *GetSummaryReply) XXX_Size() int
- func (m *GetSummaryReply) XXX_Unmarshal(b []byte) error
- type GetSummaryRequest
- func (*GetSummaryRequest) Descriptor() ([]byte, []int)
- func (m *GetSummaryRequest) GetUsername() string
- func (*GetSummaryRequest) ProtoMessage()
- func (m *GetSummaryRequest) Reset()
- func (m *GetSummaryRequest) String() string
- func (m *GetSummaryRequest) XXX_DiscardUnknown()
- func (m *GetSummaryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetSummaryRequest) XXX_Merge(src proto.Message)
- func (m *GetSummaryRequest) XXX_Size() int
- func (m *GetSummaryRequest) XXX_Unmarshal(b []byte) error
- type GetTimelineRequest
- func (*GetTimelineRequest) Descriptor() ([]byte, []int)
- func (m *GetTimelineRequest) GetUsername() string
- func (*GetTimelineRequest) ProtoMessage()
- func (m *GetTimelineRequest) Reset()
- func (m *GetTimelineRequest) String() string
- func (m *GetTimelineRequest) XXX_DiscardUnknown()
- func (m *GetTimelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTimelineRequest) XXX_Merge(src proto.Message)
- func (m *GetTimelineRequest) XXX_Size() int
- func (m *GetTimelineRequest) XXX_Unmarshal(b []byte) error
- type GetTimelineResponse
- func (*GetTimelineResponse) Descriptor() ([]byte, []int)
- func (m *GetTimelineResponse) GetTimeline() []int64
- func (*GetTimelineResponse) ProtoMessage()
- func (m *GetTimelineResponse) Reset()
- func (m *GetTimelineResponse) String() string
- func (m *GetTimelineResponse) XXX_DiscardUnknown()
- func (m *GetTimelineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTimelineResponse) XXX_Merge(src proto.Message)
- func (m *GetTimelineResponse) XXX_Size() int
- func (m *GetTimelineResponse) XXX_Unmarshal(b []byte) error
- type GetTweetsReply
- func (*GetTweetsReply) Descriptor() ([]byte, []int)
- func (m *GetTweetsReply) GetError() bool
- func (m *GetTweetsReply) GetReply() isGetTweetsReply_Reply
- func (m *GetTweetsReply) GetTweet() *Tweet
- func (*GetTweetsReply) ProtoMessage()
- func (m *GetTweetsReply) Reset()
- func (m *GetTweetsReply) String() string
- func (m *GetTweetsReply) XXX_DiscardUnknown()
- func (m *GetTweetsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTweetsReply) XXX_Merge(src proto.Message)
- func (*GetTweetsReply) XXX_OneofWrappers() []interface{}
- func (m *GetTweetsReply) XXX_Size() int
- func (m *GetTweetsReply) XXX_Unmarshal(b []byte) error
- type GetTweetsReply_Error
- type GetTweetsReply_Tweet
- type GetTweetsRequest
- func (*GetTweetsRequest) Descriptor() ([]byte, []int)
- func (m *GetTweetsRequest) GetTweets() []int64
- func (*GetTweetsRequest) ProtoMessage()
- func (m *GetTweetsRequest) Reset()
- func (m *GetTweetsRequest) String() string
- func (m *GetTweetsRequest) XXX_DiscardUnknown()
- func (m *GetTweetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTweetsRequest) XXX_Merge(src proto.Message)
- func (m *GetTweetsRequest) XXX_Size() int
- func (m *GetTweetsRequest) XXX_Unmarshal(b []byte) error
- type GetUsersReply
- func (*GetUsersReply) Descriptor() ([]byte, []int)
- func (m *GetUsersReply) GetError() bool
- func (m *GetUsersReply) GetReply() isGetUsersReply_Reply
- func (m *GetUsersReply) GetUser() *User
- func (*GetUsersReply) ProtoMessage()
- func (m *GetUsersReply) Reset()
- func (m *GetUsersReply) String() string
- func (m *GetUsersReply) XXX_DiscardUnknown()
- func (m *GetUsersReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetUsersReply) XXX_Merge(src proto.Message)
- func (*GetUsersReply) XXX_OneofWrappers() []interface{}
- func (m *GetUsersReply) XXX_Size() int
- func (m *GetUsersReply) XXX_Unmarshal(b []byte) error
- type GetUsersReply_Error
- type GetUsersReply_User
- type GetUsersRequest
- func (*GetUsersRequest) Descriptor() ([]byte, []int)
- func (m *GetUsersRequest) GetRole() Role
- func (m *GetUsersRequest) GetUsername() string
- func (*GetUsersRequest) ProtoMessage()
- func (m *GetUsersRequest) Reset()
- func (m *GetUsersRequest) String() string
- func (m *GetUsersRequest) XXX_DiscardUnknown()
- func (m *GetUsersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetUsersRequest) XXX_Merge(src proto.Message)
- func (m *GetUsersRequest) XXX_Size() int
- func (m *GetUsersRequest) XXX_Unmarshal(b []byte) error
- type NatsCreateTweetMessage
- func (*NatsCreateTweetMessage) Descriptor() ([]byte, []int)
- func (m *NatsCreateTweetMessage) GetContent() string
- func (m *NatsCreateTweetMessage) GetCreator() string
- func (m *NatsCreateTweetMessage) GetParentTweetId() int64
- func (m *NatsCreateTweetMessage) GetTweetId() int64
- func (*NatsCreateTweetMessage) ProtoMessage()
- func (m *NatsCreateTweetMessage) Reset()
- func (m *NatsCreateTweetMessage) String() string
- func (m *NatsCreateTweetMessage) XXX_DiscardUnknown()
- func (m *NatsCreateTweetMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsCreateTweetMessage) XXX_Merge(src proto.Message)
- func (m *NatsCreateTweetMessage) XXX_Size() int
- func (m *NatsCreateTweetMessage) XXX_Unmarshal(b []byte) error
- type NatsDeleteTweetsMessage
- func (*NatsDeleteTweetsMessage) Descriptor() ([]byte, []int)
- func (m *NatsDeleteTweetsMessage) GetTweets() []int64
- func (*NatsDeleteTweetsMessage) ProtoMessage()
- func (m *NatsDeleteTweetsMessage) Reset()
- func (m *NatsDeleteTweetsMessage) String() string
- func (m *NatsDeleteTweetsMessage) XXX_DiscardUnknown()
- func (m *NatsDeleteTweetsMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsDeleteTweetsMessage) XXX_Merge(src proto.Message)
- func (m *NatsDeleteTweetsMessage) XXX_Size() int
- func (m *NatsDeleteTweetsMessage) XXX_Unmarshal(b []byte) error
- type NatsDeleteUserMessage
- func (*NatsDeleteUserMessage) Descriptor() ([]byte, []int)
- func (m *NatsDeleteUserMessage) GetTweets() []int64
- func (m *NatsDeleteUserMessage) GetUsername() string
- func (*NatsDeleteUserMessage) ProtoMessage()
- func (m *NatsDeleteUserMessage) Reset()
- func (m *NatsDeleteUserMessage) String() string
- func (m *NatsDeleteUserMessage) XXX_DiscardUnknown()
- func (m *NatsDeleteUserMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsDeleteUserMessage) XXX_Merge(src proto.Message)
- func (m *NatsDeleteUserMessage) XXX_Size() int
- func (m *NatsDeleteUserMessage) XXX_Unmarshal(b []byte) error
- type NatsMessage
- func (*NatsMessage) Descriptor() ([]byte, []int)
- func (m *NatsMessage) GetCommand() NatsMessage_Command
- func (m *NatsMessage) GetMessage() []byte
- func (*NatsMessage) ProtoMessage()
- func (m *NatsMessage) Reset()
- func (m *NatsMessage) String() string
- func (m *NatsMessage) XXX_DiscardUnknown()
- func (m *NatsMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsMessage) XXX_Merge(src proto.Message)
- func (m *NatsMessage) XXX_Size() int
- func (m *NatsMessage) XXX_Unmarshal(b []byte) error
- type NatsMessage_Command
- type Role
- type Tweet
- func (*Tweet) Descriptor() ([]byte, []int)
- func (m *Tweet) GetContent() string
- func (m *Tweet) GetCreationTimestamp() int64
- func (m *Tweet) GetCreator() string
- func (m *Tweet) GetId() int64
- func (m *Tweet) GetParentId() int64
- func (*Tweet) ProtoMessage()
- func (m *Tweet) Reset()
- func (m *Tweet) String() string
- func (m *Tweet) XXX_DiscardUnknown()
- func (m *Tweet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Tweet) XXX_Merge(src proto.Message)
- func (m *Tweet) XXX_Size() int
- func (m *Tweet) XXX_Unmarshal(b []byte) error
- type TweetsClient
- type TweetsServer
- type Tweets_GetTweetsClient
- type Tweets_GetTweetsServer
- type UnimplementedTweetsServer
- type UnimplementedUsersServer
- func (*UnimplementedUsersServer) CreateUser(context.Context, *CreateRequest) (*Empty, error)
- func (*UnimplementedUsersServer) DeleteUser(context.Context, *DeleteRequest) (*Empty, error)
- func (*UnimplementedUsersServer) Follow(context.Context, *FollowRequest) (*Empty, error)
- func (*UnimplementedUsersServer) GetTimeline(context.Context, *GetTimelineRequest) (*GetTimelineResponse, error)
- func (*UnimplementedUsersServer) GetUserInfoSummary(context.Context, *GetSummaryRequest) (*GetSummaryReply, error)
- func (*UnimplementedUsersServer) GetUsers(*GetUsersRequest, Users_GetUsersServer) error
- func (*UnimplementedUsersServer) Unfollow(context.Context, *FollowRequest) (*Empty, error)
- type User
- func (*User) Descriptor() ([]byte, []int)
- func (m *User) GetDescription() string
- func (m *User) GetFirstname() string
- func (m *User) GetFollowers() []string
- func (m *User) GetFollowing() []string
- func (m *User) GetLastname() string
- func (m *User) GetRegistrationTimestamp() int64
- func (m *User) GetTweets() []int64
- func (m *User) GetUsername() string
- func (*User) ProtoMessage()
- func (m *User) Reset()
- func (m *User) String() string
- func (m *User) XXX_DiscardUnknown()
- func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *User) XXX_Merge(src proto.Message)
- func (m *User) XXX_Size() int
- func (m *User) XXX_Unmarshal(b []byte) error
- type UsersClient
- type UsersServer
- type Users_GetUsersClient
- type Users_GetUsersServer
Constants ¶
This section is empty.
Variables ¶
var DeleteTweetsRequest_Context_name = map[int32]string{
0: "Client",
1: "Service",
}
var DeleteTweetsRequest_Context_value = map[string]int32{
"Client": 0,
"Service": 1,
}
var NatsMessage_Command_name = map[int32]string{
0: "DeleteUser",
1: "CreateTweet",
2: "DeleteTweets",
}
var NatsMessage_Command_value = map[string]int32{
"DeleteUser": 0,
"CreateTweet": 1,
"DeleteTweets": 2,
}
var Role_name = map[int32]string{
0: "Follower",
1: "Followed",
}
var Role_value = map[string]int32{
"Follower": 0,
"Followed": 1,
}
Functions ¶
func RegisterTweetsServer ¶
func RegisterTweetsServer(s *grpc.Server, srv TweetsServer)
func RegisterUsersServer ¶
func RegisterUsersServer(s *grpc.Server, srv UsersServer)
Types ¶
type CreateRequest ¶
type CreateRequest struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Firstname string `protobuf:"bytes,2,opt,name=firstname,proto3" json:"firstname,omitempty"` Lastname string `protobuf:"bytes,3,opt,name=lastname,proto3" json:"lastname,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateRequest) Descriptor ¶
func (*CreateRequest) Descriptor() ([]byte, []int)
func (*CreateRequest) GetDescription ¶
func (m *CreateRequest) GetDescription() string
func (*CreateRequest) GetFirstname ¶
func (m *CreateRequest) GetFirstname() string
func (*CreateRequest) GetLastname ¶
func (m *CreateRequest) GetLastname() string
func (*CreateRequest) GetUsername ¶
func (m *CreateRequest) GetUsername() string
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) Reset ¶
func (m *CreateRequest) Reset()
func (*CreateRequest) String ¶
func (m *CreateRequest) String() string
func (*CreateRequest) XXX_DiscardUnknown ¶
func (m *CreateRequest) XXX_DiscardUnknown()
func (*CreateRequest) XXX_Marshal ¶
func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRequest) XXX_Merge ¶
func (m *CreateRequest) XXX_Merge(src proto.Message)
func (*CreateRequest) XXX_Size ¶
func (m *CreateRequest) XXX_Size() int
func (*CreateRequest) XXX_Unmarshal ¶
func (m *CreateRequest) XXX_Unmarshal(b []byte) error
type CreateTweetRequest ¶
type CreateTweetRequest struct { ParentId int64 `protobuf:"varint,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` Creator string `protobuf:"bytes,2,opt,name=creator,proto3" json:"creator,omitempty"` Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateTweetRequest) Descriptor ¶
func (*CreateTweetRequest) Descriptor() ([]byte, []int)
func (*CreateTweetRequest) GetContent ¶
func (m *CreateTweetRequest) GetContent() string
func (*CreateTweetRequest) GetCreator ¶
func (m *CreateTweetRequest) GetCreator() string
func (*CreateTweetRequest) GetParentId ¶
func (m *CreateTweetRequest) GetParentId() int64
func (*CreateTweetRequest) ProtoMessage ¶
func (*CreateTweetRequest) ProtoMessage()
func (*CreateTweetRequest) Reset ¶
func (m *CreateTweetRequest) Reset()
func (*CreateTweetRequest) String ¶
func (m *CreateTweetRequest) String() string
func (*CreateTweetRequest) XXX_DiscardUnknown ¶
func (m *CreateTweetRequest) XXX_DiscardUnknown()
func (*CreateTweetRequest) XXX_Marshal ¶
func (m *CreateTweetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateTweetRequest) XXX_Merge ¶
func (m *CreateTweetRequest) XXX_Merge(src proto.Message)
func (*CreateTweetRequest) XXX_Size ¶
func (m *CreateTweetRequest) XXX_Size() int
func (*CreateTweetRequest) XXX_Unmarshal ¶
func (m *CreateTweetRequest) XXX_Unmarshal(b []byte) error
type DeleteRequest ¶
type DeleteRequest struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) GetUsername ¶
func (m *DeleteRequest) GetUsername() string
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) Reset ¶
func (m *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (m *DeleteRequest) String() string
func (*DeleteRequest) XXX_DiscardUnknown ¶
func (m *DeleteRequest) XXX_DiscardUnknown()
func (*DeleteRequest) XXX_Marshal ¶
func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteRequest) XXX_Merge ¶
func (m *DeleteRequest) XXX_Merge(src proto.Message)
func (*DeleteRequest) XXX_Size ¶
func (m *DeleteRequest) XXX_Size() int
func (*DeleteRequest) XXX_Unmarshal ¶
func (m *DeleteRequest) XXX_Unmarshal(b []byte) error
type DeleteTweetsRequest ¶
type DeleteTweetsRequest struct { Context DeleteTweetsRequest_Context `protobuf:"varint,1,opt,name=context,proto3,enum=DeleteTweetsRequest_Context" json:"context,omitempty"` Tweets []int64 `protobuf:"varint,2,rep,packed,name=tweets,proto3" json:"tweets,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteTweetsRequest) Descriptor ¶
func (*DeleteTweetsRequest) Descriptor() ([]byte, []int)
func (*DeleteTweetsRequest) GetContext ¶
func (m *DeleteTweetsRequest) GetContext() DeleteTweetsRequest_Context
func (*DeleteTweetsRequest) GetTweets ¶
func (m *DeleteTweetsRequest) GetTweets() []int64
func (*DeleteTweetsRequest) ProtoMessage ¶
func (*DeleteTweetsRequest) ProtoMessage()
func (*DeleteTweetsRequest) Reset ¶
func (m *DeleteTweetsRequest) Reset()
func (*DeleteTweetsRequest) String ¶
func (m *DeleteTweetsRequest) String() string
func (*DeleteTweetsRequest) XXX_DiscardUnknown ¶
func (m *DeleteTweetsRequest) XXX_DiscardUnknown()
func (*DeleteTweetsRequest) XXX_Marshal ¶
func (m *DeleteTweetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteTweetsRequest) XXX_Merge ¶
func (m *DeleteTweetsRequest) XXX_Merge(src proto.Message)
func (*DeleteTweetsRequest) XXX_Size ¶
func (m *DeleteTweetsRequest) XXX_Size() int
func (*DeleteTweetsRequest) XXX_Unmarshal ¶
func (m *DeleteTweetsRequest) XXX_Unmarshal(b []byte) error
type DeleteTweetsRequest_Context ¶
type DeleteTweetsRequest_Context int32
const ( DeleteTweetsRequest_Client DeleteTweetsRequest_Context = 0 DeleteTweetsRequest_Service DeleteTweetsRequest_Context = 1 )
func (DeleteTweetsRequest_Context) EnumDescriptor ¶
func (DeleteTweetsRequest_Context) EnumDescriptor() ([]byte, []int)
func (DeleteTweetsRequest_Context) String ¶
func (x DeleteTweetsRequest_Context) String() string
type Empty ¶
type Empty struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type FollowRequest ¶
type FollowRequest struct { Follower string `protobuf:"bytes,1,opt,name=follower,proto3" json:"follower,omitempty"` Followed string `protobuf:"bytes,2,opt,name=followed,proto3" json:"followed,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FollowRequest) Descriptor ¶
func (*FollowRequest) Descriptor() ([]byte, []int)
func (*FollowRequest) GetFollowed ¶
func (m *FollowRequest) GetFollowed() string
func (*FollowRequest) GetFollower ¶
func (m *FollowRequest) GetFollower() string
func (*FollowRequest) ProtoMessage ¶
func (*FollowRequest) ProtoMessage()
func (*FollowRequest) Reset ¶
func (m *FollowRequest) Reset()
func (*FollowRequest) String ¶
func (m *FollowRequest) String() string
func (*FollowRequest) XXX_DiscardUnknown ¶
func (m *FollowRequest) XXX_DiscardUnknown()
func (*FollowRequest) XXX_Marshal ¶
func (m *FollowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FollowRequest) XXX_Merge ¶
func (m *FollowRequest) XXX_Merge(src proto.Message)
func (*FollowRequest) XXX_Size ¶
func (m *FollowRequest) XXX_Size() int
func (*FollowRequest) XXX_Unmarshal ¶
func (m *FollowRequest) XXX_Unmarshal(b []byte) error
type GetSummaryReply ¶
type GetSummaryReply struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Firstname string `protobuf:"bytes,2,opt,name=firstname,proto3" json:"firstname,omitempty"` Lastname string `protobuf:"bytes,3,opt,name=lastname,proto3" json:"lastname,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` RegistrationTimestamp int64 `protobuf:"varint,5,opt,name=registration_timestamp,json=registrationTimestamp,proto3" json:"registration_timestamp,omitempty"` FollowersCount int64 `protobuf:"varint,6,opt,name=followers_count,json=followersCount,proto3" json:"followers_count,omitempty"` FollowingCount int64 `protobuf:"varint,7,opt,name=following_count,json=followingCount,proto3" json:"following_count,omitempty"` Tweets []int64 `protobuf:"varint,8,rep,packed,name=tweets,proto3" json:"tweets,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetSummaryReply) Descriptor ¶
func (*GetSummaryReply) Descriptor() ([]byte, []int)
func (*GetSummaryReply) GetDescription ¶
func (m *GetSummaryReply) GetDescription() string
func (*GetSummaryReply) GetFirstname ¶
func (m *GetSummaryReply) GetFirstname() string
func (*GetSummaryReply) GetFollowersCount ¶
func (m *GetSummaryReply) GetFollowersCount() int64
func (*GetSummaryReply) GetFollowingCount ¶
func (m *GetSummaryReply) GetFollowingCount() int64
func (*GetSummaryReply) GetLastname ¶
func (m *GetSummaryReply) GetLastname() string
func (*GetSummaryReply) GetRegistrationTimestamp ¶
func (m *GetSummaryReply) GetRegistrationTimestamp() int64
func (*GetSummaryReply) GetTweets ¶
func (m *GetSummaryReply) GetTweets() []int64
func (*GetSummaryReply) GetUsername ¶
func (m *GetSummaryReply) GetUsername() string
func (*GetSummaryReply) ProtoMessage ¶
func (*GetSummaryReply) ProtoMessage()
func (*GetSummaryReply) Reset ¶
func (m *GetSummaryReply) Reset()
func (*GetSummaryReply) String ¶
func (m *GetSummaryReply) String() string
func (*GetSummaryReply) XXX_DiscardUnknown ¶
func (m *GetSummaryReply) XXX_DiscardUnknown()
func (*GetSummaryReply) XXX_Marshal ¶
func (m *GetSummaryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetSummaryReply) XXX_Merge ¶
func (m *GetSummaryReply) XXX_Merge(src proto.Message)
func (*GetSummaryReply) XXX_Size ¶
func (m *GetSummaryReply) XXX_Size() int
func (*GetSummaryReply) XXX_Unmarshal ¶
func (m *GetSummaryReply) XXX_Unmarshal(b []byte) error
type GetSummaryRequest ¶
type GetSummaryRequest struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetSummaryRequest) Descriptor ¶
func (*GetSummaryRequest) Descriptor() ([]byte, []int)
func (*GetSummaryRequest) GetUsername ¶
func (m *GetSummaryRequest) GetUsername() string
func (*GetSummaryRequest) ProtoMessage ¶
func (*GetSummaryRequest) ProtoMessage()
func (*GetSummaryRequest) Reset ¶
func (m *GetSummaryRequest) Reset()
func (*GetSummaryRequest) String ¶
func (m *GetSummaryRequest) String() string
func (*GetSummaryRequest) XXX_DiscardUnknown ¶
func (m *GetSummaryRequest) XXX_DiscardUnknown()
func (*GetSummaryRequest) XXX_Marshal ¶
func (m *GetSummaryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetSummaryRequest) XXX_Merge ¶
func (m *GetSummaryRequest) XXX_Merge(src proto.Message)
func (*GetSummaryRequest) XXX_Size ¶
func (m *GetSummaryRequest) XXX_Size() int
func (*GetSummaryRequest) XXX_Unmarshal ¶
func (m *GetSummaryRequest) XXX_Unmarshal(b []byte) error
type GetTimelineRequest ¶
type GetTimelineRequest struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTimelineRequest) Descriptor ¶
func (*GetTimelineRequest) Descriptor() ([]byte, []int)
func (*GetTimelineRequest) GetUsername ¶
func (m *GetTimelineRequest) GetUsername() string
func (*GetTimelineRequest) ProtoMessage ¶
func (*GetTimelineRequest) ProtoMessage()
func (*GetTimelineRequest) Reset ¶
func (m *GetTimelineRequest) Reset()
func (*GetTimelineRequest) String ¶
func (m *GetTimelineRequest) String() string
func (*GetTimelineRequest) XXX_DiscardUnknown ¶
func (m *GetTimelineRequest) XXX_DiscardUnknown()
func (*GetTimelineRequest) XXX_Marshal ¶
func (m *GetTimelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTimelineRequest) XXX_Merge ¶
func (m *GetTimelineRequest) XXX_Merge(src proto.Message)
func (*GetTimelineRequest) XXX_Size ¶
func (m *GetTimelineRequest) XXX_Size() int
func (*GetTimelineRequest) XXX_Unmarshal ¶
func (m *GetTimelineRequest) XXX_Unmarshal(b []byte) error
type GetTimelineResponse ¶
type GetTimelineResponse struct { Timeline []int64 `protobuf:"varint,1,rep,packed,name=timeline,proto3" json:"timeline,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTimelineResponse) Descriptor ¶
func (*GetTimelineResponse) Descriptor() ([]byte, []int)
func (*GetTimelineResponse) GetTimeline ¶
func (m *GetTimelineResponse) GetTimeline() []int64
func (*GetTimelineResponse) ProtoMessage ¶
func (*GetTimelineResponse) ProtoMessage()
func (*GetTimelineResponse) Reset ¶
func (m *GetTimelineResponse) Reset()
func (*GetTimelineResponse) String ¶
func (m *GetTimelineResponse) String() string
func (*GetTimelineResponse) XXX_DiscardUnknown ¶
func (m *GetTimelineResponse) XXX_DiscardUnknown()
func (*GetTimelineResponse) XXX_Marshal ¶
func (m *GetTimelineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTimelineResponse) XXX_Merge ¶
func (m *GetTimelineResponse) XXX_Merge(src proto.Message)
func (*GetTimelineResponse) XXX_Size ¶
func (m *GetTimelineResponse) XXX_Size() int
func (*GetTimelineResponse) XXX_Unmarshal ¶
func (m *GetTimelineResponse) XXX_Unmarshal(b []byte) error
type GetTweetsReply ¶
type GetTweetsReply struct { // Types that are valid to be assigned to Reply: // *GetTweetsReply_Tweet // *GetTweetsReply_Error Reply isGetTweetsReply_Reply `protobuf_oneof:"reply"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTweetsReply) Descriptor ¶
func (*GetTweetsReply) Descriptor() ([]byte, []int)
func (*GetTweetsReply) GetError ¶
func (m *GetTweetsReply) GetError() bool
func (*GetTweetsReply) GetReply ¶
func (m *GetTweetsReply) GetReply() isGetTweetsReply_Reply
func (*GetTweetsReply) GetTweet ¶
func (m *GetTweetsReply) GetTweet() *Tweet
func (*GetTweetsReply) ProtoMessage ¶
func (*GetTweetsReply) ProtoMessage()
func (*GetTweetsReply) Reset ¶
func (m *GetTweetsReply) Reset()
func (*GetTweetsReply) String ¶
func (m *GetTweetsReply) String() string
func (*GetTweetsReply) XXX_DiscardUnknown ¶
func (m *GetTweetsReply) XXX_DiscardUnknown()
func (*GetTweetsReply) XXX_Marshal ¶
func (m *GetTweetsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTweetsReply) XXX_Merge ¶
func (m *GetTweetsReply) XXX_Merge(src proto.Message)
func (*GetTweetsReply) XXX_OneofWrappers ¶
func (*GetTweetsReply) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*GetTweetsReply) XXX_Size ¶
func (m *GetTweetsReply) XXX_Size() int
func (*GetTweetsReply) XXX_Unmarshal ¶
func (m *GetTweetsReply) XXX_Unmarshal(b []byte) error
type GetTweetsReply_Error ¶
type GetTweetsReply_Error struct {
Error bool `protobuf:"varint,2,opt,name=error,proto3,oneof"`
}
type GetTweetsReply_Tweet ¶
type GetTweetsReply_Tweet struct {
Tweet *Tweet `protobuf:"bytes,1,opt,name=tweet,proto3,oneof"`
}
type GetTweetsRequest ¶
type GetTweetsRequest struct { Tweets []int64 `protobuf:"varint,1,rep,packed,name=tweets,proto3" json:"tweets,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTweetsRequest) Descriptor ¶
func (*GetTweetsRequest) Descriptor() ([]byte, []int)
func (*GetTweetsRequest) GetTweets ¶
func (m *GetTweetsRequest) GetTweets() []int64
func (*GetTweetsRequest) ProtoMessage ¶
func (*GetTweetsRequest) ProtoMessage()
func (*GetTweetsRequest) Reset ¶
func (m *GetTweetsRequest) Reset()
func (*GetTweetsRequest) String ¶
func (m *GetTweetsRequest) String() string
func (*GetTweetsRequest) XXX_DiscardUnknown ¶
func (m *GetTweetsRequest) XXX_DiscardUnknown()
func (*GetTweetsRequest) XXX_Marshal ¶
func (m *GetTweetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTweetsRequest) XXX_Merge ¶
func (m *GetTweetsRequest) XXX_Merge(src proto.Message)
func (*GetTweetsRequest) XXX_Size ¶
func (m *GetTweetsRequest) XXX_Size() int
func (*GetTweetsRequest) XXX_Unmarshal ¶
func (m *GetTweetsRequest) XXX_Unmarshal(b []byte) error
type GetUsersReply ¶
type GetUsersReply struct { // Types that are valid to be assigned to Reply: // *GetUsersReply_User // *GetUsersReply_Error Reply isGetUsersReply_Reply `protobuf_oneof:"reply"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetUsersReply) Descriptor ¶
func (*GetUsersReply) Descriptor() ([]byte, []int)
func (*GetUsersReply) GetError ¶
func (m *GetUsersReply) GetError() bool
func (*GetUsersReply) GetReply ¶
func (m *GetUsersReply) GetReply() isGetUsersReply_Reply
func (*GetUsersReply) GetUser ¶
func (m *GetUsersReply) GetUser() *User
func (*GetUsersReply) ProtoMessage ¶
func (*GetUsersReply) ProtoMessage()
func (*GetUsersReply) Reset ¶
func (m *GetUsersReply) Reset()
func (*GetUsersReply) String ¶
func (m *GetUsersReply) String() string
func (*GetUsersReply) XXX_DiscardUnknown ¶
func (m *GetUsersReply) XXX_DiscardUnknown()
func (*GetUsersReply) XXX_Marshal ¶
func (m *GetUsersReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetUsersReply) XXX_Merge ¶
func (m *GetUsersReply) XXX_Merge(src proto.Message)
func (*GetUsersReply) XXX_OneofWrappers ¶
func (*GetUsersReply) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*GetUsersReply) XXX_Size ¶
func (m *GetUsersReply) XXX_Size() int
func (*GetUsersReply) XXX_Unmarshal ¶
func (m *GetUsersReply) XXX_Unmarshal(b []byte) error
type GetUsersReply_Error ¶
type GetUsersReply_Error struct {
Error bool `protobuf:"varint,2,opt,name=error,proto3,oneof"`
}
type GetUsersReply_User ¶
type GetUsersReply_User struct {
User *User `protobuf:"bytes,1,opt,name=user,proto3,oneof"`
}
type GetUsersRequest ¶
type GetUsersRequest struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Role Role `protobuf:"varint,2,opt,name=role,proto3,enum=Role" json:"role,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetUsersRequest) Descriptor ¶
func (*GetUsersRequest) Descriptor() ([]byte, []int)
func (*GetUsersRequest) GetRole ¶
func (m *GetUsersRequest) GetRole() Role
func (*GetUsersRequest) GetUsername ¶
func (m *GetUsersRequest) GetUsername() string
func (*GetUsersRequest) ProtoMessage ¶
func (*GetUsersRequest) ProtoMessage()
func (*GetUsersRequest) Reset ¶
func (m *GetUsersRequest) Reset()
func (*GetUsersRequest) String ¶
func (m *GetUsersRequest) String() string
func (*GetUsersRequest) XXX_DiscardUnknown ¶
func (m *GetUsersRequest) XXX_DiscardUnknown()
func (*GetUsersRequest) XXX_Marshal ¶
func (m *GetUsersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetUsersRequest) XXX_Merge ¶
func (m *GetUsersRequest) XXX_Merge(src proto.Message)
func (*GetUsersRequest) XXX_Size ¶
func (m *GetUsersRequest) XXX_Size() int
func (*GetUsersRequest) XXX_Unmarshal ¶
func (m *GetUsersRequest) XXX_Unmarshal(b []byte) error
type NatsCreateTweetMessage ¶
type NatsCreateTweetMessage struct { TweetId int64 `protobuf:"varint,1,opt,name=tweet_id,json=tweetId,proto3" json:"tweet_id,omitempty"` ParentTweetId int64 `protobuf:"varint,2,opt,name=parent_tweet_id,json=parentTweetId,proto3" json:"parent_tweet_id,omitempty"` Creator string `protobuf:"bytes,3,opt,name=creator,proto3" json:"creator,omitempty"` Content string `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NatsCreateTweetMessage) Descriptor ¶
func (*NatsCreateTweetMessage) Descriptor() ([]byte, []int)
func (*NatsCreateTweetMessage) GetContent ¶
func (m *NatsCreateTweetMessage) GetContent() string
func (*NatsCreateTweetMessage) GetCreator ¶
func (m *NatsCreateTweetMessage) GetCreator() string
func (*NatsCreateTweetMessage) GetParentTweetId ¶
func (m *NatsCreateTweetMessage) GetParentTweetId() int64
func (*NatsCreateTweetMessage) GetTweetId ¶
func (m *NatsCreateTweetMessage) GetTweetId() int64
func (*NatsCreateTweetMessage) ProtoMessage ¶
func (*NatsCreateTweetMessage) ProtoMessage()
func (*NatsCreateTweetMessage) Reset ¶
func (m *NatsCreateTweetMessage) Reset()
func (*NatsCreateTweetMessage) String ¶
func (m *NatsCreateTweetMessage) String() string
func (*NatsCreateTweetMessage) XXX_DiscardUnknown ¶
func (m *NatsCreateTweetMessage) XXX_DiscardUnknown()
func (*NatsCreateTweetMessage) XXX_Marshal ¶
func (m *NatsCreateTweetMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NatsCreateTweetMessage) XXX_Merge ¶
func (m *NatsCreateTweetMessage) XXX_Merge(src proto.Message)
func (*NatsCreateTweetMessage) XXX_Size ¶
func (m *NatsCreateTweetMessage) XXX_Size() int
func (*NatsCreateTweetMessage) XXX_Unmarshal ¶
func (m *NatsCreateTweetMessage) XXX_Unmarshal(b []byte) error
type NatsDeleteTweetsMessage ¶
type NatsDeleteTweetsMessage struct { Tweets []int64 `protobuf:"varint,1,rep,packed,name=tweets,proto3" json:"tweets,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NatsDeleteTweetsMessage) Descriptor ¶
func (*NatsDeleteTweetsMessage) Descriptor() ([]byte, []int)
func (*NatsDeleteTweetsMessage) GetTweets ¶
func (m *NatsDeleteTweetsMessage) GetTweets() []int64
func (*NatsDeleteTweetsMessage) ProtoMessage ¶
func (*NatsDeleteTweetsMessage) ProtoMessage()
func (*NatsDeleteTweetsMessage) Reset ¶
func (m *NatsDeleteTweetsMessage) Reset()
func (*NatsDeleteTweetsMessage) String ¶
func (m *NatsDeleteTweetsMessage) String() string
func (*NatsDeleteTweetsMessage) XXX_DiscardUnknown ¶
func (m *NatsDeleteTweetsMessage) XXX_DiscardUnknown()
func (*NatsDeleteTweetsMessage) XXX_Marshal ¶
func (m *NatsDeleteTweetsMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NatsDeleteTweetsMessage) XXX_Merge ¶
func (m *NatsDeleteTweetsMessage) XXX_Merge(src proto.Message)
func (*NatsDeleteTweetsMessage) XXX_Size ¶
func (m *NatsDeleteTweetsMessage) XXX_Size() int
func (*NatsDeleteTweetsMessage) XXX_Unmarshal ¶
func (m *NatsDeleteTweetsMessage) XXX_Unmarshal(b []byte) error
type NatsDeleteUserMessage ¶
type NatsDeleteUserMessage struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Tweets []int64 `protobuf:"varint,2,rep,packed,name=tweets,proto3" json:"tweets,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NatsDeleteUserMessage) Descriptor ¶
func (*NatsDeleteUserMessage) Descriptor() ([]byte, []int)
func (*NatsDeleteUserMessage) GetTweets ¶
func (m *NatsDeleteUserMessage) GetTweets() []int64
func (*NatsDeleteUserMessage) GetUsername ¶
func (m *NatsDeleteUserMessage) GetUsername() string
func (*NatsDeleteUserMessage) ProtoMessage ¶
func (*NatsDeleteUserMessage) ProtoMessage()
func (*NatsDeleteUserMessage) Reset ¶
func (m *NatsDeleteUserMessage) Reset()
func (*NatsDeleteUserMessage) String ¶
func (m *NatsDeleteUserMessage) String() string
func (*NatsDeleteUserMessage) XXX_DiscardUnknown ¶
func (m *NatsDeleteUserMessage) XXX_DiscardUnknown()
func (*NatsDeleteUserMessage) XXX_Marshal ¶
func (m *NatsDeleteUserMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NatsDeleteUserMessage) XXX_Merge ¶
func (m *NatsDeleteUserMessage) XXX_Merge(src proto.Message)
func (*NatsDeleteUserMessage) XXX_Size ¶
func (m *NatsDeleteUserMessage) XXX_Size() int
func (*NatsDeleteUserMessage) XXX_Unmarshal ¶
func (m *NatsDeleteUserMessage) XXX_Unmarshal(b []byte) error
type NatsMessage ¶
type NatsMessage struct { Command NatsMessage_Command `protobuf:"varint,1,opt,name=command,proto3,enum=NatsMessage_Command" json:"command,omitempty"` Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NatsMessage) Descriptor ¶
func (*NatsMessage) Descriptor() ([]byte, []int)
func (*NatsMessage) GetCommand ¶
func (m *NatsMessage) GetCommand() NatsMessage_Command
func (*NatsMessage) GetMessage ¶
func (m *NatsMessage) GetMessage() []byte
func (*NatsMessage) ProtoMessage ¶
func (*NatsMessage) ProtoMessage()
func (*NatsMessage) Reset ¶
func (m *NatsMessage) Reset()
func (*NatsMessage) String ¶
func (m *NatsMessage) String() string
func (*NatsMessage) XXX_DiscardUnknown ¶
func (m *NatsMessage) XXX_DiscardUnknown()
func (*NatsMessage) XXX_Marshal ¶
func (m *NatsMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NatsMessage) XXX_Merge ¶
func (m *NatsMessage) XXX_Merge(src proto.Message)
func (*NatsMessage) XXX_Size ¶
func (m *NatsMessage) XXX_Size() int
func (*NatsMessage) XXX_Unmarshal ¶
func (m *NatsMessage) XXX_Unmarshal(b []byte) error
type NatsMessage_Command ¶
type NatsMessage_Command int32
const ( NatsMessage_DeleteUser NatsMessage_Command = 0 NatsMessage_CreateTweet NatsMessage_Command = 1 NatsMessage_DeleteTweets NatsMessage_Command = 2 )
func (NatsMessage_Command) EnumDescriptor ¶
func (NatsMessage_Command) EnumDescriptor() ([]byte, []int)
func (NatsMessage_Command) String ¶
func (x NatsMessage_Command) String() string
type Tweet ¶
type Tweet struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` ParentId int64 `protobuf:"varint,2,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` Creator string `protobuf:"bytes,3,opt,name=creator,proto3" json:"creator,omitempty"` Content string `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"` CreationTimestamp int64 `protobuf:"varint,5,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Tweet) Descriptor ¶
func (*Tweet) GetContent ¶
func (*Tweet) GetCreationTimestamp ¶
func (*Tweet) GetCreator ¶
func (*Tweet) GetParentId ¶
func (*Tweet) ProtoMessage ¶
func (*Tweet) ProtoMessage()
func (*Tweet) XXX_DiscardUnknown ¶
func (m *Tweet) XXX_DiscardUnknown()
func (*Tweet) XXX_Marshal ¶
func (*Tweet) XXX_Unmarshal ¶
type TweetsClient ¶
type TweetsClient interface { CreateTweet(ctx context.Context, in *CreateTweetRequest, opts ...grpc.CallOption) (*Empty, error) GetTweets(ctx context.Context, in *GetTweetsRequest, opts ...grpc.CallOption) (Tweets_GetTweetsClient, error) DeleteTweets(ctx context.Context, in *DeleteTweetsRequest, opts ...grpc.CallOption) (*Empty, error) }
TweetsClient is the client API for Tweets service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewTweetsClient ¶
func NewTweetsClient(cc grpc.ClientConnInterface) TweetsClient
type TweetsServer ¶
type TweetsServer interface { CreateTweet(context.Context, *CreateTweetRequest) (*Empty, error) GetTweets(*GetTweetsRequest, Tweets_GetTweetsServer) error DeleteTweets(context.Context, *DeleteTweetsRequest) (*Empty, error) // contains filtered or unexported methods }
TweetsServer is the server API for Tweets service. All implementations must embed UnimplementedTweetsServer for forward compatibility
type Tweets_GetTweetsClient ¶
type Tweets_GetTweetsClient interface { Recv() (*GetTweetsReply, error) grpc.ClientStream }
type Tweets_GetTweetsServer ¶
type Tweets_GetTweetsServer interface { Send(*GetTweetsReply) error grpc.ServerStream }
type UnimplementedTweetsServer ¶
type UnimplementedTweetsServer struct { }
UnimplementedTweetsServer must be embedded to have forward compatible implementations.
func (*UnimplementedTweetsServer) CreateTweet ¶
func (*UnimplementedTweetsServer) CreateTweet(context.Context, *CreateTweetRequest) (*Empty, error)
func (*UnimplementedTweetsServer) DeleteTweets ¶
func (*UnimplementedTweetsServer) DeleteTweets(context.Context, *DeleteTweetsRequest) (*Empty, error)
func (*UnimplementedTweetsServer) GetTweets ¶
func (*UnimplementedTweetsServer) GetTweets(*GetTweetsRequest, Tweets_GetTweetsServer) error
type UnimplementedUsersServer ¶
type UnimplementedUsersServer struct { }
UnimplementedUsersServer must be embedded to have forward compatible implementations.
func (*UnimplementedUsersServer) CreateUser ¶
func (*UnimplementedUsersServer) CreateUser(context.Context, *CreateRequest) (*Empty, error)
func (*UnimplementedUsersServer) DeleteUser ¶
func (*UnimplementedUsersServer) DeleteUser(context.Context, *DeleteRequest) (*Empty, error)
func (*UnimplementedUsersServer) Follow ¶
func (*UnimplementedUsersServer) Follow(context.Context, *FollowRequest) (*Empty, error)
func (*UnimplementedUsersServer) GetTimeline ¶
func (*UnimplementedUsersServer) GetTimeline(context.Context, *GetTimelineRequest) (*GetTimelineResponse, error)
func (*UnimplementedUsersServer) GetUserInfoSummary ¶
func (*UnimplementedUsersServer) GetUserInfoSummary(context.Context, *GetSummaryRequest) (*GetSummaryReply, error)
func (*UnimplementedUsersServer) GetUsers ¶
func (*UnimplementedUsersServer) GetUsers(*GetUsersRequest, Users_GetUsersServer) error
func (*UnimplementedUsersServer) Unfollow ¶
func (*UnimplementedUsersServer) Unfollow(context.Context, *FollowRequest) (*Empty, error)
type User ¶
type User struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Firstname string `protobuf:"bytes,2,opt,name=firstname,proto3" json:"firstname,omitempty"` Lastname string `protobuf:"bytes,3,opt,name=lastname,proto3" json:"lastname,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` RegistrationTimestamp int64 `protobuf:"varint,5,opt,name=registration_timestamp,json=registrationTimestamp,proto3" json:"registration_timestamp,omitempty"` Followers []string `protobuf:"bytes,6,rep,name=followers,proto3" json:"followers,omitempty"` Following []string `protobuf:"bytes,7,rep,name=following,proto3" json:"following,omitempty"` Tweets []int64 `protobuf:"varint,8,rep,packed,name=tweets,proto3" json:"tweets,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*User) Descriptor ¶
func (*User) GetDescription ¶
func (*User) GetFirstname ¶
func (*User) GetFollowers ¶
func (*User) GetFollowing ¶
func (*User) GetLastname ¶
func (*User) GetRegistrationTimestamp ¶
func (*User) GetUsername ¶
func (*User) ProtoMessage ¶
func (*User) ProtoMessage()
func (*User) XXX_DiscardUnknown ¶
func (m *User) XXX_DiscardUnknown()
func (*User) XXX_Unmarshal ¶
type UsersClient ¶
type UsersClient interface { CreateUser(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*Empty, error) DeleteUser(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*Empty, error) GetUserInfoSummary(ctx context.Context, in *GetSummaryRequest, opts ...grpc.CallOption) (*GetSummaryReply, error) GetUsers(ctx context.Context, in *GetUsersRequest, opts ...grpc.CallOption) (Users_GetUsersClient, error) GetTimeline(ctx context.Context, in *GetTimelineRequest, opts ...grpc.CallOption) (*GetTimelineResponse, error) Follow(ctx context.Context, in *FollowRequest, opts ...grpc.CallOption) (*Empty, error) Unfollow(ctx context.Context, in *FollowRequest, opts ...grpc.CallOption) (*Empty, error) }
UsersClient is the client API for Users service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewUsersClient ¶
func NewUsersClient(cc grpc.ClientConnInterface) UsersClient
type UsersServer ¶
type UsersServer interface { CreateUser(context.Context, *CreateRequest) (*Empty, error) DeleteUser(context.Context, *DeleteRequest) (*Empty, error) GetUserInfoSummary(context.Context, *GetSummaryRequest) (*GetSummaryReply, error) GetUsers(*GetUsersRequest, Users_GetUsersServer) error GetTimeline(context.Context, *GetTimelineRequest) (*GetTimelineResponse, error) Follow(context.Context, *FollowRequest) (*Empty, error) Unfollow(context.Context, *FollowRequest) (*Empty, error) // contains filtered or unexported methods }
UsersServer is the server API for Users service. All implementations must embed UnimplementedUsersServer for forward compatibility
type Users_GetUsersClient ¶
type Users_GetUsersClient interface { Recv() (*GetUsersReply, error) grpc.ClientStream }
type Users_GetUsersServer ¶
type Users_GetUsersServer interface { Send(*GetUsersReply) error grpc.ServerStream }