rpccontext

Documentation

Index

• func AddMetricsLabel(ctx context.Context, name, value string)
• func AddRPCAuditFields(ctx context.Context, fields logrus.Fields)
• func AuditLog(ctx context.Context) (audit.Logger, bool)
• func AuditRPC(ctx context.Context)
• func AuditRPCWithError(ctx context.Context, err error)
• func AuditRPCWithFields(ctx context.Context, fields logrus.Fields)
• func AuditRPCWithTypesStatus(ctx context.Context, s *types.Status, fieldsFunc func() logrus.Fields)
• func CallCounter(ctx context.Context) api.CallCounter
• func CallerAddr(ctx context.Context) net.Addr
• func CallerAdminEntries(ctx context.Context) ([]*types.Entry, bool)
• func CallerDownstreamEntries(ctx context.Context) ([]*types.Entry, bool)
• func CallerID(ctx context.Context) (spiffeid.ID, bool)
• func CallerIsAdmin(ctx context.Context) bool
• func CallerIsAgent(ctx context.Context) bool
• func CallerIsDownstream(ctx context.Context) bool
• func CallerIsLocal(ctx context.Context) bool
• func CallerX509SVID(ctx context.Context) (*x509.Certificate, bool)
• func Logger(ctx context.Context) logrus.FieldLogger
• func Names(ctx context.Context) (api.Names, bool)
• func RateLimit(ctx context.Context, count int) error
• func RateLimiter(ctx context.Context) (api.RateLimiter, bool)
• func WithAgentCaller(ctx context.Context) context.Context
• func WithAuditLog(ctx context.Context, auditLog audit.Logger) context.Context
• func WithCallCounter(ctx context.Context, counter api.CallCounter) context.Context
• func WithCallerAddr(ctx context.Context, addr net.Addr) context.Context
• func WithCallerAdminEntries(ctx context.Context, entries []*types.Entry) context.Context
• func WithCallerDownstreamEntries(ctx context.Context, entries []*types.Entry) context.Context
• func WithCallerID(ctx context.Context, id spiffeid.ID) context.Context
• func WithCallerX509SVID(ctx context.Context, x509SVID *x509.Certificate) context.Context
• func WithLocalCaller(ctx context.Context) context.Context
• func WithLogger(ctx context.Context, log logrus.FieldLogger) context.Context
• func WithNames(ctx context.Context, names api.Names) context.Context
• func WithRateLimiter(ctx context.Context, limiter api.RateLimiter) context.Context

Functions

func AddMetricsLabel

func AddMetricsLabel(ctx context.Context, name, value string)

func AddRPCAuditFields

func AddRPCAuditFields(ctx context.Context, fields logrus.Fields)

func AuditLog

func AuditLog(ctx context.Context) (audit.Logger, bool)

func AuditRPC

func AuditRPC(ctx context.Context)

func AuditRPCWithError

func AuditRPCWithError(ctx context.Context, err error)

func AuditRPCWithFields

func AuditRPCWithFields(ctx context.Context, fields logrus.Fields)

func AuditRPCWithTypesStatus

func AuditRPCWithTypesStatus(ctx context.Context, s *types.Status, fieldsFunc func() logrus.Fields)

func CallCounter

func CallCounter(ctx context.Context) api.CallCounter

func CallerAddr

func CallerAddr(ctx context.Context) net.Addr

CallerAddr returns the caller address.

func CallerAdminEntries

func CallerAdminEntries(ctx context.Context) ([]*types.Entry, bool)

CallerAdminEntries returns the admin entries for the caller. If the caller is not an admin caller, it returns false.

func CallerDownstreamEntries

func CallerDownstreamEntries(ctx context.Context) ([]*types.Entry, bool)

CallerDownstreamEntries returns the downstream entries for the caller. If the caller is not a downstream caller, it returns false.

func CallerID

func CallerID(ctx context.Context) (spiffeid.ID, bool)

CallerID returns the caller ID, if available.

func CallerIsAdmin

func CallerIsAdmin(ctx context.Context) bool

CallerIsAdmin returns true if the caller is an admin caller.

func CallerIsAgent

func CallerIsAgent(ctx context.Context) bool

CallerIsAgent returns true if the caller is an agent.

func CallerIsDownstream

func CallerIsDownstream(ctx context.Context) bool

CallerIsDownstream returns true if the caller is a downstream caller.

func CallerIsLocal

func CallerIsLocal(ctx context.Context) bool

CallerIsLocal returns true if the caller is local.

func CallerX509SVID

func CallerX509SVID(ctx context.Context) (*x509.Certificate, bool)

CallerX509SVID returns the caller X509SVID, if available.

func Logger

func Logger(ctx context.Context) logrus.FieldLogger

func Names

func Names(ctx context.Context) (api.Names, bool)

func RateLimit

func RateLimit(ctx context.Context, count int) error

func RateLimiter

func RateLimiter(ctx context.Context) (api.RateLimiter, bool)

func WithAgentCaller

func WithAgentCaller(ctx context.Context) context.Context

WithAgentCaller returns a context whether the caller is tagged as an agent.

func WithAuditLog

func WithAuditLog(ctx context.Context, auditLog audit.Logger) context.Context

func WithCallCounter

func WithCallCounter(ctx context.Context, counter api.CallCounter) context.Context

func WithCallerAddr

func WithCallerAddr(ctx context.Context, addr net.Addr) context.Context

WithCallerAddr returns a context with the given address.

func WithCallerAdminEntries

func WithCallerAdminEntries(ctx context.Context, entries []*types.Entry) context.Context

WithCallerAdminEntries returns a context with the given entries.

func WithCallerDownstreamEntries

func WithCallerDownstreamEntries(ctx context.Context, entries []*types.Entry) context.Context

WithCallerDownstreamEntries returns a context with the given entries.

func WithCallerID

func WithCallerID(ctx context.Context, id spiffeid.ID) context.Context

WithCallerID returns a context with the given ID.

func WithCallerX509SVID

func WithCallerX509SVID(ctx context.Context, x509SVID *x509.Certificate) context.Context

WithCallerX509SVID returns a context with the given X509SVID.

func WithLocalCaller

func WithLocalCaller(ctx context.Context) context.Context

WithLocalCaller returns a context whether the caller is tagged as local.

func WithLogger

func WithLogger(ctx context.Context, log logrus.FieldLogger) context.Context

func WithNames

func WithNames(ctx context.Context, names api.Names) context.Context

func WithRateLimiter

func WithRateLimiter(ctx context.Context, limiter api.RateLimiter) context.Context