rkgrpc

Oct 24, 2023

Changes in this version

type GrpcEntry

+ GwPort uint64

type GrpcEntryOption

+ func WithGwPort(gwPort uint64) GrpcEntryOption

Sep 25, 2022

Changes in this version

+ func ToAllowOriginFunc(allowOrigins []string) grpcweb.Option

+ func ToGrpcWebOptions(conf *BootConfigGrpcWeb) []grpcweb.Option

+ type BootConfigGrpcWeb struct

+ Cors struct{ ... }

+ Enabled bool

+ Websocket struct{ ... }

type GrpcEntry

+ GrpcWebOptions []grpcweb.Option

+ func (entry *GrpcEntry) IsGrpcWebEnabled() bool

type GrpcEntryOption

+ func WithGrpcWebOptions(opts ...grpcweb.Option) GrpcEntryOption

Apr 4, 2022

Changes in this version

type GrpcEntry

+ func (entry *GrpcEntry) AddGwMuxOptions(opts ...gwruntime.ServeMuxOption)

Mar 17, 2022

Changes in this version

type GrpcEntry

+ PProfEntry *rkentry.PProfEntry

+ func (entry *GrpcEntry) IsPProfEnabled() bool

type GrpcEntryOption

+ func WithPProfEntry(p *rkentry.PProfEntry) GrpcEntryOption

Mar 5, 2022

Changes in this version

+ const GrpcEntryType

+ const HeaderBased

+ const IpBased

+ const PathBased

+ const ProxyEntryNameDefault

+ const ProxyEntryType

+ func Codec() encoding.Codec

+ func CodecWithFallback(fallback encoding.Codec) encoding.Codec

+ func HttpErrorHandler(ctx context.Context, mux *runtime.ServeMux, marshaler runtime.Marshaler, ...)

+ func IncomingHeaderMatcher(key string) (string, bool)

+ func NewRkGwServerMuxOptions(mOptIn *protojson.MarshalOptions, uOptIn *protojson.UnmarshalOptions) []runtime.ServeMuxOption

+ func NewRule(opts ...ruleOption) *rule

+ func OutgoingHeaderMatcher(key string) (string, bool)

+ func RegisterGrpcEntryYAML(raw []byte) map[string]rkentry.Entry

+ func TransparentHandler(director Director) grpc.StreamHandler

+ func WithHeaderPatterns(pattern ...*HeaderPattern) ruleOption

+ func WithIpPatterns(pattern ...*IpPattern) ruleOption

+ func WithPathPatterns(pattern ...*PathPattern) ruleOption

+ type BootConfig struct

+ Grpc []struct{ ... }

+ type BootConfigProxy struct

+ Enabled bool

+ Rules []struct{ ... }

+ type Director func(context.Context) (context.Context, *grpc.ClientConn, error)

+ type GrpcEntry struct

+ CertEntry *rkentry.CertEntry

+ CommonServiceEntry *rkentry.CommonServiceEntry

+ DocsEntry *rkentry.DocsEntry

+ EnableReflection bool

+ EventEntry *rkentry.EventEntry

+ GrpcRegF []GrpcRegFunc

+ GwDialOptions []grpc.DialOption

+ GwMux *gwruntime.ServeMux

+ GwMuxOptions []gwruntime.ServeMuxOption

+ GwRegF []GwRegFunc

+ HttpMux *http.ServeMux

+ HttpServer *http.Server

+ LoggerEntry *rkentry.LoggerEntry

+ Port uint64

+ PromEntry *rkentry.PromEntry

+ ProxyEntry *ProxyEntry

+ SWEntry *rkentry.SWEntry

+ Server *grpc.Server

+ ServerOpts []grpc.ServerOption

+ StaticFileEntry *rkentry.StaticFileHandlerEntry

+ StreamInterceptors []grpc.StreamServerInterceptor

+ TlsConfig *tls.Config

+ TlsConfigInsecure *tls.Config

+ UnaryInterceptors []grpc.UnaryServerInterceptor

+ func GetGrpcEntry(name string) *GrpcEntry

+ func RegisterGrpcEntry(opts ...GrpcEntryOption) *GrpcEntry

+ func (entry *GrpcEntry) AddGwCorsOptions(opts ...rkmidcors.Option)

+ func (entry *GrpcEntry) AddGwCsrfOptions(opts ...rkmidcsrf.Option)

+ func (entry *GrpcEntry) AddGwDialOptions(opts ...grpc.DialOption)

+ func (entry *GrpcEntry) AddGwSecureOptions(opts ...rkmidsec.Option)

+ func (entry *GrpcEntry) AddRegFuncGrpc(f ...GrpcRegFunc)

+ func (entry *GrpcEntry) AddRegFuncGw(f ...GwRegFunc)

