sentinel

Documentation

Index

• Constants
• func SetDubboConsumerFallback(f DubboFallback)
• func SetDubboProviderFallback(f DubboFallback)
• type ConsumerFilter
  • func (d *ConsumerFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result
  • func (d *ConsumerFilter) OnResponse(ctx context.Context, result protocol.Result, _ protocol.Invoker, ...) protocol.Result
• type DubboFallback
• type DubboLoggerWrapper
  • func (d DubboLoggerWrapper) Debug(msg string, keysAndValues ...interface{})
  • func (d DubboLoggerWrapper) DebugEnabled() bool
  • func (d DubboLoggerWrapper) Error(err error, msg string, keysAndValues ...interface{})
  • func (d DubboLoggerWrapper) ErrorEnabled() bool
  • func (d DubboLoggerWrapper) Info(msg string, keysAndValues ...interface{})
  • func (d DubboLoggerWrapper) InfoEnabled() bool
  • func (d DubboLoggerWrapper) Warn(msg string, keysAndValues ...interface{})
  • func (d DubboLoggerWrapper) WarnEnabled() bool
• type ProviderFilter
  • func (d *ProviderFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result
  • func (d *ProviderFilter) OnResponse(ctx context.Context, result protocol.Result, _ protocol.Invoker, ...) protocol.Result

Constants

const (
	DefaultProviderPrefix = "dubbo:provider:"
	DefaultConsumerPrefix = "dubbo:consumer:"

	MethodEntryKey    = constant.DubboCtxKey("$$sentinelMethodEntry")
	InterfaceEntryKey = constant.DubboCtxKey("$$sentinelInterfaceEntry")
)

Functions

func SetDubboConsumerFallback

func SetDubboConsumerFallback(f DubboFallback)

func SetDubboProviderFallback

func SetDubboProviderFallback(f DubboFallback)

Types

type ConsumerFilter

type ConsumerFilter struct{}

func (*ConsumerFilter) Invoke

func (d *ConsumerFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result

func (*ConsumerFilter) OnResponse

func (d *ConsumerFilter) OnResponse(ctx context.Context, result protocol.Result, _ protocol.Invoker, _ protocol.Invocation) protocol.Result

type DubboFallback

type DubboFallback func(context.Context, protocol.Invoker, protocol.Invocation, *base.BlockError) protocol.Result

type DubboLoggerWrapper

type DubboLoggerWrapper struct {
	logger.Logger
}

func (DubboLoggerWrapper) Debug

func (d DubboLoggerWrapper) Debug(msg string, keysAndValues ...interface{})

func (DubboLoggerWrapper) DebugEnabled

func (d DubboLoggerWrapper) DebugEnabled() bool

func (DubboLoggerWrapper) Error

func (d DubboLoggerWrapper) Error(err error, msg string, keysAndValues ...interface{})

func (DubboLoggerWrapper) ErrorEnabled

func (d DubboLoggerWrapper) ErrorEnabled() bool

func (DubboLoggerWrapper) Info

func (d DubboLoggerWrapper) Info(msg string, keysAndValues ...interface{})

func (DubboLoggerWrapper) InfoEnabled

func (d DubboLoggerWrapper) InfoEnabled() bool

func (DubboLoggerWrapper) Warn

func (d DubboLoggerWrapper) Warn(msg string, keysAndValues ...interface{})

func (DubboLoggerWrapper) WarnEnabled

func (d DubboLoggerWrapper) WarnEnabled() bool

type ProviderFilter

type ProviderFilter struct{}

func (*ProviderFilter) Invoke

func (d *ProviderFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result

func (*ProviderFilter) OnResponse

func (d *ProviderFilter) OnResponse(ctx context.Context, result protocol.Result, _ protocol.Invoker, _ protocol.Invocation) protocol.Result