mock

Documentation

Index

• func ACLManagementToken() *structs.ACLToken
• func ACLPolicy() *structs.ACLPolicy
• func ACLToken() *structs.ACLToken
• func AgentPolicy(policy string) string
• func Alloc() *structs.Allocation
• func BatchAlloc() *structs.Allocation
• func BatchConnectAlloc() *structs.Allocation
• func BatchConnectJob() *structs.Job
• func BatchJob() *structs.Job
• func CSIPlugin() *structs.CSIPlugin
• func CSIVolume(plugin *structs.CSIPlugin) *structs.CSIVolume
• func ConnectAlloc() *structs.Allocation
• func ConnectJob() *structs.Job
• func CreatePolicy(t testing.T, state StateStore, index uint64, name, rule string)
• func CreatePolicyAndToken(t testing.T, state StateStore, index uint64, name, rule string) *structs.ACLToken
• func CreateToken(t testing.T, state StateStore, index uint64, policies []string) *structs.ACLToken
• func Deployment() *structs.Deployment
• func Eval() *structs.Evaluation
• func HCL() string
• func HostVolumePolicy(vol string, policy string, capabilities []string) string
• func Job() *structs.Job
• func JobSummary(jobID string) *structs.JobSummary
• func JobWithScalingPolicy() (*structs.Job, *structs.ScalingPolicy)
• func LifecycleAlloc() *structs.Allocation
• func LifecycleInitTask(resources structs.Resources, i int) *structs.Task
• func LifecycleJob() *structs.Job
• func LifecycleMainTask(resources structs.Resources, i int) *structs.Task
• func LifecycleSideTask(resources structs.Resources, i int) *structs.Task
• func MaxParallelJob() *structs.Job
• func NamespacePolicy(namespace string, policy string, capabilities []string) string
• func Node() *structs.Node
• func NodePolicy(policy string) string
• func NvidiaNode() *structs.Node
• func PeriodicJob() *structs.Job
• func Plan() *structs.Plan
• func PlanResult() *structs.PlanResult
• func PluginPolicy(policy string) string
• func QuotaPolicy(policy string) string
• func SITokenAccessor() *structs.SITokenAccessor
• func ScalingPolicy() *structs.ScalingPolicy
• func SystemAlloc() *structs.Allocation
• func SystemJob() *structs.Job
• func VariableLifecycleJob(resources structs.Resources, main int, init int, side int) *structs.Job
• func VaultAccessor() *structs.VaultAccessor
• type StateStore

Functions

func ACLManagementToken

func ACLManagementToken() *structs.ACLToken

func ACLPolicy

func ACLPolicy() *structs.ACLPolicy

func ACLToken

func ACLToken() *structs.ACLToken

func AgentPolicy

func AgentPolicy(policy string) string

AgentPolicy is a helper for generating the hcl for a given agent policy.

func Alloc

func Alloc() *structs.Allocation

func BatchAlloc

func BatchAlloc() *structs.Allocation

func BatchConnectAlloc

func BatchConnectAlloc() *structs.Allocation

BatchConnectAlloc is useful for testing task runner things.

func BatchConnectJob

func BatchConnectJob() *structs.Job

func BatchJob

func BatchJob() *structs.Job

func CSIPlugin

func CSIPlugin() *structs.CSIPlugin

func CSIVolume

func CSIVolume(plugin *structs.CSIPlugin) *structs.CSIVolume

func ConnectAlloc

func ConnectAlloc() *structs.Allocation

ConnectJob adds a Connect proxy sidecar group service to mock.Alloc.

func ConnectJob

func ConnectJob() *structs.Job

ConnectJob adds a Connect proxy sidecar group service to mock.Job.

Note this does *not* include the Job.Register mutation that inserts the associated Sidecar Task (nor the hook that configures envoy as the default).

func CreatePolicy

func CreatePolicy(t testing.T, state StateStore, index uint64, name, rule string)

CreatePolicy creates a policy with the given name and rule.

func CreatePolicyAndToken

func CreatePolicyAndToken(t testing.T, state StateStore, index uint64, name, rule string) *structs.ACLToken

CreatePolicyAndToken creates a policy and then returns a token configured for just that policy. CreatePolicyAndToken uses the given index and index+1.

func CreateToken

func CreateToken(t testing.T, state StateStore, index uint64, policies []string) *structs.ACLToken

CreateToken creates a local, client token for the given policies

func Deployment

func Deployment() *structs.Deployment

func Eval

func Eval() *structs.Evaluation

func HCL

func HCL() string

func HostVolumePolicy

func HostVolumePolicy(vol string, policy string, capabilities []string) string

HostVolumePolicy is a helper for generating the policy hcl for a given host-volume. Either policy or capabilities may be nil but not both.

func Job

func Job() *structs.Job

func JobSummary

func JobSummary(jobID string) *structs.JobSummary

func JobWithScalingPolicy

func JobWithScalingPolicy() (*structs.Job, *structs.ScalingPolicy)

func LifecycleAlloc

func LifecycleAlloc() *structs.Allocation

func LifecycleInitTask

func LifecycleInitTask(resources structs.Resources, i int) *structs.Task

func LifecycleJob

func LifecycleJob() *structs.Job

func LifecycleMainTask

func LifecycleMainTask(resources structs.Resources, i int) *structs.Task

func LifecycleSideTask

func LifecycleSideTask(resources structs.Resources, i int) *structs.Task

func MaxParallelJob

func MaxParallelJob() *structs.Job

func NamespacePolicy

func NamespacePolicy(namespace string, policy string, capabilities []string) string

NamespacePolicy is a helper for generating the policy hcl for a given namespace. Either policy or capabilities may be nil but not both.

func Node

func Node() *structs.Node

func NodePolicy

func NodePolicy(policy string) string

NodePolicy is a helper for generating the hcl for a given node policy.

func NvidiaNode

func NvidiaNode() *structs.Node

NvidiaNode returns a node with two instances of an Nvidia GPU

func PeriodicJob

func PeriodicJob() *structs.Job

func Plan

func Plan() *structs.Plan

func PlanResult

func PlanResult() *structs.PlanResult

func PluginPolicy

func PluginPolicy(policy string) string

PluginPolicy is a helper for generating the hcl for a given plugin policy.

func QuotaPolicy

func QuotaPolicy(policy string) string

QuotaPolicy is a helper for generating the hcl for a given quota policy.

func SITokenAccessor

func SITokenAccessor() *structs.SITokenAccessor

func ScalingPolicy

func ScalingPolicy() *structs.ScalingPolicy

func SystemAlloc

func SystemAlloc() *structs.Allocation

func SystemJob

func SystemJob() *structs.Job

func VariableLifecycleJob

func VariableLifecycleJob(resources structs.Resources, main int, init int, side int) *structs.Job

func VaultAccessor

func VaultAccessor() *structs.VaultAccessor

Types

type StateStore

type StateStore interface {
	UpsertACLPolicies(index uint64, policies []*structs.ACLPolicy) error
	UpsertACLTokens(index uint64, tokens []*structs.ACLToken) error
}

StateStore defines the methods required from state.StateStore but avoids a circular dependency.