+ func (entry *GrpcEntry) AddServerOptions(opts ...grpc.ServerOption)

+ func (entry *GrpcEntry) AddStreamInterceptors(inter ...grpc.StreamServerInterceptor)

+ func (entry *GrpcEntry) AddUnaryInterceptors(inter ...grpc.UnaryServerInterceptor)

+ func (entry *GrpcEntry) Bootstrap(ctx context.Context)

+ func (entry *GrpcEntry) GetDescription() string

+ func (entry *GrpcEntry) GetName() string

+ func (entry *GrpcEntry) GetType() string

+ func (entry *GrpcEntry) Interrupt(ctx context.Context)

+ func (entry *GrpcEntry) IsCommonServiceEnabled() bool

+ func (entry *GrpcEntry) IsDocsEnabled() bool

+ func (entry *GrpcEntry) IsPromEnabled() bool

+ func (entry *GrpcEntry) IsProxyEnabled() bool

+ func (entry *GrpcEntry) IsSWEnabled() bool

+ func (entry *GrpcEntry) IsStaticFileHandlerEnabled() bool

+ func (entry *GrpcEntry) IsTlsEnabled() bool

+ func (entry *GrpcEntry) MarshalJSON() ([]byte, error)

+ func (entry *GrpcEntry) String() string

+ func (entry *GrpcEntry) UnmarshalJSON([]byte) error

+ type GrpcEntryOption func(*GrpcEntry)

+ func WithCertEntry(certEntry *rkentry.CertEntry) GrpcEntryOption

+ func WithCommonServiceEntry(commonService *rkentry.CommonServiceEntry) GrpcEntryOption

+ func WithDescription(description string) GrpcEntryOption

+ func WithDocsEntry(docs *rkentry.DocsEntry) GrpcEntryOption

+ func WithEnableReflection(enabled bool) GrpcEntryOption

+ func WithEventEntry(logger *rkentry.EventEntry) GrpcEntryOption

+ func WithGrpcDialOptions(opts ...grpc.DialOption) GrpcEntryOption

+ func WithGrpcRegF(f ...GrpcRegFunc) GrpcEntryOption

+ func WithGwMuxOptions(opts ...gwruntime.ServeMuxOption) GrpcEntryOption

+ func WithGwRegF(f ...GwRegFunc) GrpcEntryOption

+ func WithLoggerEntry(logger *rkentry.LoggerEntry) GrpcEntryOption

+ func WithName(name string) GrpcEntryOption

+ func WithPort(port uint64) GrpcEntryOption

+ func WithPromEntry(prom *rkentry.PromEntry) GrpcEntryOption

+ func WithProxyEntry(proxy *ProxyEntry) GrpcEntryOption

+ func WithServerOptions(opts ...grpc.ServerOption) GrpcEntryOption

+ func WithStaticFileHandlerEntry(staticEntry *rkentry.StaticFileHandlerEntry) GrpcEntryOption

+ func WithStreamInterceptors(opts ...grpc.StreamServerInterceptor) GrpcEntryOption

+ func WithSwEntry(sw *rkentry.SWEntry) GrpcEntryOption

+ func WithUnaryInterceptors(opts ...grpc.UnaryServerInterceptor) GrpcEntryOption

+ type GrpcRegFunc func(server *grpc.Server)

+ type GwRegFunc func(context.Context, *gwruntime.ServeMux, string, []grpc.DialOption) error

+ type HeaderPattern struct

+ Dest []string

+ Headers map[string]string

+ type IpPattern struct

+ Cidrs []string

+ Dest []string

+ type PathPattern struct

+ Dest []string

+ Paths []string

+ type ProxyEntry struct

+ EventEntry *rkentry.EventEntry

+ LoggerEntry *rkentry.LoggerEntry

+ func NewProxyEntry(opts ...ProxyEntryOption) *ProxyEntry

+ func (entry *ProxyEntry) Bootstrap(ctx context.Context)

+ func (entry *ProxyEntry) GetDescription() string

+ func (entry *ProxyEntry) GetName() string

+ func (entry *ProxyEntry) GetType() string

+ func (entry *ProxyEntry) Interrupt(ctx context.Context)

+ func (entry *ProxyEntry) MarshalJSON() ([]byte, error)

+ func (entry *ProxyEntry) String() string

+ func (entry *ProxyEntry) UnmarshalJSON(b []byte) error

+ type ProxyEntryOption func(*ProxyEntry)

+ func WithEventEntryProxy(eventEntry *rkentry.EventEntry) ProxyEntryOption

+ func WithLoggerEntryProxy(loggerEntry *rkentry.LoggerEntry) ProxyEntryOption

+ func WithNameProxy(name string) ProxyEntryOption

+ func WithRuleProxy(r *rule) ProxyEntryOption