syncer

Documentation

Index

• type FleetImageSyncer
  • func NewFleetImageSyncer(client ImageServiceClient) *FleetImageSyncer
  • func (f *FleetImageSyncer) BuildEnvelope(event events.Event) (*events.Envelope, error)
  • func (f *FleetImageSyncer) CheckImageStatus(image string) (bool, error)
  • func (f *FleetImageSyncer) HandleAddedUpdated(fleet *v1.Fleet) error
  • func (f *FleetImageSyncer) PullImage(image string) (string, error)
  • func (f *FleetImageSyncer) SendMessage(envelope *events.Envelope) error
  • func (f *FleetImageSyncer) Unwrap(message interface{}) (*v1.Fleet, error)
• type ImageServiceClient

Types

type FleetImageSyncer

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

FleetImageSyncer implements the Broker interface used by the Agones Event Broadcaster to notify events

func NewFleetImageSyncer

func NewFleetImageSyncer(client ImageServiceClient) *FleetImageSyncer

func (*FleetImageSyncer) BuildEnvelope

func (f *FleetImageSyncer) BuildEnvelope(event events.Event) (*events.Envelope, error)

func (*FleetImageSyncer) CheckImageStatus

func (f *FleetImageSyncer) CheckImageStatus(image string) (bool, error)

func (*FleetImageSyncer) HandleAddedUpdated

func (f *FleetImageSyncer) HandleAddedUpdated(fleet *v1.Fleet) error

func (*FleetImageSyncer) PullImage

func (f *FleetImageSyncer) PullImage(image string) (string, error)

func (*FleetImageSyncer) SendMessage

func (f *FleetImageSyncer) SendMessage(envelope *events.Envelope) error

func (*FleetImageSyncer) Unwrap

func (f *FleetImageSyncer) Unwrap(message interface{}) (*v1.Fleet, error)

type ImageServiceClient

type ImageServiceClient interface {
	ImageStatus(ctx context.Context, request *pb.ImageStatusRequest) (*pb.ImageStatusResponse, error)
	PullImage(ctx context.Context, request *pb.PullImageRequest) (*pb.PullImageResponse, error)
}