rkgrpc

Jan 17, 2022

Changes in this version

+ type BootConfig struct

+ Grpc []struct{ ... }

type GrpcEntry

+ func (entry *GrpcEntry) Apis(w http.ResponseWriter, req *http.Request)

+ func (entry *GrpcEntry) GwErrorMapping(w http.ResponseWriter, req *http.Request)

+ func (entry *GrpcEntry) Req(w http.ResponseWriter, req *http.Request)

+ func (entry *GrpcEntry) TV(w http.ResponseWriter, req *http.Request)

type GrpcEntryOption

+ func WithCertEntry(certEntry *rkentry.CertEntry) GrpcEntryOption

+ func WithCommonServiceEntry(commonService *rkentry.CommonServiceEntry) GrpcEntryOption

+ func WithDescription(description string) GrpcEntryOption

+ func WithEnableReflection(enabled bool) GrpcEntryOption

+ func WithEventLoggerEntry(logger *rkentry.EventLoggerEntry) GrpcEntryOption

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

+ func WithGwMappingFilePaths(paths ...string) GrpcEntryOption

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

+ func WithGwRegF(f ...GwRegFunc) GrpcEntryOption

+ func WithPromEntry(prom *rkentry.PromEntry) GrpcEntryOption

+ func WithProxyEntry(proxy *ProxyEntry) GrpcEntryOption

+ func WithStaticFileHandlerEntry(staticEntry *rkentry.StaticFileHandlerEntry) GrpcEntryOption

+ func WithSwEntry(sw *rkentry.SwEntry) GrpcEntryOption

+ func WithTvEntry(tv *rkentry.TvEntry) GrpcEntryOption

+ func WithZapLoggerEntry(logger *rkentry.ZapLoggerEntry) GrpcEntryOption

Dec 5, 2021

Changes in this version

+ const StaticFileHandlerEntryDescription

+ const StaticFileHandlerEntryNameDefault

+ const StaticFileHandlerEntryType

+ type BootConfigStaticHandler struct

+ Enabled bool

+ Path string

+ SourcePath string

+ SourceType string

type GrpcEntry

+ StaticFileEntry *StaticFileHandlerEntry

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

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

+ func (entry *GrpcEntry) IsStaticFileHandlerEnabled() bool

type GrpcEntryOption

+ func WithStaticFileHandlerEntryGrpc(staticEntry *StaticFileHandlerEntry) GrpcEntryOption

+ type StaticFileHandlerEntry struct

+ EntryDescription string

+ EntryName string

+ EntryType string

+ EventLoggerEntry *rkentry.EventLoggerEntry

+ Fs http.FileSystem

+ Path string

+ Template *template.Template

+ ZapLoggerEntry *rkentry.ZapLoggerEntry

+ func NewStaticFileHandlerEntry(opts ...StaticFileHandlerEntryOption) *StaticFileHandlerEntry

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

+ func (entry *StaticFileHandlerEntry) GetDescription() string

+ func (entry *StaticFileHandlerEntry) GetFileHandler(w http.ResponseWriter, r *http.Request)

+ func (entry *StaticFileHandlerEntry) GetName() string

+ func (entry *StaticFileHandlerEntry) GetType() string

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

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

+ func (entry *StaticFileHandlerEntry) String() string

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

+ type StaticFileHandlerEntryOption func(*StaticFileHandlerEntry)

+ func WithEventLoggerEntryStatic(eventLoggerEntry *rkentry.EventLoggerEntry) StaticFileHandlerEntryOption

+ func WithFileSystemStatic(fs http.FileSystem) StaticFileHandlerEntryOption

+ func WithNameStatic(name string) StaticFileHandlerEntryOption

+ func WithPathStatic(path string) StaticFileHandlerEntryOption

+ func WithZapLoggerEntryStatic(zapLoggerEntry *rkentry.ZapLoggerEntry) StaticFileHandlerEntryOption

Nov 26, 2021

Changes in this version

type GrpcEntry

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

Nov 18, 2021

Changes in this version

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

Nov 12, 2021

Changes in this version

+ const HeaderBased

+ const IpBased

+ const PathBased

