Versions in this module Expand all Collapse all v1 v1.16.4 Nov 29, 2024 v0 v0.16.4 Nov 29, 2024 Changes in this version + const CatalogDatacentersName + const CatalogListServicesName + const CatalogServiceListName + const CatalogServicesName + const CompiledDiscoveryChainName + const ConfigEntryListName + const ConfigEntryName + const ConnectCARootName + const ExportedPeeredServicesName + const FederationStateListMeshGatewaysName + const GatewayServicesName + const HealthServicesName + const IntentionMatchName + const IntentionUpstreamsDestinationName + const IntentionUpstreamsName + const InternalServiceDumpName + const NodeServicesName + const PeeredUpstreamsName + const PeeringListName + const PreparedQueryName + const ResolvedServiceConfigName + const ServiceGatewaysName + const ServiceHTTPChecksName + const TrustBundleListName + const TrustBundleReadName + func TestFetchCh(t testinf.T, typ cache.Type, opts cache.FetchOptions, req cache.Request) <-chan interface + func TestFetchChResult(t testinf.T, ch <-chan interface{}, expected interface{}) + type Agent interface + LocalBlockingQuery func(alwaysBlock bool, hash string, wait time.Duration, ...) (string, interface{}, error) + LocalState func() *local.State + ServiceHTTPBasedChecks func(id structs.ServiceID) []structs.CheckType + type CatalogDatacenters struct + RPC RPC + func (c *CatalogDatacenters) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type CatalogListServices struct + RPC RPC + func (c *CatalogListServices) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type CatalogServiceList struct + RPC RPC + func (c *CatalogServiceList) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type CatalogServices struct + RPC RPC + func (c *CatalogServices) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type CompiledDiscoveryChain struct + RPC RPC + func (c *CompiledDiscoveryChain) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type ConfigEntry struct + RPC RPC + func (c *ConfigEntry) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type ConfigEntryList struct + RPC RPC + func (c *ConfigEntryList) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type ConnectCARoot struct + RPC RPC + func (c *ConnectCARoot) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type ExportedPeeredServices struct + RPC RPC + func (c *ExportedPeeredServices) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type FederationStateListMeshGateways struct + RPC RPC + func (c *FederationStateListMeshGateways) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type GatewayServices struct + RPC RPC + func (g *GatewayServices) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type HealthServices struct + RPC RPC + func (c *HealthServices) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type IntentionMatch struct + RPC RPC + func (c *IntentionMatch) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type IntentionUpstreams struct + RPC RPC + func (i *IntentionUpstreams) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type IntentionUpstreamsDestination struct + RPC RPC + func (i *IntentionUpstreamsDestination) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type InternalServiceDump struct + RPC RPC + func (c *InternalServiceDump) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type MockRPC struct + func NewMockRPC(t mockConstructorTestingTNewMockRPC) *MockRPC + func TestRPC(t testinf.T) *MockRPC + func (_m *MockRPC) RPC(ctx context.Context, method string, args interface{}, reply interface{}) error + type NodeServices struct + RPC RPC + func (c *NodeServices) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type PeeredUpstreams struct + RPC RPC + func (i *PeeredUpstreams) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type PeeringListRequest struct + Request *pbpeering.PeeringListRequest + func (r *PeeringListRequest) CacheInfo() cache.RequestInfo + type PeeringLister interface + PeeringList func(ctx context.Context, in *pbpeering.PeeringListRequest, opts ...grpc.CallOption) (*pbpeering.PeeringListResponse, error) + type Peerings struct + Client PeeringLister + func (t *Peerings) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type PreparedQuery struct + RPC RPC + func (c *PreparedQuery) Fetch(_ cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type RPC interface + RPC func(ctx context.Context, method string, args interface{}, reply interface{}) error + type RegisterOptionsBlockingNoRefresh struct + func (r RegisterOptionsBlockingNoRefresh) RegisterOptions() cache.RegisterOptions + type RegisterOptionsBlockingRefresh struct + func (r RegisterOptionsBlockingRefresh) RegisterOptions() cache.RegisterOptions + type RegisterOptionsNoRefresh struct + func (r RegisterOptionsNoRefresh) RegisterOptions() cache.RegisterOptions + type ResolvedServiceConfig struct + RPC RPC + func (c *ResolvedServiceConfig) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type ServiceGateways struct + RPC RPC + func (g *ServiceGateways) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type ServiceHTTPChecks struct + Agent Agent + func (c *ServiceHTTPChecks) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type ServiceHTTPChecksRequest struct + MaxQueryTime time.Duration + MinQueryIndex uint64 + NodeName string + ServiceID string + func (s *ServiceHTTPChecksRequest) CacheInfo() cache.RequestInfo + type TrustBundle struct + Client TrustBundleReader + func (t *TrustBundle) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error) + type TrustBundleListRequest struct + Request *pbpeering.TrustBundleListByServiceRequest + func (r *TrustBundleListRequest) CacheInfo() cache.RequestInfo + type TrustBundleLister interface + TrustBundleListByService func(ctx context.Context, in *pbpeering.TrustBundleListByServiceRequest, ...) (*pbpeering.TrustBundleListByServiceResponse, error) + type TrustBundleReadRequest struct + Request *pbpeering.TrustBundleReadRequest + func (r *TrustBundleReadRequest) CacheInfo() cache.RequestInfo + type TrustBundleReader interface + TrustBundleRead func(ctx context.Context, in *pbpeering.TrustBundleReadRequest, ...) (*pbpeering.TrustBundleReadResponse, error) + type TrustBundles struct + Client TrustBundleLister + func (t *TrustBundles) Fetch(opts cache.FetchOptions, req cache.Request) (cache.FetchResult, error)
Go to main page