service

Documentation

Overview

Package service provides an implemenation of the twitter service defined under package proto.

Index

• type Server
  • func NewTwitterServer(httpClient *http.Client) *Server
  • func (s *Server) SearchTweets(ctx context.Context, args *pb.SearchTweetsArgs) (*pb.SearchTweetsRet, error)
  • func (s *Server) StreamTweets(args *pb.StreamTweetsArgs, stream pb.Twitter_StreamTweetsServer) error
• type TwitterError
  • func (e TwitterError) Error() string

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server is a grpc complient server as defined in /proto.

func NewTwitterServer

func NewTwitterServer(httpClient *http.Client) *Server

NewTwitterServer creates a new grpc complient server as defined in /proto.

func (*Server) SearchTweets

func (s *Server) SearchTweets(ctx context.Context, args *pb.SearchTweetsArgs) (*pb.SearchTweetsRet, error)

SearchTweets queries the Twitter REST API.

func (*Server) StreamTweets

func (s *Server) StreamTweets(args *pb.StreamTweetsArgs, stream pb.Twitter_StreamTweetsServer) error

StreamTweets queries the Twitter STREAM API.

type TwitterError

type TwitterError struct {
	Errors []apierror `json:"errors"`
}

TwitterError represents a Twitter API Error response. https://dev.twitter.com/overview/api/response-codes

func (TwitterError) Error

func (e TwitterError) Error() string