+ const ProxyEntryDescription

+ const ProxyEntryNameDefault

+ const ProxyEntryType

+ func Codec() encoding.Codec

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

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

+ func TransparentHandler(director Director) grpc.StreamHandler

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

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

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

+ type BootConfigProxy struct

+ Enabled bool

+ Rules []struct{ ... }

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

type GrpcEntry

+ ProxyEntry *ProxyEntry

+ func (entry *GrpcEntry) IsProxyEnabled() bool

type GrpcEntryOption

+ func WithProxyEntryGrpc(proxy *ProxyEntry) GrpcEntryOption

+ 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

+ EntryDescription string

+ EntryName string

+ EntryType string

+ EventLoggerEntry *rkentry.EventLoggerEntry

+ ZapLoggerEntry *rkentry.ZapLoggerEntry

+ 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 WithEventLoggerEntryProxy(eventLoggerEntry *rkentry.EventLoggerEntry) ProxyEntryOption

+ func WithNameProxy(name string) ProxyEntryOption

+ func WithRuleProxy(r *rule) ProxyEntryOption

+ func WithZapLoggerEntryProxy(zapLoggerEntry *rkentry.ZapLoggerEntry) ProxyEntryOption

Sep 10, 2021

Changes in this version

type CommonServiceEntry

+ GrpcRegF GrpcRegFunc

+ GwRegF GwRegFunc

type GrpcEntry

+ GrpcRegF []GrpcRegFunc

+ GwDialOptions []grpc.DialOption

+ GwHttpToGrpcMapping map[string]*gwRule

+ GwMappingFilePaths []string

+ GwMux *gwruntime.ServeMux

+ GwMuxOptions []gwruntime.ServeMuxOption

+ GwRegF []GwRegFunc

+ HttpMux *http.ServeMux

+ HttpServer *http.Server

+ PromEntry *PromEntry

+ SwEntry *SwEntry

+ TlsConfig *tls.Config

+ TlsConfigInsecure *tls.Config

+ TvEntry *TvEntry

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

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

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

+ func (entry *GrpcEntry) IsPromEnabled() bool

+ func (entry *GrpcEntry) IsSwEnabled() bool

+ func (entry *GrpcEntry) IsTvEnabled() bool

type GrpcEntryOption

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

+ func WithGrpcRegF(f ...GrpcRegFunc) GrpcEntryOption

+ func WithGwMappingFilePathsGrpc(paths ...string) GrpcEntryOption

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

+ func WithGwRegFGrpc(f ...GwRegFunc) GrpcEntryOption

+ func WithPromEntryGrpc(prom *PromEntry) GrpcEntryOption

+ func WithSwEntryGrpc(sw *SwEntry) GrpcEntryOption

+ func WithTvEntryGrpc(tv *TvEntry) GrpcEntryOption

Jul 11, 2021

Changes in this version

+ const CommonServiceEntryDescription

+ const CommonServiceEntryNameDefault

+ const CommonServiceEntryType

+ const CommonServiceGwMappingFilePath

+ const GrpcEntryDescription

+ const GrpcEntryType

+ const GwEntryDescription

+ const GwEntryNameDefault

+ const GwEntryType

+ const PromEntryDescription

+ const PromEntryNameDefault

+ const PromEntryType

+ const SwEntryCommonServiceJsonFileSuffix

+ const SwEntryDescription

+ const SwEntryNameDefault

+ const SwEntryType

+ const TvEntryDescription

+ const TvEntryNameDefault

+ const TvEntryType

+ var RkGwServerMuxOptions = []runtime.ServeMuxOption

+ var Templates = map[string][]byte

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

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

+ func RegisterGrpcEntriesWithConfig(configFilePath string) map[string]rkentry.Entry

+ type BootConfigCommonService struct

+ Enabled bool

+ type BootConfigGrpc struct

+ Grpc []struct{ ... }

+ type BootConfigGw struct

+ Cert struct{ ... }

+ Enabled bool

+ GwMappingFilePaths []string

+ Port uint64

+ Prom BootConfigProm

+ RkServerOption bool

+ SW BootConfigSw

+ TV BootConfigTv

