Александр Павлюк

case <-ctx.Done():
      return nil, ctx.Err()

ctx, cancel := context.WithTimeout(context.Background(), time.Second)
defer cancel()
resp, err := srv.RPCClient.Call(ctx, topic, payload)
if err != nil { // тут вернет ошибку "context cancelled" при таймауте
  srv.logger.Error("RPC call error. ", err)
  return err
}

func getA() []IA {
	var arr = make([]IA, 10)
	arr[0] = a{}
	return arr
}

package main

import (
	"errors"
	"fmt"
	"strings"
)

type validator interface {
	Validate() error
}

type FieldEmail string

func (fi *FieldEmail) Validate() error {
	if fi == nil {
		return errors.New("invalid field")
	}

	if !strings.Contains(string(*fi), "@") {
		return errors.New("invalid field")
	}

	return nil
}

func NewFieldEmail(str string) *FieldEmail {
	fieldEmail := FieldEmail(str)
	return &fieldEmail
}

func checkValidators(validators ...validator) error {
	for _, v := range validators {
		if v == nil {
			continue
		}
		if err := v.Validate(); err != nil {
			return err
		}
	}
	return nil
}

func main() {
	fmt.Printf("Error: %v\n", checkValidators(NewFieldEmail("test@test")))

	var email *FieldEmail
	fmt.Printf("Error: %v\n", checkValidators(email))
}

ctx, cancel := context.WithTimeout(r.Context(), config.Read().HTTP.Timeout.Request*time.Second)

City = s.Find(".list-jobs__details__info > .icon-location").Text()

body, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        http.Error(w, "error reading response body", http.StatusInternalServerError)
        return
    }

    // write status code and body from proxy request into the answer
    w.WriteHeader(resp.StatusCode)
    w.Write(body)

w.WriteHeader(resp.StatusCode)
_, err := io.Copy(w, body)
if err != nil {
    http.Error(w, "error reading response body", http.StatusInternalServerError)
    return
}

longDescription = s.Find(".vacancy-post").Not(".vacancy-page-title").Text()

str := "UserName: Vasya Pupkin"
result := strings.TrimPrefix(str, "UserName: ")
fmt.Println(result)