client

package
v0.0.0-...-4fdfd55 Latest Latest
Warning

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

 Go to latest Published: Sep 1, 2019 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrTimeout = errors.New("request timed out")

ErrTimeout happens when there is no response for a given request in the specified time frame.

Functions

func NewClient 

func NewClient(config Config, log log.Logger) (rpc.RPC, error)

NewClient returns a new instance of Client.

func NewMessage 

func NewMessage(rpc string) *protocol.Message

NewMessage generates a new RPC message. NewMessage ensures that a unique request ID has been generated.

Types

type Client 

type Client struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Client implements the RPC interface and provides a programmatic access to the backend API.

func (*Client) AddToWaitlist 

func (c *Client) AddToWaitlist(ctx context.Context, req rpc.AddToWaitlistRequest) (*rpc.AddToWaitlistResponse, error)

func (*Client) Auth 

func (c *Client) Auth(ctx context.Context, req rpc.AuthRequest) (*rpc.AuthResponse, error)

func (*Client) BlockUser 

func (c *Client) BlockUser(ctx context.Context, req rpc.BlockUserRequest) (*rpc.BlockUserResponse, error)

func (*Client) CanAffordAnonymousPost 

func (c *Client) CanAffordAnonymousPost(ctx context.Context, req rpc.CanAffordAnonymousPostRequest) (*rpc.CanAffordAnonymousPostResponse, error)

func (*Client) ConfirmValidation 

func (c *Client) ConfirmValidation(ctx context.Context, req rpc.ConfirmValidationRequest) (*rpc.ConfirmValidationResponse, error)

func (*Client) ConnectUsers 

func (c *Client) ConnectUsers(ctx context.Context, req rpc.ConnectUsersRequest) (*rpc.ConnectUsersResponse, error)

func (*Client) CreateChannel 

func (c *Client) CreateChannel(ctx context.Context, req rpc.CreateChannelRequest) (*rpc.CreateChannelResponse, error)

func (*Client) DecodeGenericResponse 

func (c *Client) DecodeGenericResponse(resp string) (*protocol.Message, error)

DecodeGenericResponse unmarshales a response into the generic Message format in order to parse header information.

func (*Client) DeleteCard 

func (c *Client) DeleteCard(ctx context.Context, req rpc.DeleteCardRequest) (*rpc.DeleteCardResponse, error)

func (*Client) FollowUser 

func (c *Client) FollowUser(ctx context.Context, req rpc.FollowUserRequest) (*rpc.FollowUserResponse, error)

func (*Client) GetActionCosts 

func (c *Client) GetActionCosts(ctx context.Context, req rpc.GetActionCostsRequest) (*rpc.GetActionCostsResponse, error)

func (*Client) GetAnonymousHandle 

func (c *Client) GetAnonymousHandle(ctx context.Context, req rpc.GetAnonymousHandleRequest) (*rpc.GetAnonymousHandleResponse, error)

func (*Client) GetCard 

func (c *Client) GetCard(ctx context.Context, req rpc.GetCardRequest) (*rpc.GetCardResponse, error)

func (*Client) GetCards 

func (c *Client) GetCards(ctx context.Context, req rpc.GetCardsRequest) (*rpc.GetCardsResponse, error)

func (*Client) GetCardsForChannel 

func (c *Client) GetCardsForChannel(ctx context.Context, req rpc.GetCardsForChannelRequest) (*rpc.GetCardsForChannelResponse, error)

func (*Client) GetChannel 

func (c *Client) GetChannel(ctx context.Context, req rpc.GetChannelRequest) (*rpc.GetChannelResponse, error)

func (*Client) GetChannels 

func (c *Client) GetChannels(ctx context.Context, req rpc.GetChannelsRequest) (*rpc.GetChannelsResponse, error)

func (*Client) GetFeaturesForUser 

func (c *Client) GetFeaturesForUser(ctx context.Context, req rpc.GetFeaturesForUserRequest) (*rpc.GetFeaturesForUserResponse, error)

func (*Client) GetFollowingUsers 

func (c *Client) GetFollowingUsers(ctx context.Context, req rpc.GetFollowingUsersRequest) (*rpc.GetFollowingUsersResponse, error)

func (*Client) GetInvites 

func (c *Client) GetInvites(ctx context.Context, req rpc.GetInvitesRequest) (*rpc.GetInvitesResponse, error)

func (*Client) GetLeaderboard 

func (c *Client) GetLeaderboard(ctx context.Context, req rpc.GetLeaderboardRequest) (*rpc.GetLeaderboardResponse, error)