+ type BootConfigProm struct

+ Enabled bool

+ Path string

+ Pusher struct{ ... }

+ type BootConfigSw struct

+ Enabled bool

+ Headers []string

+ JsonPath string

+ Path string

+ type BootConfigTv struct

+ Enabled bool

+ type CommonServiceEntry struct

+ EntryDescription string

+ EntryName string

+ EntryType string

+ EventLoggerEntry *rkentry.EventLoggerEntry

+ GwMapping map[string]string

+ GwMappingFilePath string

+ RegFuncGrpc GrpcRegFunc

+ RegFuncGw GwRegFunc

+ ZapLoggerEntry *rkentry.ZapLoggerEntry

+ func NewCommonServiceEntry(opts ...CommonServiceEntryOption) *CommonServiceEntry

+ func (entry *CommonServiceEntry) Apis(ctx context.Context, request *rk_grpc_common_v1.ApisRequest) (*structpb.Struct, error)

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

+ func (entry *CommonServiceEntry) Certs(ctx context.Context, request *rk_grpc_common_v1.CertsRequest) (*structpb.Struct, error)

+ func (entry *CommonServiceEntry) Configs(ctx context.Context, request *rk_grpc_common_v1.ConfigsRequest) (*structpb.Struct, error)

+ func (entry *CommonServiceEntry) Deps(ctx context.Context, request *rk_grpc_common_v1.DepsRequest) (*structpb.Struct, error)

+ func (entry *CommonServiceEntry) Entries(ctx context.Context, request *rk_grpc_common_v1.EntriesRequest) (*structpb.Struct, error)

+ func (entry *CommonServiceEntry) Gc(ctx context.Context, request *rk_grpc_common_v1.GcRequest) (*structpb.Struct, error)

+ func (entry *CommonServiceEntry) GetDescription() string

+ func (entry *CommonServiceEntry) GetName() string

+ func (entry *CommonServiceEntry) GetType() string

+ func (entry *CommonServiceEntry) Git(ctx context.Context, request *rk_grpc_common_v1.GitRequest) (*structpb.Struct, error)

+ func (entry *CommonServiceEntry) GwErrorMapping(ctx context.Context, request *rk_grpc_common_v1.GwErrorMappingRequest) (*structpb.Struct, error)

+ func (entry *CommonServiceEntry) Healthy(ctx context.Context, request *rk_grpc_common_v1.HealthyRequest) (*structpb.Struct, error)

+ func (entry *CommonServiceEntry) Info(ctx context.Context, request *rk_grpc_common_v1.InfoRequest) (*structpb.Struct, error)

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

+ func (entry *CommonServiceEntry) License(ctx context.Context, request *rk_grpc_common_v1.LicenseRequest) (*structpb.Struct, error)

+ func (entry *CommonServiceEntry) Logs(ctx context.Context, request *rk_grpc_common_v1.LogsRequest) (*structpb.Struct, error)

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

+ func (entry *CommonServiceEntry) Readme(ctx context.Context, request *rk_grpc_common_v1.ReadmeRequest) (*structpb.Struct, error)

+ func (entry *CommonServiceEntry) Req(ctx context.Context, request *rk_grpc_common_v1.ReqRequest) (*structpb.Struct, error)

+ func (entry *CommonServiceEntry) String() string

+ func (entry *CommonServiceEntry) Sys(ctx context.Context, request *rk_grpc_common_v1.SysRequest) (*structpb.Struct, error)

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

+ type CommonServiceEntryOption func(*CommonServiceEntry)

+ func WithEventLoggerEntryCommonService(eventLoggerEntry *rkentry.EventLoggerEntry) CommonServiceEntryOption

+ func WithNameCommonService(name string) CommonServiceEntryOption

+ func WithZapLoggerEntryCommonService(zapLoggerEntry *rkentry.ZapLoggerEntry) CommonServiceEntryOption

+ type GrpcEntry struct

+ CertEntry *rkentry.CertEntry

+ CommonServiceEntry *CommonServiceEntry

+ EnableReflection bool

+ EntryDescription string

+ EntryName string

+ EntryType string

