middleware

Documentation

Index

• Constants
• func AccessStorageInterceptor(svc *logstore.Service[*record.AccessLog]) grpc.UnaryServerInterceptor
• func ActivityInterceptor() grpc.UnaryServerInterceptor
• func AuthorizationInterceptor(verifier authz.APITokenVerifier, authConfig authz.Config) grpc.UnaryServerInterceptor
• func CallDurationHandler() grpc.UnaryServerInterceptor
• func DefaultTracingServer() grpc.UnaryServerInterceptor
• func ErrorHandler() grpc.UnaryServerInterceptor
• func ExecutionHandler(queries *query.Queries) grpc.UnaryServerInterceptor
• func InstanceInterceptor(verifier authz.InstanceVerifier, externalDomain string, ...) grpc.UnaryServerInterceptor
• func LimitsInterceptor(ignoreService ...string) grpc.UnaryServerInterceptor
• func MetricsHandler(metricTypes []metrics.MetricType, ignoredMethodSuffixes ...string) grpc.UnaryServerInterceptor
• func NoCacheInterceptor() grpc.UnaryServerInterceptor
• func QuotaExhaustedInterceptor(svc *logstore.Service[*record.AccessLog], ignoreService ...string) grpc.UnaryServerInterceptor
• func RegisterGrpcRequestCodeCounter(ctx context.Context, info *grpc.UnaryServerInfo, err error)
• func RegisterGrpcRequestCounter(ctx context.Context, info *grpc.UnaryServerInfo)
• func RegisterGrpcTotalRequestCounter(ctx context.Context)
• func RegisterMetrics(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (_ interface{}, err error)
• func ServiceHandler() grpc.UnaryServerInterceptor
• func TracingServer(ignoredMethods ...GRPCMethod) grpc.UnaryServerInterceptor
• func TranslationHandler() ...
• func ValidationHandler() grpc.UnaryServerInterceptor
• type ContextInfoRequest
  • func (c *ContextInfoRequest) GetContent() interface{}
  • func (c *ContextInfoRequest) GetHTTPRequestBody() []byte
  • func (c *ContextInfoRequest) SetHTTPResponseBody(resp []byte) error
• type ContextInfoResponse
  • func (c *ContextInfoResponse) GetContent() interface{}
  • func (c *ContextInfoResponse) GetHTTPRequestBody() []byte
  • func (c *ContextInfoResponse) SetHTTPResponseBody(resp []byte) error
• type ExecutionQueries
• type GRPCMethod
• type Localizer
• type Organization
• type OrganizationFromRequest

Constants

const (
	GrpcMethod                         = "grpc_method"
	ReturnCode                         = "return_code"
	GrpcRequestCounter                 = "grpc.server.request_counter"
	GrpcRequestCounterDescription      = "Grpc request counter"
	TotalGrpcRequestCounter            = "grpc.server.total_request_counter"
	TotalGrpcRequestCounterDescription = "Total grpc request counter"
	GrpcStatusCodeCounter              = "grpc.server.grpc_status_code"
	GrpcStatusCodeCounterDescription   = "Grpc status code counter"
)

const (
	HTTP1Host = "x-zitadel-http1-host"
)

Functions

func AccessStorageInterceptor

func AccessStorageInterceptor(svc *logstore.Service[*record.AccessLog]) grpc.UnaryServerInterceptor

func ActivityInterceptor

func ActivityInterceptor() grpc.UnaryServerInterceptor

func AuthorizationInterceptor

func AuthorizationInterceptor(verifier authz.APITokenVerifier, authConfig authz.Config) grpc.UnaryServerInterceptor

func CallDurationHandler

func CallDurationHandler() grpc.UnaryServerInterceptor

func DefaultTracingServer

func DefaultTracingServer() grpc.UnaryServerInterceptor

func ErrorHandler

func ErrorHandler() grpc.UnaryServerInterceptor

func ExecutionHandler

func ExecutionHandler(queries *query.Queries) grpc.UnaryServerInterceptor

func InstanceInterceptor

func InstanceInterceptor(verifier authz.InstanceVerifier, externalDomain string, explicitInstanceIdServices ...string) grpc.UnaryServerInterceptor

func LimitsInterceptor

func LimitsInterceptor(ignoreService ...string) grpc.UnaryServerInterceptor

func MetricsHandler

func MetricsHandler(metricTypes []metrics.MetricType, ignoredMethodSuffixes ...string) grpc.UnaryServerInterceptor

func NoCacheInterceptor

func NoCacheInterceptor() grpc.UnaryServerInterceptor

func QuotaExhaustedInterceptor

func QuotaExhaustedInterceptor(svc *logstore.Service[*record.AccessLog], ignoreService ...string) grpc.UnaryServerInterceptor

func RegisterGrpcRequestCodeCounter

func RegisterGrpcRequestCodeCounter(ctx context.Context, info *grpc.UnaryServerInfo, err error)

func RegisterGrpcRequestCounter

func RegisterGrpcRequestCounter(ctx context.Context, info *grpc.UnaryServerInfo)

func RegisterGrpcTotalRequestCounter

func RegisterGrpcTotalRequestCounter(ctx context.Context)

func RegisterMetrics

func RegisterMetrics(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler, metricTypes []metrics.MetricType, ignoredMethodSuffixes ...string) (_ interface{}, err error)

func ServiceHandler

func ServiceHandler() grpc.UnaryServerInterceptor

func TracingServer

func TracingServer(ignoredMethods ...GRPCMethod) grpc.UnaryServerInterceptor

func TranslationHandler

func TranslationHandler() func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

func ValidationHandler

func ValidationHandler() grpc.UnaryServerInterceptor

Types

type ContextInfoRequest

type ContextInfoRequest struct {
	FullMethod string      `json:"fullMethod,omitempty"`
	InstanceID string      `json:"instanceID,omitempty"`
	OrgID      string      `json:"orgID,omitempty"`
	ProjectID  string      `json:"projectID,omitempty"`
	UserID     string      `json:"userID,omitempty"`
	Request    interface{} `json:"request,omitempty"`
}

func (*ContextInfoRequest) GetContent

func (c *ContextInfoRequest) GetContent() interface{}

func (*ContextInfoRequest) GetHTTPRequestBody

func (c *ContextInfoRequest) GetHTTPRequestBody() []byte

func (*ContextInfoRequest) SetHTTPResponseBody

func (c *ContextInfoRequest) SetHTTPResponseBody(resp []byte) error

type ContextInfoResponse

type ContextInfoResponse struct {
	FullMethod string      `json:"fullMethod,omitempty"`
	InstanceID string      `json:"instanceID,omitempty"`
	OrgID      string      `json:"orgID,omitempty"`
	ProjectID  string      `json:"projectID,omitempty"`
	UserID     string      `json:"userID,omitempty"`
	Request    interface{} `json:"request,omitempty"`
	Response   interface{} `json:"response,omitempty"`
}

func (*ContextInfoResponse) GetContent

func (c *ContextInfoResponse) GetContent() interface{}

func (*ContextInfoResponse) GetHTTPRequestBody

func (c *ContextInfoResponse) GetHTTPRequestBody() []byte

func (*ContextInfoResponse) SetHTTPResponseBody

func (c *ContextInfoResponse) SetHTTPResponseBody(resp []byte) error

type ExecutionQueries

type ExecutionQueries interface {
	TargetsByExecutionIDs(ctx context.Context, ids1, ids2 []string) (execution []*query.ExecutionTarget, err error)
}

type GRPCMethod

type GRPCMethod string

type Localizer

type Localizer interface {
	LocalizationKey() string
	SetLocalizedMessage(string)
}

type Organization

type Organization struct {
	ID     string
	Domain string
}

type OrganizationFromRequest

type OrganizationFromRequest interface {
	OrganizationFromRequest() *Organization
}