mocks

Documentation

Index

• type ClientConn
  • func NewClientConn() *ClientConn
  • func (t *ClientConn) Addrs() (addrs []resolver.Address)
  • func (t *ClientConn) LastReportedError() error
  • func (t *ClientConn) NewAddress(addrs []resolver.Address)
  • func (*ClientConn) NewServiceConfig(string)
  • func (t *ClientConn) ParseServiceConfig(_ string) *serviceconfig.ParseResult
  • func (t *ClientConn) ReportError(err error)
  • func (t *ClientConn) ReportErrorCallCnt() int
  • func (t *ClientConn) UpdateState(state resolver.State) error
  • func (t *ClientConn) UpdateStateCallCnt() int
• type ConsulHealthClient
  • func NewConsulHealthClient() *ConsulHealthClient
  • func (c *ConsulHealthClient) ResolveCount() int
  • func (c *ConsulHealthClient) ServiceMultipleTags(_ string, _ []string, _ bool, q *consul.QueryOptions) ([]*consul.ServiceEntry, *consul.QueryMeta, error)
  • func (c *ConsulHealthClient) SetRespEntries(entries []*consul.ServiceEntry)
  • func (c *ConsulHealthClient) SetRespError(err error)
  • func (c *ConsulHealthClient) SetRespServiceEntries(s []*consul.AgentService)

Types

type ClientConn

type ClientConn struct {
	// contains filtered or unexported fields
}

func NewClientConn

func NewClientConn() *ClientConn

func (*ClientConn) Addrs

func (t *ClientConn) Addrs() (addrs []resolver.Address)

func (*ClientConn) LastReportedError

func (t *ClientConn) LastReportedError() error

func (*ClientConn) NewAddress

func (t *ClientConn) NewAddress(addrs []resolver.Address)

func (*ClientConn) NewServiceConfig

func (*ClientConn) NewServiceConfig(string)

func (*ClientConn) ParseServiceConfig

func (t *ClientConn) ParseServiceConfig(_ string) *serviceconfig.ParseResult

func (*ClientConn) ReportError

func (t *ClientConn) ReportError(err error)

func (*ClientConn) ReportErrorCallCnt

func (t *ClientConn) ReportErrorCallCnt() int

func (*ClientConn) UpdateState

func (t *ClientConn) UpdateState(state resolver.State) error

func (*ClientConn) UpdateStateCallCnt

func (t *ClientConn) UpdateStateCallCnt() int

type ConsulHealthClient

type ConsulHealthClient struct {
	Mutex   sync.Mutex
	Entries []*consul.ServiceEntry

	ResolveCnt            int
	Err                   error
	ServiceMultipleTagsFn func(*ConsulHealthClient, string, []string, bool, *consul.QueryOptions) ([]*consul.ServiceEntry, *consul.QueryMeta, error)
	// contains filtered or unexported fields
}

func NewConsulHealthClient

func NewConsulHealthClient() *ConsulHealthClient

func (*ConsulHealthClient) ResolveCount

func (c *ConsulHealthClient) ResolveCount() int

func (*ConsulHealthClient) ServiceMultipleTags

func (c *ConsulHealthClient) ServiceMultipleTags(_ string, _ []string, _ bool, q *consul.QueryOptions) ([]*consul.ServiceEntry, *consul.QueryMeta, error)

func (*ConsulHealthClient) SetRespEntries

func (c *ConsulHealthClient) SetRespEntries(entries []*consul.ServiceEntry)

func (*ConsulHealthClient) SetRespError

func (c *ConsulHealthClient) SetRespError(err error)

func (*ConsulHealthClient) SetRespServiceEntries

func (c *ConsulHealthClient) SetRespServiceEntries(s []*consul.AgentService)