+ EventLoggerEntry *rkentry.EventLoggerEntry

+ GwEntry *GwEntry

+ Listener net.Listener

+ Port uint64

+ RegFuncs []GrpcRegFunc

+ Server *grpc.Server

+ ServerOpts []grpc.ServerOption

+ StreamInterceptors []grpc.StreamServerInterceptor

+ UnaryInterceptors []grpc.UnaryServerInterceptor

+ ZapLoggerEntry *rkentry.ZapLoggerEntry

+ func GetGrpcEntry(name string) *GrpcEntry

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

+ func (entry *GrpcEntry) AddGrpcRegFuncs(funcs ...GrpcRegFunc)

+ func (entry *GrpcEntry) AddGwRegFuncs(funcs ...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) IsGwEnabled() 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 WithCertEntryGrpc(certEntry *rkentry.CertEntry) GrpcEntryOption

+ func WithCommonServiceEntryGrpc(commonService *CommonServiceEntry) GrpcEntryOption

+ func WithDescriptionGrpc(description string) GrpcEntryOption

+ func WithEnableReflectionGrpc(enabled bool) GrpcEntryOption

+ func WithEventLoggerEntryGrpc(logger *rkentry.EventLoggerEntry) GrpcEntryOption

+ func WithGrpcRegFuncsGrpc(funcs ...GrpcRegFunc) GrpcEntryOption

+ func WithGwEntryGrpc(gw *GwEntry) GrpcEntryOption

+ func WithNameGrpc(name string) GrpcEntryOption

+ func WithPortGrpc(port uint64) GrpcEntryOption

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

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

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

+ func WithZapLoggerEntryGrpc(logger *rkentry.ZapLoggerEntry) GrpcEntryOption

+ type GrpcRegFunc func(server *grpc.Server)

+ type GwEntry struct

+ CertEntry *rkentry.CertEntry

+ CommonServiceEntry *CommonServiceEntry

+ EntryDescription string

+ EntryName string

+ EntryType string

+ EventLoggerEntry *rkentry.EventLoggerEntry

+ GrpcCertEntry *rkentry.CertEntry

+ GrpcDialOptions []grpc.DialOption

+ GrpcPort uint64

+ GwMapping map[string]*gwRule

+ GwMappingFilePaths []string

+ GwMux *runtime.ServeMux

+ HttpPort uint64

+ Mux *http.ServeMux

+ PromEntry *PromEntry

+ RegFuncsGw []GwRegFunc

+ Server *http.Server

+ ServerMuxOptions []runtime.ServeMuxOption

+ SwEntry *SwEntry

+ TvEntry *TvEntry

+ ZapLoggerEntry *rkentry.ZapLoggerEntry

+ func NewGwEntry(opts ...GwOption) *GwEntry

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

+ func (entry *GwEntry) GetDescription() string

+ func (entry *GwEntry) GetName() string

+ func (entry *GwEntry) GetType() string

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

+ func (entry *GwEntry) IsCommonServiceEnabled() bool

+ func (entry *GwEntry) IsGrpcTlsEnabled() bool

+ func (entry *GwEntry) IsPromEnabled() bool

+ func (entry *GwEntry) IsServerTlsEnabled() bool

+ func (entry *GwEntry) IsSwEnabled() bool

+ func (entry *GwEntry) IsTvEnabled() bool

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

+ func (entry *GwEntry) String() string

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

+ type GwOption func(*GwEntry)

+ func WithCertEntryGw(certEntry *rkentry.CertEntry) GwOption

+ func WithCommonServiceEntryGw(commonService *CommonServiceEntry) GwOption

+ func WithEventLoggerEntryGw(eventLoggerEntry *rkentry.EventLoggerEntry) GwOption

+ func WithGrpcCertEntryGw(grpcCertEntry *rkentry.CertEntry) GwOption

+ func WithGrpcDialOptionsGw(opts ...grpc.DialOption) GwOption

+ func WithGrpcPortGw(port uint64) GwOption

+ func WithGwMappingFilePathsGw(paths ...string) GwOption

+ func WithHttpPortGw(port uint64) GwOption

