grpc

Documentation

Index

• func NewTokenPayloadProvider(address string, timeout time.Duration) (model.TokenPayloadProvider, error)
• type GRPCClient
  • func (p *GRPCClient) Close() error
  • func (p *GRPCClient) TokenPayloadForApp(appId, appName, userID string) (map[string]interface{}, error)
• type GRPCServer
  • func (s *GRPCServer) Close(ctx context.Context, _ *pp.CloseRequest) (*pp.CloseResponse, error)
  • func (s *GRPCServer) TokenPayload(ctx context.Context, request *pp.TokenPayloadRequest) (*pp.TokenPayloadResponse, error)

Functions

func NewTokenPayloadProvider

func NewTokenPayloadProvider(address string, timeout time.Duration) (model.TokenPayloadProvider, error)

Types

type GRPCClient

type GRPCClient struct {
	Client  pp.PayloadProviderServiceClient
	Timeout time.Duration

	Closable io.Closer
}

func (*GRPCClient) Close

func (p *GRPCClient) Close() error

func (*GRPCClient) TokenPayloadForApp

func (p *GRPCClient) TokenPayloadForApp(appId, appName, userID string) (map[string]interface{}, error)

type GRPCServer

type GRPCServer struct {
	// This is the real implementation
	Impl model.TokenPayloadProvider
	pp.UnimplementedPayloadProviderServiceServer
}

Here is the gRPC server that GRPCClient talks to.

func (*GRPCServer) Close

func (s *GRPCServer) Close(ctx context.Context, _ *pp.CloseRequest) (*pp.CloseResponse, error)

func (*GRPCServer) TokenPayload

func (s *GRPCServer) TokenPayload(ctx context.Context, request *pp.TokenPayloadRequest) (*pp.TokenPayloadResponse, error)