marathon

Documentation

Index

• type Adapter
  • func New(marathonURL string) (*Adapter, error)
  • func (m *Adapter) ListenForEvents(channel types.EventsChannel) error
  • func (m *Adapter) Services() ([]*types.ServiceGroup, error)
• type AddressResolver
• type Client
• type MockAddressResolver
  • func NewMockAddressResolver(ctrl *gomock.Controller) *MockAddressResolver
  • func (_m *MockAddressResolver) EXPECT() *_MockAddressResolverRecorder
  • func (_m *MockAddressResolver) Resolve(hostname string) (string, error)
• type MockClient
  • func NewMockClient(ctrl *gomock.Controller) *MockClient
  • func (_m *MockClient) AddEventsListener(channel go_marathon.EventsChannel, filter int) error
  • func (_m *MockClient) Applications(_param0 url.Values) (*go_marathon.Applications, error)
  • func (_m *MockClient) EXPECT() *_MockClientRecorder
  • func (_m *MockClient) RemoveEventsListener(channel go_marathon.EventsChannel)

Types

type Adapter

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

Adapter is the implementation of RegistryAdapter for Marathon.

func New

func New(marathonURL string) (*Adapter, error)

New creates a new Adapter.

func (*Adapter) ListenForEvents

func (m *Adapter) ListenForEvents(channel types.EventsChannel) error

ListenForEvents subscribes to Marathon events and publishes them to channel.

func (*Adapter) Services

func (m *Adapter) Services() ([]*types.ServiceGroup, error)

Services returns the list of registered services.

type AddressResolver

type AddressResolver interface {
	Resolve(hostname string) (string, error)
}

AddressResolver is the interface for address resolver implementations.

type Client

type Client interface {
	Applications(url.Values) (*marathonClient.Applications, error)
	AddEventsListener(channel marathonClient.EventsChannel, filter int) error
	RemoveEventsListener(channel marathonClient.EventsChannel)
}

Client is the excerpt interface from Marathon API client to generate mocks.

type MockAddressResolver

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

Mock of AddressResolver interface

func NewMockAddressResolver

func NewMockAddressResolver(ctrl *gomock.Controller) *MockAddressResolver

func (*MockAddressResolver) EXPECT

func (_m *MockAddressResolver) EXPECT() *_MockAddressResolverRecorder

func (*MockAddressResolver) Resolve

func (_m *MockAddressResolver) Resolve(hostname string) (string, error)

type MockClient

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

Mock of Client interface

func NewMockClient

func NewMockClient(ctrl *gomock.Controller) *MockClient

func (*MockClient) AddEventsListener

func (_m *MockClient) AddEventsListener(channel go_marathon.EventsChannel, filter int) error

func (*MockClient) Applications

func (_m *MockClient) Applications(_param0 url.Values) (*go_marathon.Applications, error)

func (*MockClient) EXPECT

func (_m *MockClient) EXPECT() *_MockClientRecorder

func (*MockClient) RemoveEventsListener

func (_m *MockClient) RemoveEventsListener(channel go_marathon.EventsChannel)