+ func WithNameGw(name string) GwOption

+ func WithPromEntryGw(prom *PromEntry) GwOption

+ func WithRegFuncsGw(funcs ...GwRegFunc) GwOption

+ func WithServerMuxOptionsGw(opts ...runtime.ServeMuxOption) GwOption

+ func WithSwEntryGw(sw *SwEntry) GwOption

+ func WithTvEntryGw(tv *TvEntry) GwOption

+ func WithZapLoggerEntryGw(zapLoggerEntry *rkentry.ZapLoggerEntry) GwOption

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

+ type PromEntry struct

+ EntryDescription string

+ EntryName string

+ EntryType string

+ EventLoggerEntry *rkentry.EventLoggerEntry

+ Gatherer prometheus.Gatherer

+ Path string

+ Port uint64

+ Pusher *rkprom.PushGatewayPusher

+ Registerer prometheus.Registerer

+ Registry *prometheus.Registry

+ ZapLoggerEntry *rkentry.ZapLoggerEntry

+ func NewPromEntry(opts ...PromEntryOption) *PromEntry

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

+ func (entry *PromEntry) GetDescription() string

+ func (entry *PromEntry) GetName() string

+ func (entry *PromEntry) GetType() string

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

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

+ func (entry *PromEntry) RegisterCollectors(collectors ...prometheus.Collector) error

+ func (entry *PromEntry) String() string

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

+ type PromEntryOption func(*PromEntry)

+ func WithEventLoggerEntryProm(eventLoggerEntry *rkentry.EventLoggerEntry) PromEntryOption

+ func WithNameProm(name string) PromEntryOption

+ func WithPathProm(path string) PromEntryOption

+ func WithPortProm(port uint64) PromEntryOption

+ func WithPromRegistryProm(registry *prometheus.Registry) PromEntryOption

+ func WithPusherProm(pusher *rkprom.PushGatewayPusher) PromEntryOption

+ func WithZapLoggerEntryProm(zapLoggerEntry *rkentry.ZapLoggerEntry) PromEntryOption

+ type SwEntry struct

+ EnableCommonService bool

+ EntryDescription string

+ EntryName string

+ EntryType string

+ EventLoggerEntry *rkentry.EventLoggerEntry

+ Headers map[string]string

+ JsonPath string

+ Path string

+ Port uint64

+ ZapLoggerEntry *rkentry.ZapLoggerEntry

+ func NewSwEntry(opts ...SwOption) *SwEntry

+ func (entry *SwEntry) AssetsFileHandler(w http.ResponseWriter, r *http.Request)

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

+ func (entry *SwEntry) ConfigFileHandler(w http.ResponseWriter, r *http.Request)

+ func (entry *SwEntry) GetDescription() string

+ func (entry *SwEntry) GetName() string

+ func (entry *SwEntry) GetType() string

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

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

+ func (entry *SwEntry) String() string

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

+ type SwOption func(*SwEntry)

+ func WithEnableCommonServiceSw(enabled bool) SwOption

+ func WithEventLoggerEntrySw(eventLoggerEntry *rkentry.EventLoggerEntry) SwOption

+ func WithHeadersSw(headers map[string]string) SwOption

+ func WithJsonPathSw(path string) SwOption

+ func WithNameSw(name string) SwOption

+ func WithPathSw(path string) SwOption

+ func WithPortSw(port uint64) SwOption

+ func WithZapLoggerEntrySw(zapLoggerEntry *rkentry.ZapLoggerEntry) SwOption

+ type TvEntry struct

+ EntryDescription string

+ EntryName string

+ EntryType string

+ EventLoggerEntry *rkentry.EventLoggerEntry

+ Template *template.Template

+ ZapLoggerEntry *rkentry.ZapLoggerEntry

+ func NewTvEntry(opts ...TvEntryOption) *TvEntry

+ func (entry *TvEntry) AssetsFileHandler(w http.ResponseWriter, r *http.Request)

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

+ func (entry *TvEntry) GetDescription() string

+ func (entry *TvEntry) GetName() string

+ func (entry *TvEntry) GetType() string

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

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

+ func (entry *TvEntry) String() string

