rpc

Documentation

Index

• func InitClients(mode string) ([]*grpc.ClientConn, error)
• type AllClient
• type Dorm
  • func (d *Dorm) GetAll(req *pb.EmptyRequest) (*pb.GetAllReply, error)
  • func (d *Dorm) GetRemainCnt(req *pb.EmptyRequest) (*pb.MapReply, error)
• type EtcdRegister
  • func InitEtcdRegister() (*EtcdRegister, error)
  • func (e *EtcdRegister) Close() error
  • func (e *EtcdRegister) RegisterServer(serviceName, addr string, expire int64) error
• type EtcdResolverBuilder
  • func InitEtcdResolverBuilder() (*EtcdResolverBuilder, error)
  • func (r EtcdResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (r EtcdResolverBuilder) Close() error
  • func (r EtcdResolverBuilder) Scheme() string
• type Order
  • func (o *Order) Delete(req *pb.DeleteRequest) (*pb.DeleteReply, error)
  • func (o *Order) Get(req *pb.GetRequest) (*pb.GetReply, error)
• type Team
  • func (t *Team) Create(req *pb.CreateRequest) (*pb.CreateReply, error)
  • func (t *Team) Get(req *pb.GetRequest) (*pb.GetReply, error)
  • func (t *Team) Join(req *pb.JoinRequest) (*pb.JoinReply, error)
  • func (t *Team) Leave(req *pb.LeaveRequest) (*pb.LeaveReply, error)
  • func (t *Team) Transfer(req *pb.TransferRequest) (*pb.TransferReply, error)
• type Token
  • func (t *Token) GenAccessToken(req *pb.GenAccessTokenRequest) (*pb.TokenReply, error)
  • func (t *Token) GenAllToken(req *pb.GenAllTokenRequest) (*pb.TokenReply, error)
• type User
  • func (u *User) Edit(req *pb.EditRequest) (*pb.EditReply, error)
  • func (u *User) Get(req *pb.GetRequest) (*pb.GetReply, error)
  • func (u *User) Login(req *pb.RegisterLoginRequest) (*pb.UserReply, error)
  • func (u *User) Register(req *pb.RegisterLoginRequest) (*pb.UserReply, error)

Functions

func InitClients

func InitClients(mode string) ([]*grpc.ClientConn, error)

InitClients initialize RPC clients and return all connections

Types

type AllClient

type AllClient struct {
	Dorm  Dorm
	Order Order
	Team  Team
	Token Token
	User  User
}

var Client AllClient

type Dorm

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

func (*Dorm) GetAll

func (d *Dorm) GetAll(req *pb.EmptyRequest) (*pb.GetAllReply, error)

func (*Dorm) GetRemainCnt

func (d *Dorm) GetRemainCnt(req *pb.EmptyRequest) (*pb.MapReply, error)

type EtcdRegister

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

func InitEtcdRegister

func InitEtcdRegister() (*EtcdRegister, error)

func (*EtcdRegister) Close

func (e *EtcdRegister) Close() error

func (*EtcdRegister) RegisterServer

func (e *EtcdRegister) RegisterServer(serviceName, addr string, expire int64) error

type EtcdResolverBuilder

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

func InitEtcdResolverBuilder

func InitEtcdResolverBuilder() (*EtcdResolverBuilder, error)

func (EtcdResolverBuilder) Build

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

func (EtcdResolverBuilder) Close

func (r EtcdResolverBuilder) Close() error

func (EtcdResolverBuilder) Scheme

func (r EtcdResolverBuilder) Scheme() string

type Order

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

func (*Order) Delete

func (o *Order) Delete(req *pb.DeleteRequest) (*pb.DeleteReply, error)

func (*Order) Get

func (o *Order) Get(req *pb.GetRequest) (*pb.GetReply, error)

type Team

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

func (*Team) Create

func (t *Team) Create(req *pb.CreateRequest) (*pb.CreateReply, error)

func (*Team) Get

func (t *Team) Get(req *pb.GetRequest) (*pb.GetReply, error)

func (*Team) Join

func (t *Team) Join(req *pb.JoinRequest) (*pb.JoinReply, error)

func (*Team) Leave

func (t *Team) Leave(req *pb.LeaveRequest) (*pb.LeaveReply, error)

func (*Team) Transfer

func (t *Team) Transfer(req *pb.TransferRequest) (*pb.TransferReply, error)

type Token

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

func (*Token) GenAccessToken

func (t *Token) GenAccessToken(req *pb.GenAccessTokenRequest) (*pb.TokenReply, error)

func (*Token) GenAllToken

func (t *Token) GenAllToken(req *pb.GenAllTokenRequest) (*pb.TokenReply, error)

type User

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

func (*User) Edit

func (u *User) Edit(req *pb.EditRequest) (*pb.EditReply, error)

func (*User) Get

func (u *User) Get(req *pb.GetRequest) (*pb.GetReply, error)

func (*User) Login

func (u *User) Login(req *pb.RegisterLoginRequest) (*pb.UserReply, error)

func (*User) Register

func (u *User) Register(req *pb.RegisterLoginRequest) (*pb.UserReply, error)