artifacts

Documentation

Index

• type ArtifactRegistry
  • func NewArtifactRegistry(ctx context.Context, connCfg *admin2.Config, _ ...grpc.DialOption) *ArtifactRegistry
  • func (a *ArtifactRegistry) GetClient() artifact.ArtifactRegistryClient
  • func (a *ArtifactRegistry) RegisterArtifactConsumer(ctx context.Context, id *core.Identifier, pm core.ParameterMap)
  • func (a *ArtifactRegistry) RegisterArtifactProducer(ctx context.Context, id *core.Identifier, ti core.TypedInterface)
  • func (a *ArtifactRegistry) RegisterTrigger(ctx context.Context, plan *admin.LaunchPlan) error

Types

type ArtifactRegistry

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

ArtifactRegistry contains a client to talk to an Artifact service and has helper methods

func NewArtifactRegistry

func NewArtifactRegistry(ctx context.Context, connCfg *admin2.Config, _ ...grpc.DialOption) *ArtifactRegistry

NewArtifactRegistry todo: update this to return error, and proper cfg handling. if nil, should either call the default config or return an error

func (*ArtifactRegistry) GetClient

func (a *ArtifactRegistry) GetClient() artifact.ArtifactRegistryClient

func (*ArtifactRegistry) RegisterArtifactConsumer

func (a *ArtifactRegistry) RegisterArtifactConsumer(ctx context.Context, id *core.Identifier, pm core.ParameterMap)

func (*ArtifactRegistry) RegisterArtifactProducer

func (a *ArtifactRegistry) RegisterArtifactProducer(ctx context.Context, id *core.Identifier, ti core.TypedInterface)

func (*ArtifactRegistry) RegisterTrigger

func (a *ArtifactRegistry) RegisterTrigger(ctx context.Context, plan *admin.LaunchPlan) error