server

Documentation

Index

• Variables
• type GRPC
  • func (g *GRPC) Add(ctx context.Context, req *pb.User) (*wrapperspb.StringValue, error)
  • func (g *GRPC) Del(ctx context.Context, req *wrapperspb.StringValue) (*emptypb.Empty, error)
  • func (g *GRPC) Find(ctx context.Context, req *wrapperspb.StringValue) (*pb.User, error)
  • func (g *GRPC) List(_ *emptypb.Empty, resp pb.Account_ListServer) error
  • func (g *GRPC) ShutdownGRPC() error
  • func (g *GRPC) StartupGRPC() error

Variables

var (
	GrpcHost string
	GrpcPort int
)

Types

type GRPC

type GRPC struct {
	ServiceName string
	ExecTimeout time.Duration
	Client      *clientv3.Client

	pb.UnimplementedAccountServer
	// contains filtered or unexported fields
}

func (*GRPC) Add

func (g *GRPC) Add(ctx context.Context, req *pb.User) (*wrapperspb.StringValue, error)

func (*GRPC) Del

func (g *GRPC) Del(ctx context.Context, req *wrapperspb.StringValue) (*emptypb.Empty, error)

func (*GRPC) Find

func (g *GRPC) Find(ctx context.Context, req *wrapperspb.StringValue) (*pb.User, error)

func (*GRPC) List

func (g *GRPC) List(_ *emptypb.Empty, resp pb.Account_ListServer) error

func (*GRPC) ShutdownGRPC

func (g *GRPC) ShutdownGRPC() error

func (*GRPC) StartupGRPC

func (g *GRPC) StartupGRPC() error