pkg

type GCRMessage ¶

type GCRMessage struct {
	Action string `json:"action"`
	Digest string `json:"digest"`
	Tag    string `json:"tag"`
}

{
	Action:"INSERT",
	Digest:"gcr.io/alex-dev-ne8701/testing@sha256:0b1e25fb646c62aff375bd5e6eb1b26a81abf2e9f5abb41f98acc88789c75434",
	Tag:"gcr.io/alex-dev-ne8701/testing:873245"
}

type GCRSubscriber ¶

type GCRSubscriber struct {
	EventChan chan GCRMessage
	// contains filtered or unexported fields
}

func NewGCRSubscriber(ctx context.Context, projectID, topicID, subID string) (*GCRSubscriber, error)

func (s *GCRSubscriber) SendNotification(msg GCRMessage, fluxRPC *rpc.RPCClientV11) error

func (s *GCRSubscriber) Subscriber() error