Versions in this module Expand all Collapse all v0 v0.1.0 Jun 9, 2018 Changes in this version + func SvcName(entry *Entry) string + type CDSResult struct + Clusters []*EnvoyCluster + func (mj *CDSResult) MarshalJSON() ([]byte, error) + func (mj *CDSResult) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *CDSResult) UnmarshalJSON(input []byte) error + func (uj *CDSResult) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type Entry struct + BackendAddr *net.TCPAddr + EnvironmentName string + FrontendAddr *net.TCPAddr + ProxyMode string + ServiceName string + func RequestToEntry(req *shimrpc.RegistrarRequest) *Entry + type EnvoyApi struct + func NewEnvoyApi(registrar *Registrar) *EnvoyApi + func (s *EnvoyApi) EnvoyClustersFromRegistrar() []*EnvoyCluster + func (s *EnvoyApi) EnvoyListenerFromEntry(entry *Entry) *EnvoyListener + func (s *EnvoyApi) EnvoyListenersFromRegistrar() []*EnvoyListener + func (s *EnvoyApi) EnvoyServiceFromEntry(entry *Entry) *EnvoyService + func (s *EnvoyApi) HttpMux() http.Handler + type EnvoyCluster struct + ConnectTimeoutMs int64 + LBType string + Name string + ServiceName string + Type string + func (mj *EnvoyCluster) MarshalJSON() ([]byte, error) + func (mj *EnvoyCluster) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *EnvoyCluster) UnmarshalJSON(input []byte) error + func (uj *EnvoyCluster) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type EnvoyFilter struct + Config *EnvoyFilterConfig + Name string + func (mj *EnvoyFilter) MarshalJSON() ([]byte, error) + func (mj *EnvoyFilter) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *EnvoyFilter) UnmarshalJSON(input []byte) error + func (uj *EnvoyFilter) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type EnvoyFilterConfig struct + CodecType string + Filters []*EnvoyFilter + RouteConfig *EnvoyRouteConfig + StatPrefix string + Tracing *EnvoyTracingConfig + func (mj *EnvoyFilterConfig) MarshalJSON() ([]byte, error) + func (mj *EnvoyFilterConfig) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *EnvoyFilterConfig) UnmarshalJSON(input []byte) error + func (uj *EnvoyFilterConfig) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type EnvoyHTTPVirtualHost struct + Domains []string + Name string + Routes []*EnvoyRoute + func (mj *EnvoyHTTPVirtualHost) MarshalJSON() ([]byte, error) + func (mj *EnvoyHTTPVirtualHost) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *EnvoyHTTPVirtualHost) UnmarshalJSON(input []byte) error + func (uj *EnvoyHTTPVirtualHost) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type EnvoyListener struct + Address string + Filters []*EnvoyFilter + Name string + func (mj *EnvoyListener) MarshalJSON() ([]byte, error) + func (mj *EnvoyListener) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *EnvoyListener) UnmarshalJSON(input []byte) error + func (uj *EnvoyListener) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type EnvoyRoute struct + Cluster string + Decorator *EnvoyRouteDecorator + HostRewrite string + Prefix string + TimeoutMs int + func (mj *EnvoyRoute) MarshalJSON() ([]byte, error) + func (mj *EnvoyRoute) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *EnvoyRoute) UnmarshalJSON(input []byte) error + func (uj *EnvoyRoute) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type EnvoyRouteConfig struct + Routes []*EnvoyTCPRoute + VirtualHosts []*EnvoyHTTPVirtualHost + func (mj *EnvoyRouteConfig) MarshalJSON() ([]byte, error) + func (mj *EnvoyRouteConfig) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *EnvoyRouteConfig) UnmarshalJSON(input []byte) error + func (uj *EnvoyRouteConfig) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type EnvoyRouteDecorator struct + Operation string + func (mj *EnvoyRouteDecorator) MarshalJSON() ([]byte, error) + func (mj *EnvoyRouteDecorator) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *EnvoyRouteDecorator) UnmarshalJSON(input []byte) error + func (uj *EnvoyRouteDecorator) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type EnvoyService struct + IPAddress string + LastCheckIn string + Port int64 + Revision string + Service string + ServiceRepoName string + Tags map[string]string + func (mj *EnvoyService) MarshalJSON() ([]byte, error) + func (mj *EnvoyService) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *EnvoyService) UnmarshalJSON(input []byte) error + func (uj *EnvoyService) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type EnvoyTCPRoute struct + Cluster string + DestinationIPList []string + DestinationPorts string + SourceIPList []string + SourcePorts []string + func (mj *EnvoyTCPRoute) MarshalJSON() ([]byte, error) + func (mj *EnvoyTCPRoute) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *EnvoyTCPRoute) UnmarshalJSON(input []byte) error + func (uj *EnvoyTCPRoute) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type EnvoyTracingConfig struct + OperationName string + func (mj *EnvoyTracingConfig) MarshalJSON() ([]byte, error) + func (mj *EnvoyTracingConfig) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *EnvoyTracingConfig) UnmarshalJSON(input []byte) error + func (uj *EnvoyTracingConfig) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type LDSResult struct + Listeners []*EnvoyListener + func (mj *LDSResult) MarshalJSON() ([]byte, error) + func (mj *LDSResult) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *LDSResult) UnmarshalJSON(input []byte) error + func (uj *LDSResult) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error + type Registrar struct + func NewRegistrar() *Registrar + func (r *Registrar) EachEntry(fn func(svcName string, entry *Entry) error) error + func (r *Registrar) GetEntry(svcName string) *Entry + func (r *Registrar) PrintRequests() + func (r *Registrar) Register(ctx context.Context, req *shimrpc.RegistrarRequest) (*shimrpc.RegistrarReply, error) + type SDSResult struct + Env string + Hosts []*EnvoyService + Service string + func (mj *SDSResult) MarshalJSON() ([]byte, error) + func (mj *SDSResult) MarshalJSONBuf(buf fflib.EncodingBuffer) error + func (uj *SDSResult) UnmarshalJSON(input []byte) error + func (uj *SDSResult) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
Go to main page