introspector

Documentation

Overview

introspector provides grpc/rest introspection API endpoint on shared tcp port.

Index

• type PublisherServerMock
  • func NewPublisherServerMock(t minimock.Tester) *PublisherServerMock
  • func (mmGetMessagesFilters *PublisherServerMock) GetMessagesFilters(ctx context.Context, ep1 *mm_introproto.EmptyArgs) (ap1 *mm_introproto.AllMessageFilterStats, err error)
  • func (mmGetMessagesFilters *PublisherServerMock) GetMessagesFiltersAfterCounter() uint64
  • func (mmGetMessagesFilters *PublisherServerMock) GetMessagesFiltersBeforeCounter() uint64
  • func (mmGetMessagesStat *PublisherServerMock) GetMessagesStat(ctx context.Context, ep1 *mm_introproto.EmptyArgs) (ap1 *mm_introproto.AllMessageStatByType, err error)
  • func (mmGetMessagesStat *PublisherServerMock) GetMessagesStatAfterCounter() uint64
  • func (mmGetMessagesStat *PublisherServerMock) GetMessagesStatBeforeCounter() uint64
  • func (m *PublisherServerMock) MinimockFinish()
  • func (m *PublisherServerMock) MinimockGetMessagesFiltersDone() bool
  • func (m *PublisherServerMock) MinimockGetMessagesFiltersInspect()
  • func (m *PublisherServerMock) MinimockGetMessagesStatDone() bool
  • func (m *PublisherServerMock) MinimockGetMessagesStatInspect()
  • func (m *PublisherServerMock) MinimockSetMessagesFilterDone() bool
  • func (m *PublisherServerMock) MinimockSetMessagesFilterInspect()
  • func (m *PublisherServerMock) MinimockWait(timeout mm_time.Duration)
  • func (mmSetMessagesFilter *PublisherServerMock) SetMessagesFilter(ctx context.Context, mp1 *mm_introproto.MessageFilterByType) (mp2 *mm_introproto.MessageFilterByType, err error)
  • func (mmSetMessagesFilter *PublisherServerMock) SetMessagesFilterAfterCounter() uint64
  • func (mmSetMessagesFilter *PublisherServerMock) SetMessagesFilterBeforeCounter() uint64
• type PublisherServerMockGetMessagesFiltersExpectation
  • func (e *PublisherServerMockGetMessagesFiltersExpectation) Then(ap1 *mm_introproto.AllMessageFilterStats, err error) *PublisherServerMock
• type PublisherServerMockGetMessagesFiltersParams
• type PublisherServerMockGetMessagesFiltersResults
• type PublisherServerMockGetMessagesStatExpectation
  • func (e *PublisherServerMockGetMessagesStatExpectation) Then(ap1 *mm_introproto.AllMessageStatByType, err error) *PublisherServerMock
• type PublisherServerMockGetMessagesStatParams
• type PublisherServerMockGetMessagesStatResults
• type PublisherServerMockSetMessagesFilterExpectation
  • func (e *PublisherServerMockSetMessagesFilterExpectation) Then(mp2 *mm_introproto.MessageFilterByType, err error) *PublisherServerMock
• type PublisherServerMockSetMessagesFilterParams
• type PublisherServerMockSetMessagesFilterResults
• type Server
  • func NewServer(addr string, ps introproto.PublisherServer) *Server
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Stop(ctx context.Context) error

Types

type PublisherServerMock

type PublisherServerMock struct {
	GetMessagesFiltersMock mPublisherServerMockGetMessagesFilters

	GetMessagesStatMock mPublisherServerMockGetMessagesStat

	SetMessagesFilterMock mPublisherServerMockSetMessagesFilter
	// contains filtered or unexported fields
}

PublisherServerMock implements introproto.PublisherServer

func NewPublisherServerMock

func NewPublisherServerMock(t minimock.Tester) *PublisherServerMock

NewPublisherServerMock returns a mock for introproto.PublisherServer

func (*PublisherServerMock) GetMessagesFilters

func (mmGetMessagesFilters *PublisherServerMock) GetMessagesFilters(ctx context.Context, ep1 *mm_introproto.EmptyArgs) (ap1 *mm_introproto.AllMessageFilterStats, err error)

GetMessagesFilters implements introproto.PublisherServer

func (*PublisherServerMock) GetMessagesFiltersAfterCounter

func (mmGetMessagesFilters *PublisherServerMock) GetMessagesFiltersAfterCounter() uint64

GetMessagesFiltersAfterCounter returns a count of finished PublisherServerMock.GetMessagesFilters invocations

func (*PublisherServerMock) GetMessagesFiltersBeforeCounter

func (mmGetMessagesFilters *PublisherServerMock) GetMessagesFiltersBeforeCounter() uint64

GetMessagesFiltersBeforeCounter returns a count of PublisherServerMock.GetMessagesFilters invocations

func (*PublisherServerMock) GetMessagesStat

func (mmGetMessagesStat *PublisherServerMock) GetMessagesStat(ctx context.Context, ep1 *mm_introproto.EmptyArgs) (ap1 *mm_introproto.AllMessageStatByType, err error)

GetMessagesStat implements introproto.PublisherServer

func (*PublisherServerMock) GetMessagesStatAfterCounter

func (mmGetMessagesStat *PublisherServerMock) GetMessagesStatAfterCounter() uint64

GetMessagesStatAfterCounter returns a count of finished PublisherServerMock.GetMessagesStat invocations

func (*PublisherServerMock) GetMessagesStatBeforeCounter

func (mmGetMessagesStat *PublisherServerMock) GetMessagesStatBeforeCounter() uint64

