service

Documentation

Index

• Constants
• func StatusString(status int) string
• type Port
  • func (mj *Port) MarshalJSON() ([]byte, error)
  • func (mj *Port) MarshalJSONBuf(buf fflib.EncodingBuffer) error
  • func (uj *Port) UnmarshalJSON(input []byte) error
  • func (uj *Port) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
• type Service
  • func Decode(data []byte) (*Service, error)
  • func ToService(container *docker.APIContainers, ip string) Service
  • func (svc *Service) Encode() ([]byte, error)
  • func (svc *Service) Format() string
  • func (svc *Service) Invalidates(otherSvc *Service) bool
  • func (svc *Service) IsAlive() bool
  • func (svc *Service) IsDraining() bool
  • func (svc *Service) IsTombstone() bool
  • func (svc *Service) ListenerName() string
  • func (mj *Service) MarshalJSON() ([]byte, error)
  • func (mj *Service) MarshalJSONBuf(buf fflib.EncodingBuffer) error
  • func (svc *Service) PortForServicePort(findPort int64, pType string) int64
  • func (svc *Service) StatusString() string
  • func (svc *Service) Tombstone()
  • func (uj *Service) UnmarshalJSON(input []byte) error
  • func (uj *Service) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
  • func (svc *Service) Version() string

Constants

const (
	ALIVE     = iota
	TOMBSTONE = iota
	UNHEALTHY = iota
	UNKNOWN   = iota
	DRAINING  = iota
)

Functions

func StatusString

func StatusString(status int) string

Types

type Port

type Port struct {
	Type        string
	Port        int64
	ServicePort int64
	IP          string
}

func (*Port) MarshalJSON

func (mj *Port) MarshalJSON() ([]byte, error)

func (*Port) MarshalJSONBuf

func (mj *Port) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Port) UnmarshalJSON

func (uj *Port) UnmarshalJSON(input []byte) error

func (*Port) UnmarshalJSONFFLexer

func (uj *Port) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type Service

type Service struct {
	ID        string
	Name      string
	Image     string
	Created   time.Time
	Hostname  string
	Ports     []Port
	Updated   time.Time
	ProxyMode string
	Status    int
}

func Decode

func Decode(data []byte) (*Service, error)

Decode decodes the input data JSON into a *Service. If it fails, it returns a non-nil error

func ToService

func ToService(container *docker.APIContainers, ip string) Service

Format an APIContainers struct into a more compact struct we can ship over the wire in a broadcast.

func (*Service) Encode

func (svc *Service) Encode() ([]byte, error)

func (*Service) Format

func (svc *Service) Format() string

func (*Service) Invalidates

func (svc *Service) Invalidates(otherSvc *Service) bool

func (*Service) IsAlive

func (svc *Service) IsAlive() bool

func (*Service) IsDraining

func (svc *Service) IsDraining() bool

func (*Service) IsTombstone

func (svc *Service) IsTombstone() bool

func (*Service) ListenerName

func (svc *Service) ListenerName() string

ListenerName returns the string name this service should be identified by as a listener to Sidecar state

func (*Service) MarshalJSON

func (mj *Service) MarshalJSON() ([]byte, error)

func (*Service) MarshalJSONBuf

func (mj *Service) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*Service) PortForServicePort

func (svc *Service) PortForServicePort(findPort int64, pType string) int64

Look up a (usually Docker) mapped Port for a service by ServicePort

func (*Service) StatusString

func (svc *Service) StatusString() string

func (*Service) Tombstone

func (svc *Service) Tombstone()

func (*Service) UnmarshalJSON

func (uj *Service) UnmarshalJSON(input []byte) error

func (*Service) UnmarshalJSONFFLexer

func (uj *Service) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*Service) Version

func (svc *Service) Version() string

Version attempts to extract a version from the image. Otherwise it returns the full image name.