func (*Client) GetMyNetwork 

func (c *Client) GetMyNetwork(ctx context.Context, req rpc.GetMyNetworkRequest) (*rpc.GetMyNetworkResponse, error)

func (*Client) GetNotifications 

func (c *Client) GetNotifications(ctx context.Context, req rpc.GetNotificationsRequest) (*rpc.GetNotificationsResponse, error)

func (*Client) GetOnboardingData 

func (c *Client) GetOnboardingData(ctx context.Context, req rpc.GetOnboardingDataRequest) (*rpc.GetOnboardingDataResponse, error)

func (*Client) GetPopularCards 

func (c *Client) GetPopularCards(ctx context.Context, req rpc.GetPopularCardsRequest) (*rpc.GetPopularCardsResponse, error)

func (*Client) GetPostsForUser 

func (c *Client) GetPostsForUser(ctx context.Context, req rpc.GetPostsForUserRequest) (*rpc.GetPostsForUserResponse, error)

func (*Client) GetTaggableUsers 

func (c *Client) GetTaggableUsers(ctx context.Context, req rpc.GetTaggableUsersRequest) (*rpc.GetTaggableUsersResponse, error)

func (*Client) GetTags 

func (c *Client) GetTags(ctx context.Context, req rpc.GetTagsRequest) (*rpc.GetTagsResponse, error)

func (*Client) GetThread 

func (c *Client) GetThread(ctx context.Context, req rpc.GetThreadRequest) (*rpc.GetThreadResponse, error)

func (*Client) GetUser 

func (c *Client) GetUser(ctx context.Context, req rpc.GetUserRequest) (*rpc.GetUserResponse, error)

func (*Client) GetUsers 

func (c *Client) GetUsers(ctx context.Context, req rpc.GetUsersRequest) (*rpc.GetUsersResponse, error)

func (*Client) GroupInvites 

func (c *Client) GroupInvites(ctx context.Context, req rpc.GroupInvitesRequest) (*rpc.GroupInvitesResponse, error)

func (*Client) JoinChannel 

func (c *Client) JoinChannel(ctx context.Context, req rpc.JoinChannelRequest) (*rpc.JoinChannelResponse, error)

func (*Client) LeaveChannel 

func (c *Client) LeaveChannel(ctx context.Context, req rpc.LeaveChannelRequest) (*rpc.LeaveChannelResponse, error)

func (*Client) Logout 

func (c *Client) Logout(ctx context.Context, req rpc.LogoutRequest) (*rpc.LogoutResponse, error)

func (*Client) ModifyCardScore 

func (c *Client) ModifyCardScore(ctx context.Context, req rpc.ModifyCardScoreRequest) (*rpc.ModifyCardScoreResponse, error)

func (*Client) MuteChannel 

func (c *Client) MuteChannel(ctx context.Context, req rpc.MuteChannelRequest) (*rpc.MuteChannelResponse, error)

func (*Client) MuteThread 

func (c *Client) MuteThread(ctx context.Context, req rpc.MuteThreadRequest) (*rpc.MuteThreadResponse, error)

func (*Client) MuteUser 

func (c *Client) MuteUser(ctx context.Context, req rpc.MuteUserRequest) (*rpc.MuteUserResponse, error)

func (*Client) NewInvite 

func (c *Client) NewInvite(ctx context.Context, req rpc.NewInviteRequest) (*rpc.NewInviteResponse, error)

func (*Client) NewUser 

func (c *Client) NewUser(ctx context.Context, req rpc.NewUserRequest) (*rpc.NewUserResponse, error)

func (*Client) PostCard 

func (c *Client) PostCard(ctx context.Context, req rpc.PostCardRequest) (*rpc.PostCardResponse, error)

func (*Client) PreviewContent 

func (c *Client) PreviewContent(ctx context.Context, req rpc.PreviewContentRequest) (*rpc.PreviewContentResponse, error)

func (*Client) ReactToCard 

func (c *Client) ReactToCard(ctx context.Context, req rpc.ReactToCardRequest) (*rpc.ReactToCardResponse, error)

func (*Client) RegisterDevice 

func (c *Client) RegisterDevice(ctx context.Context, req rpc.RegisterDeviceRequest) (*rpc.RegisterDeviceResponse, error)

func (*Client) ReportCard 

func (c *Client) ReportCard(ctx context.Context, req rpc.ReportCardRequest) (*rpc.ReportCardResponse, error)