GetMessagesStatBeforeCounter returns a count of PublisherServerMock.GetMessagesStat invocations

func (*PublisherServerMock) MinimockFinish

func (m *PublisherServerMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*PublisherServerMock) MinimockGetMessagesFiltersDone

func (m *PublisherServerMock) MinimockGetMessagesFiltersDone() bool

MinimockGetMessagesFiltersDone returns true if the count of the GetMessagesFilters invocations corresponds the number of defined expectations

func (*PublisherServerMock) MinimockGetMessagesFiltersInspect

func (m *PublisherServerMock) MinimockGetMessagesFiltersInspect()

MinimockGetMessagesFiltersInspect logs each unmet expectation

func (*PublisherServerMock) MinimockGetMessagesStatDone

func (m *PublisherServerMock) MinimockGetMessagesStatDone() bool

MinimockGetMessagesStatDone returns true if the count of the GetMessagesStat invocations corresponds the number of defined expectations

func (*PublisherServerMock) MinimockGetMessagesStatInspect

func (m *PublisherServerMock) MinimockGetMessagesStatInspect()

MinimockGetMessagesStatInspect logs each unmet expectation

func (*PublisherServerMock) MinimockSetMessagesFilterDone

func (m *PublisherServerMock) MinimockSetMessagesFilterDone() bool

MinimockSetMessagesFilterDone returns true if the count of the SetMessagesFilter invocations corresponds the number of defined expectations

func (*PublisherServerMock) MinimockSetMessagesFilterInspect

func (m *PublisherServerMock) MinimockSetMessagesFilterInspect()

MinimockSetMessagesFilterInspect logs each unmet expectation

func (*PublisherServerMock) MinimockWait

func (m *PublisherServerMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*PublisherServerMock) SetMessagesFilter

func (mmSetMessagesFilter *PublisherServerMock) SetMessagesFilter(ctx context.Context, mp1 *mm_introproto.MessageFilterByType) (mp2 *mm_introproto.MessageFilterByType, err error)

SetMessagesFilter implements introproto.PublisherServer

func (*PublisherServerMock) SetMessagesFilterAfterCounter

func (mmSetMessagesFilter *PublisherServerMock) SetMessagesFilterAfterCounter() uint64

SetMessagesFilterAfterCounter returns a count of finished PublisherServerMock.SetMessagesFilter invocations

func (*PublisherServerMock) SetMessagesFilterBeforeCounter

func (mmSetMessagesFilter *PublisherServerMock) SetMessagesFilterBeforeCounter() uint64

SetMessagesFilterBeforeCounter returns a count of PublisherServerMock.SetMessagesFilter invocations

type PublisherServerMockGetMessagesFiltersExpectation

type PublisherServerMockGetMessagesFiltersExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

PublisherServerMockGetMessagesFiltersExpectation specifies expectation struct of the PublisherServer.GetMessagesFilters

func (*PublisherServerMockGetMessagesFiltersExpectation) Then

func (e *PublisherServerMockGetMessagesFiltersExpectation) Then(ap1 *mm_introproto.AllMessageFilterStats, err error) *PublisherServerMock

Then sets up PublisherServer.GetMessagesFilters return parameters for the expectation previously defined by the When method

type PublisherServerMockGetMessagesFiltersParams

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

PublisherServerMockGetMessagesFiltersParams contains parameters of the PublisherServer.GetMessagesFilters

type PublisherServerMockGetMessagesFiltersResults

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

PublisherServerMockGetMessagesFiltersResults contains results of the PublisherServer.GetMessagesFilters

type PublisherServerMockGetMessagesStatExpectation

type PublisherServerMockGetMessagesStatExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

PublisherServerMockGetMessagesStatExpectation specifies expectation struct of the PublisherServer.GetMessagesStat

func (*PublisherServerMockGetMessagesStatExpectation) Then

func (e *PublisherServerMockGetMessagesStatExpectation) Then(ap1 *mm_introproto.AllMessageStatByType, err error) *PublisherServerMock

Then sets up PublisherServer.GetMessagesStat return parameters for the expectation previously defined by the When method

type PublisherServerMockGetMessagesStatParams

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

PublisherServerMockGetMessagesStatParams contains parameters of the PublisherServer.GetMessagesStat

type PublisherServerMockGetMessagesStatResults

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

PublisherServerMockGetMessagesStatResults contains results of the PublisherServer.GetMessagesStat

type PublisherServerMockSetMessagesFilterExpectation

type PublisherServerMockSetMessagesFilterExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

PublisherServerMockSetMessagesFilterExpectation specifies expectation struct of the PublisherServer.SetMessagesFilter

func (*PublisherServerMockSetMessagesFilterExpectation) Then

func (e *PublisherServerMockSetMessagesFilterExpectation) Then(mp2 *mm_introproto.MessageFilterByType, err error) *PublisherServerMock

Then sets up PublisherServer.SetMessagesFilter return parameters for the expectation previously defined by the When method

type PublisherServerMockSetMessagesFilterParams

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

PublisherServerMockSetMessagesFilterParams contains parameters of the PublisherServer.SetMessagesFilter

type PublisherServerMockSetMessagesFilterResults

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

PublisherServerMockSetMessagesFilterResults contains results of the PublisherServer.SetMessagesFilter

type Server

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

Server implements introspection API server.

func NewServer

func NewServer(addr string, ps introproto.PublisherServer) *Server

NewServer creates configured introspection API server.

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

Start starts introspection http/grpc endpoint.

func (*Server) Stop

func (s *Server) Stop(ctx context.Context) error

Stop stops introspection http/grpc endpoint.