Documentation ¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*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
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) }
Click to show internal directories.
Click to hide internal directories.