common

Documentation

Index

• Constants
• func NewResolver(endpoints []string, service string) resolver.Builder
• func PrivateIPv4() (net.IP, error)
• type Resolver
  • func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(rn resolver.ResolveNowOptions)
  • func (r *Resolver) Scheme() string
• type Service
  • func NewService(info ServiceInfo, etcdEndpoints []string) (service *Service, err error)
  • func (service *Service) Start() (err error)
  • func (service *Service) Stop()
• type ServiceInfo
• type StudentSrv
  • func (srv *StudentSrv) AllStudent(e *empty.Empty, rev api.StudentSrv_AllStudentServer) error
  • func (srv *StudentSrv) NewStudent(ctx context.Context, s *model.Student) (*protos.Result, error)
  • func (srv *StudentSrv) QueryStudents(student *api.QueryStudent, server api.StudentSrv_QueryStudentsServer) error
  • func (srv *StudentSrv) StudentByID(context.Context, *api.QueryStudent) (*api.QueryStudentResponse, error)
  • func (srv *StudentSrv) StudentInfo(stream api.StudentSrv_StudentInfoServer) error

Constants

const (
	ServName = "grpc_demo_srv"
)

Functions

func NewResolver

func NewResolver(endpoints []string, service string) resolver.Builder

NewResolver return resolver builder service is service name

func PrivateIPv4

func PrivateIPv4() (net.IP, error)

Types

type Resolver

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

resolver is the implementaion of grpc.resolve.Builder Resolver 实现grpc的grpc.resolve.Builder接口的Build与Scheme方法

func (*Resolver) Build

func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

Build to resolver.Resolver 实现grpc.resolve.Builder接口的方法

func (*Resolver) Close

func (r *Resolver) Close()

Close

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(rn resolver.ResolveNowOptions)

ResolveNow

func (*Resolver) Scheme

func (r *Resolver) Scheme() string

Scheme return etcd schema

type Service

type Service struct {
	ServiceInfo ServiceInfo
	// contains filtered or unexported fields
}

func NewService

func NewService(info ServiceInfo, etcdEndpoints []string) (service *Service, err error)

NewService 创建一个注册服务

func (*Service) Start

func (service *Service) Start() (err error)

Start 注册服务启动

func (*Service) Stop

func (service *Service) Stop()

type ServiceInfo

type ServiceInfo struct {
	Name string
	Addr string
}

服务信息

type StudentSrv

type StudentSrv struct {
	StudentList []*model.Student
	Version     string
}

func (*StudentSrv) AllStudent

func (srv *StudentSrv) AllStudent(e *empty.Empty, rev api.StudentSrv_AllStudentServer) error

func (*StudentSrv) NewStudent

func (srv *StudentSrv) NewStudent(ctx context.Context, s *model.Student) (*protos.Result, error)

func (*StudentSrv) QueryStudents

func (srv *StudentSrv) QueryStudents(student *api.QueryStudent, server api.StudentSrv_QueryStudentsServer) error

func (*StudentSrv) StudentByID

func (srv *StudentSrv) StudentByID(context.Context, *api.QueryStudent) (*api.QueryStudentResponse, error)

func (*StudentSrv) StudentInfo

func (srv *StudentSrv) StudentInfo(stream api.StudentSrv_StudentInfoServer) error