pubsub

package

v0.29.9 Latest Latest Go to latest Published: Oct 22, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

View Source

const (
	StorageBackendPubSub   = "pubsub"
	PubSubProviderInMemory = "inmemory"
	PubSubProviderKafka    = "kafka"
)

This section is empty.

This section is empty.

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

Backend is a storage backend that stores signed payloads in the TaskRun metadata as an annotation. It is stored as base64 encoded JSON.

func NewStorageBackend(ctx context.Context, cfg config.Config) (*Backend, error)

NewStorageBackend returns a new Tekton StorageBackend that stores signatures on a TaskRun

func (b *Backend) NewTopic(ctx context.Context) (*pubsub.Topic, error)

func (b *Backend) RetrievePayloads(ctx context.Context, _ objects.TektonObject, opts config.StorageOpts) (map[string]string, error)

func (b *Backend) RetrieveSignatures(ctx context.Context, _ objects.TektonObject, opts config.StorageOpts) (map[string][]string, error)

func (b *Backend) StorePayload(ctx context.Context, obj objects.TektonObject, rawPayload []byte, signature string, opts config.StorageOpts) error

func (b *Backend) Type() string