grpcserver

Documentation

Index

• func LogUnaryServerInterceptor(s services.ServiceManager) grpc.UnaryServerInterceptor
• type ServiceImpl
  • func New() *ServiceImpl
  • func (s *ServiceImpl) Address() string
  • func (s *ServiceImpl) Close() error
  • func (s *ServiceImpl) CreateUser(ctx context.Context, c *grpcs.UserRequest) (*grpcs.UserResponse, error)
  • func (s *ServiceImpl) DeleteUser(ctx context.Context, request *grpcs.UserRequest) (*grpcs.UserResponse, error)
  • func (s *ServiceImpl) GetUserById(ctx context.Context, c *grpcs.UserRequest) (*grpcs.UserResponse, error)
  • func (s *ServiceImpl) GetUsers(ctx context.Context, _ *empty.Empty) (*grpcs.UsersResponse, error)
  • func (s *ServiceImpl) Init(ctx context.Context) error
  • func (s *ServiceImpl) RegisterServices() *ServiceImpl
  • func (s *ServiceImpl) Run() error
  • func (s *ServiceImpl) ServiceManager() services.ServiceManager
  • func (s *ServiceImpl) UpdateUser(ctx context.Context, c *grpcs.UserRequest) (*grpcs.UserResponse, error)
  • func (s *ServiceImpl) WithAddress(address string) *ServiceImpl
  • func (s *ServiceImpl) WithServiceManager(c services.ServiceManager) services.GrpcServer

Functions

func LogUnaryServerInterceptor

func LogUnaryServerInterceptor(s services.ServiceManager) grpc.UnaryServerInterceptor

UnaryServerInterceptor returns a new unary server interceptors that adds kit.Logger to the context.

Types

type ServiceImpl

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

func New

func New() *ServiceImpl

func (*ServiceImpl) Address

func (s *ServiceImpl) Address() string

func (*ServiceImpl) Close

func (s *ServiceImpl) Close() error

func (*ServiceImpl) CreateUser

func (s *ServiceImpl) CreateUser(ctx context.Context, c *grpcs.UserRequest) (*grpcs.UserResponse, error)

func (*ServiceImpl) DeleteUser

func (s *ServiceImpl) DeleteUser(ctx context.Context, request *grpcs.UserRequest) (*grpcs.UserResponse, error)

func (*ServiceImpl) GetUserById

func (s *ServiceImpl) GetUserById(ctx context.Context, c *grpcs.UserRequest) (*grpcs.UserResponse, error)

func (*ServiceImpl) GetUsers

func (s *ServiceImpl) GetUsers(ctx context.Context, _ *empty.Empty) (*grpcs.UsersResponse, error)

func (*ServiceImpl) Init

func (s *ServiceImpl) Init(ctx context.Context) error

func (*ServiceImpl) RegisterServices

func (s *ServiceImpl) RegisterServices() *ServiceImpl

func (*ServiceImpl) Run

func (s *ServiceImpl) Run() error

func (*ServiceImpl) ServiceManager

func (s *ServiceImpl) ServiceManager() services.ServiceManager

func (*ServiceImpl) UpdateUser

func (s *ServiceImpl) UpdateUser(ctx context.Context, c *grpcs.UserRequest) (*grpcs.UserResponse, error)

func (*ServiceImpl) WithAddress

func (s *ServiceImpl) WithAddress(address string) *ServiceImpl

func (*ServiceImpl) WithServiceManager

func (s *ServiceImpl) WithServiceManager(c services.ServiceManager) services.GrpcServer