pipelineconfig

Documentation

Index

• func NewPipelineConfigID(targetID p4rtapi.TargetID, pipelineName string, pipelineVersion string, ...) p4rtapi.PipelineConfigID
• type Store
  • func NewAtomixStore(client primitive.Client) (Store, error)
• type WatchOption
  • func WithPipelineConfigID(id p4rtapi.PipelineConfigID) WatchOption
  • func WithReplay() WatchOption

Functions

func NewPipelineConfigID

func NewPipelineConfigID(targetID p4rtapi.TargetID, pipelineName string, pipelineVersion string, pipelineArch string) p4rtapi.PipelineConfigID

NewPipelineConfigID creates a new pipeline config ID

Types

type Store

type Store interface {
	// Get gets the pipeline config intended for a given target ID
	Get(ctx context.Context, id p4rtapi.PipelineConfigID) (*p4rtapi.PipelineConfig, error)

	// Create creates a p4 pipeline config
	Create(ctx context.Context, pipelineConfig *p4rtapi.PipelineConfig) error

	// Update updates a p4 pipeline config
	Update(ctx context.Context, pipelineConfig *p4rtapi.PipelineConfig) error

	// List lists all the pipeline config
	List(ctx context.Context) ([]*p4rtapi.PipelineConfig, error)

	// Watch watches pipeline config changes
	Watch(ctx context.Context, ch chan<- *p4rtapi.PipelineConfig, opts ...WatchOption) error

	// UpdateStatus updates a pipeline config  status
	UpdateStatus(ctx context.Context, pipelineConfig *p4rtapi.PipelineConfig) error

	// Remove removes a pipeline config entry
	Remove(ctx context.Context, id p4rtapi.PipelineConfigID) error

	// Close the data store
	Close(ctx context.Context) error
}

Store P4 pipeline config store interface

func NewAtomixStore

func NewAtomixStore(client primitive.Client) (Store, error)

NewAtomixStore creates a new Atomix store for device pipeline config configurations

type WatchOption

type WatchOption interface {
	// contains filtered or unexported methods
}

WatchOption is a pipeline config option for Watch calls

func WithPipelineConfigID

func WithPipelineConfigID(id p4rtapi.PipelineConfigID) WatchOption

WithPipelineConfigID returns a Watch option that watches for configurations based on a given pipeline config ID

func WithReplay

func WithReplay() WatchOption

WithReplay returns a WatchOption that replays past changes