func (*Client) RequestValidation 

func (c *Client) RequestValidation(ctx context.Context, req rpc.RequestValidationRequest) (*rpc.RequestValidationResponse, error)

func (*Client) ResetPassword 

func (c *Client) ResetPassword(ctx context.Context, req rpc.ResetPasswordRequest) (*rpc.ResetPasswordResponse, error)

func (*Client) SubmitFeedback 

func (c *Client) SubmitFeedback(ctx context.Context, req rpc.SubmitFeedbackRequest) (*rpc.SubmitFeedbackResponse, error)

func (*Client) SubscribeToCard 

func (c *Client) SubscribeToCard(ctx context.Context, req rpc.SubscribeToCardRequest) (*rpc.SubscribeToCardResponse, error)

func (*Client) TipCard 

func (c *Client) TipCard(ctx context.Context, req rpc.TipCardRequest) (*rpc.TipCardResponse, error)

func (*Client) UnfollowUser 

func (c *Client) UnfollowUser(ctx context.Context, req rpc.UnfollowUserRequest) (*rpc.UnfollowUserResponse, error)

func (*Client) UnmuteChannel 

func (c *Client) UnmuteChannel(ctx context.Context, req rpc.UnmuteChannelRequest) (*rpc.UnmuteChannelResponse, error)

func (*Client) UnmuteThread 

func (c *Client) UnmuteThread(ctx context.Context, req rpc.UnmuteThreadRequest) (*rpc.UnmuteThreadResponse, error)

func (*Client) UnmuteUser 

func (c *Client) UnmuteUser(ctx context.Context, req rpc.UnmuteUserRequest) (*rpc.UnmuteUserResponse, error)

func (*Client) UnregisterDevice 

func (c *Client) UnregisterDevice(ctx context.Context, req rpc.UnregisterDeviceRequest) (*rpc.UnregisterDeviceResponse, error)

func (*Client) UnsubscribeFromCard 

func (c *Client) UnsubscribeFromCard(ctx context.Context, req rpc.UnsubscribeFromCardRequest) (*rpc.UnsubscribeFromCardResponse, error)

func (*Client) UpdateChannelSubscription 

func (c *Client) UpdateChannelSubscription(ctx context.Context, req rpc.UpdateChannelSubscriptionRequest) (*rpc.UpdateChannelSubscriptionResponse, error)

func (*Client) UpdateNotifications 

func (c *Client) UpdateNotifications(ctx context.Context, req rpc.UpdateNotificationsRequest) (*rpc.UpdateNotificationsResponse, error)

func (*Client) UpdateSettings 

func (c *Client) UpdateSettings(ctx context.Context, req rpc.UpdateSettingsRequest) (*rpc.UpdateSettingsResponse, error)

func (*Client) UploadImage 

func (c *Client) UploadImage(ctx context.Context, req rpc.UploadImageRequest) (*rpc.UploadImageResponse, error)

func (*Client) UseInviteCode 

func (c *Client) UseInviteCode(ctx context.Context, req rpc.UseInviteCodeRequest) (*rpc.UseInviteCodeResponse, error)

func (*Client) ValidateChannelName 

func (c *Client) ValidateChannelName(ctx context.Context, req rpc.ValidateChannelNameRequest) (*rpc.ValidateChannelNameResponse, error)

func (*Client) ValidateInviteCode 

func (c *Client) ValidateInviteCode(ctx context.Context, req rpc.ValidateInviteCodeRequest) (*rpc.ValidateInviteCodeResponse, error)

func (*Client) ValidateUsername 

func (c *Client) ValidateUsername(ctx context.Context, req rpc.ValidateUsernameRequest) (*rpc.ValidateUsernameResponse, error)

func (*Client) VoteOnCard 

func (c *Client) VoteOnCard(ctx context.Context, req rpc.VoteOnCardRequest) (*rpc.VoteOnCardResponse, error)

type Config 

type Config struct {
	Address string
	APIKey  string
	Timeout time.Duration
}

Config provides the configuration for the client package.

func NewConfig 

func NewConfig() Config

NewConfig returns a new instance of Config.

func (Config) Validate 

func (c Config) Validate() error

Validate checks whether the configuration meets the requirements.

type WebSocketWriter 

type WebSocketWriter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*WebSocketWriter) ReadMessage 

func (w *WebSocketWriter) ReadMessage() (int, []byte, error)

func (*WebSocketWriter) WriteJSON 

func (w *WebSocketWriter) WriteJSON(v interface{}) error

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.