adapter

Documentation

Index

• func GetInfo() adapter.Info
• type ApigeeHandler
  • func (h *ApigeeHandler) HandleAnalytics(ctx context.Context, im []*analytics.InstanceMsg) error
  • func (h *ApigeeHandler) HandleAuthorization(ctx context.Context, im *authorization.InstanceMsg) (*model.CheckResult, error)
• type GRPCAdapter
  • func NewGRPCAdapter(addr string) (*GRPCAdapter, error)
  • func (g *GRPCAdapter) Addr() string
  • func (g *GRPCAdapter) Close() error
  • func (g *GRPCAdapter) HandleAnalytics(ctx context.Context, r *analytics.HandleAnalyticsRequest) (*model.ReportResult, error)
  • func (g *GRPCAdapter) HandleAuthorization(ctx context.Context, r *authorization.HandleAuthorizationRequest) (*model.CheckResult, error)
  • func (g *GRPCAdapter) Run(shutdown chan error)
• type Server

Functions

func GetInfo

func GetInfo() adapter.Info

GetInfo returns the adapter.Info associated with this implementation.

Types

type ApigeeHandler

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

ApigeeHandler handles a single tenant (org/env)

func (*ApigeeHandler) HandleAnalytics

func (h *ApigeeHandler) HandleAnalytics(ctx context.Context, im []*analytics.InstanceMsg) error

HandleAnalytics is in the context of a single tenant

func (*ApigeeHandler) HandleAuthorization

func (h *ApigeeHandler) HandleAuthorization(ctx context.Context, im *authorization.InstanceMsg) (*model.CheckResult, error)

HandleAuthorization is in the context of a single tenant

type GRPCAdapter

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

GRPCAdapter handles multi-tenancy

func NewGRPCAdapter

func NewGRPCAdapter(addr string) (*GRPCAdapter, error)

NewGRPCAdapter creates a new no session server from given args.

func (*GRPCAdapter) Addr

func (g *GRPCAdapter) Addr() string

Addr returns the listening address of the server

func (*GRPCAdapter) Close

func (g *GRPCAdapter) Close() error

Close gracefully shuts down the server; used for testing

func (*GRPCAdapter) HandleAnalytics

func (g *GRPCAdapter) HandleAnalytics(ctx context.Context,
	r *analytics.HandleAnalyticsRequest) (*model.ReportResult, error)

HandleAnalytics is a gRPC endpoint

func (*GRPCAdapter) HandleAuthorization

func (g *GRPCAdapter) HandleAuthorization(ctx context.Context,
	r *authorization.HandleAuthorizationRequest) (*model.CheckResult, error)

HandleAuthorization is a gRPC endpoint

func (*GRPCAdapter) Run

func (g *GRPCAdapter) Run(shutdown chan error)

Run starts the server run

type Server

type Server interface {
	Addr() string
	Close() error
	Run(shutdown chan error)
}

Server is the gRPC server instance