+ func (entry *TvEntry) TV(w http.ResponseWriter, r *http.Request)

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

+ type TvEntryOption func(entry *TvEntry)

+ func WithEventLoggerEntryTv(eventLoggerEntry *rkentry.EventLoggerEntry) TvEntryOption

+ func WithNameTv(name string) TvEntryOption

+ func WithZapLoggerEntryTv(zapLoggerEntry *rkentry.ZapLoggerEntry) TvEntryOption

Nov 22, 2020

Changes in this version

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

type CommonServiceGRpc

+ func (service *CommonServiceGRpc) APIS(ctx context.Context, request *rk_grpc_common_v1.ListAPIRequest) (*rk_grpc_common_v1.ListAPIResponse, error)

+ func (service *CommonServiceGRpc) Config(ctx context.Context, request *rk_grpc_common_v1.DumpConfigRequest) (*rk_grpc_common_v1.DumpConfigResponse, error)

+ func (service *CommonServiceGRpc) Req(ctx context.Context, request *rk_grpc_common_v1.ReqRequest) (*rk_grpc_common_v1.ReqResponse, error)

+ func (service *CommonServiceGRpc) Sys(ctx context.Context, request *rk_grpc_common_v1.SysRequest) (*rk_grpc_common_v1.SysResponse, error)

Nov 9, 2020

Changes in this version

type GRpcEntry

+ func (entry *GRpcEntry) GetType() string

+ func (entry *GRpcEntry) IsGWEnabled() bool

+ func (entry *GRpcEntry) IsTlsEnabled() bool

+ func (entry *GRpcEntry) String() string

+ func (entry *GRpcEntry) Wait(draining time.Duration)

Nov 8, 2020

Changes in this version

+ func NewGRpcEntries(path string, factory *rk_query.EventFactory, logger *zap.Logger) map[string]*GRpcEntry

+ type CommonServiceGRpc struct

+ func NewCommonServiceGRpc() *CommonServiceGRpc

+ func (service *CommonServiceGRpc) DumpConfig(ctx context.Context, request *rk_grpc_common_v1.DumpConfigRequest) (*rk_grpc_common_v1.DumpConfigResponse, error)

+ func (service *CommonServiceGRpc) GC(ctx context.Context, request *rk_grpc_common_v1.GCRequest) (*rk_grpc_common_v1.GCResponse, error)

+ func (service *CommonServiceGRpc) Healthy(ctx context.Context, request *rk_grpc_common_v1.HealthyRequest) (*rk_grpc_common_v1.HealthyResponse, error)

+ func (service *CommonServiceGRpc) Info(ctx context.Context, request *rk_grpc_common_v1.InfoRequest) (*rk_grpc_common_v1.InfoResponse, error)

+ type GRpcEntry struct

+ func NewGRpcEntry(opts ...GRpcEntryOption) *GRpcEntry

+ func (entry *GRpcEntry) AddGRpcRegFuncs(funcs ...RegFuncGRpc)

+ func (entry *GRpcEntry) AddGWRegFuncs(funcs ...regFuncGW)

+ 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(event rk_query.Event)

+ func (entry *GRpcEntry) GetGWEntry() *gwEntry

+ func (entry *GRpcEntry) GetListener() net.Listener

+ func (entry *GRpcEntry) GetName() string

+ func (entry *GRpcEntry) GetPort() uint64

+ func (entry *GRpcEntry) GetServer() *grpc.Server

+ func (entry *GRpcEntry) Shutdown(event rk_query.Event)

+ type GRpcEntryOption func(*GRpcEntry)

+ func WithCommonService(enable bool) GRpcEntryOption

+ func WithGWEntry(gw *gwEntry) GRpcEntryOption

+ func WithLogger(log *zap.Logger) GRpcEntryOption

+ func WithName(name string) GRpcEntryOption

+ func WithPort(port uint64) GRpcEntryOption

+ func WithRegFuncs(funcs ...RegFuncGRpc) GRpcEntryOption

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

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

+ func WithTlsEntry(tls *tlsEntry) GRpcEntryOption

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

+ type RegFuncGRpc func(server *grpc.Server)