rpc

Documentation

Index

• func RpcSetup(c *config.Config) (net.Listener, *grpc.Server, error)
• type Server
  • func (s *Server) GetStreamInfo(ctx context.Context, req *pb.TwitchUser) (*pb.StreamInfo, error)
  • func (s *Server) HealthCheck(ctx context.Context, req *pb.HealthRequest) (*pb.HealthStatus, error)
• type StreamInfo

Functions

func RpcSetup

func RpcSetup(c *config.Config) (net.Listener, *grpc.Server, error)

Types

type Server

type Server struct {
	pb.UnsafeTwitchViewsServer
	Config *config.Config
}

func (*Server) GetStreamInfo

func (s *Server) GetStreamInfo(ctx context.Context, req *pb.TwitchUser) (*pb.StreamInfo, error)

func (*Server) HealthCheck

func (s *Server) HealthCheck(ctx context.Context, req *pb.HealthRequest) (*pb.HealthStatus, error)

type StreamInfo

type StreamInfo struct {
	Data []struct {
		ID           string    `json:"id"`
		UserID       string    `json:"user_id"`
		UserLogin    string    `json:"user_login"`
		UserName     string    `json:"user_name"`
		GameID       string    `json:"game_id"`
		GameName     string    `json:"game_name"`
		Type         string    `json:"type"`
		Title        string    `json:"title"`
		ViewerCount  int       `json:"viewer_count"`
		StartedAt    time.Time `json:"started_at"`
		Language     string    `json:"language"`
		ThumbnailURL string    `json:"thumbnail_url"`
		TagIds       []string  `json:"tag_ids"`
		IsMature     bool      `json:"is_mature"`
	} `json:"data"`
	Pagination struct {
	} `json:"pagination"`
}