targettest

Documentation

Overview

Package targettest provides a test target subtype for use by the target package. Note that it leverages the tcp.Target's database table to avoid needing schema migrations just for tests.

Index

• Constants
• func Alloc() target.Target
• func New(projectId string, opt ...target.Option) (target.Target, error)
• func TestNewTestTarget(ctx context.Context, t *testing.T, conn *db.DB, projectId, name string, ...) target.Target
• func Vet(ctx context.Context, t target.Target) error
• func VetCredentialSources(_ context.Context, _ []*target.CredentialLibrary, _ []*target.StaticCredential) error
• func VetForUpdate(ctx context.Context, t target.Target, paths []string) error
• type Target
  • func (t *Target) Clone() target.Target
  • func (t *Target) GetCreateTime() *timestamp.Timestamp
  • func (t *Target) GetDefaultPort() uint32
  • func (t *Target) GetDescription() string
  • func (t *Target) GetName() string
  • func (t *Target) GetProjectId() string
  • func (t *Target) GetPublicId() string
  • func (t *Target) GetSessionConnectionLimit() int32
  • func (t *Target) GetSessionMaxSeconds() uint32
  • func (t *Target) GetType() subtypes.Subtype
  • func (t *Target) GetUpdateTime() *timestamp.Timestamp
  • func (t *Target) GetVersion() uint32
  • func (t *Target) GetWorkerFilter() string
  • func (t *Target) Oplog(op oplog.OpType) oplog.Metadata
  • func (t *Target) SetCreateTime(ts *timestamp.Timestamp)
  • func (t *Target) SetDefaultPort(port uint32)
  • func (t *Target) SetDescription(description string)
  • func (t *Target) SetName(name string)
  • func (t *Target) SetProjectId(projectId string)
  • func (t *Target) SetPublicId(_ context.Context, publicId string) error
  • func (t *Target) SetSessionConnectionLimit(l int32)
  • func (t *Target) SetSessionMaxSeconds(s uint32)
  • func (t *Target) SetTableName(n string)
  • func (t *Target) SetUpdateTime(ts *timestamp.Timestamp)
  • func (t *Target) SetVersion(v uint32)
  • func (t *Target) SetWorkerFilter(f string)
  • func (t *Target) TableName() string
  • func (t *Target) VetForWrite(ctx context.Context, _ db.Reader, opType db.OpType, _ ...db.Option) error

Constants

const (
	Subtype      = subtypes.Subtype("tcp")
	TargetPrefix = "ttcp"
)

Functions

func Alloc

func Alloc() target.Target

Alloc creates an in-memory Target.

func New

func New(projectId string, opt ...target.Option) (target.Target, error)

New creates a targettest.Target.

func TestNewTestTarget

func TestNewTestTarget(ctx context.Context, t *testing.T, conn *db.DB, projectId, name string, opt ...target.Option) target.Target

TestNewTestTarget is a test helper for creating a targettest.Target.

func Vet

func Vet(ctx context.Context, t target.Target) error

Vet checks that the given Target is a targettest.Target and that it is not nil.

func VetCredentialSources

func VetCredentialSources(_ context.Context, _ []*target.CredentialLibrary, _ []*target.StaticCredential) error

VetCredentialSources allows for any CredentialLibraries.

func VetForUpdate

func VetForUpdate(ctx context.Context, t target.Target, paths []string) error

vet validates that the given Target is a targettest.Target and that it has a Target store.

Types

type Target

type Target struct {
	*store.Target
	// contains filtered or unexported fields
}

Target is a target.Target used for tests.

func (*Target) Clone

func (t *Target) Clone() target.Target

func (*Target) GetCreateTime

func (t *Target) GetCreateTime() *timestamp.Timestamp

func (*Target) GetDefaultPort

func (t *Target) GetDefaultPort() uint32

func (*Target) GetDescription

func (t *Target) GetDescription() string

func (*Target) GetName

func (t *Target) GetName() string

func (*Target) GetProjectId

func (t *Target) GetProjectId() string

func (*Target) GetPublicId

func (t *Target) GetPublicId() string

func (*Target) GetSessionConnectionLimit

func (t *Target) GetSessionConnectionLimit() int32

func (*Target) GetSessionMaxSeconds

func (t *Target) GetSessionMaxSeconds() uint32

func (*Target) GetType

func (t *Target) GetType() subtypes.Subtype

func (*Target) GetUpdateTime

func (t *Target) GetUpdateTime() *timestamp.Timestamp

func (*Target) GetVersion

func (t *Target) GetVersion() uint32

func (*Target) GetWorkerFilter

func (t *Target) GetWorkerFilter() string

func (*Target) Oplog

func (t *Target) Oplog(op oplog.OpType) oplog.Metadata

func (*Target) SetCreateTime

func (t *Target) SetCreateTime(ts *timestamp.Timestamp)

func (*Target) SetDefaultPort

func (t *Target) SetDefaultPort(port uint32)

func (*Target) SetDescription

func (t *Target) SetDescription(description string)

func (*Target) SetName

func (t *Target) SetName(name string)

func (*Target) SetProjectId

func (t *Target) SetProjectId(projectId string)

func (*Target) SetPublicId

func (t *Target) SetPublicId(_ context.Context, publicId string) error

func (*Target) SetSessionConnectionLimit

func (t *Target) SetSessionConnectionLimit(l int32)

func (*Target) SetSessionMaxSeconds

func (t *Target) SetSessionMaxSeconds(s uint32)

func (*Target) SetTableName

func (t *Target) SetTableName(n string)

SetTableName sets the tablename and satisfies the ReplayableMessage interface. If the caller attempts to set the name to "" the name will be reset to the default name.

func (*Target) SetUpdateTime

func (t *Target) SetUpdateTime(ts *timestamp.Timestamp)

func (*Target) SetVersion

func (t *Target) SetVersion(v uint32)

func (*Target) SetWorkerFilter

func (t *Target) SetWorkerFilter(f string)

func (*Target) TableName

func (t *Target) TableName() string

TableName returns the tablename to override the default gorm table name

func (*Target) VetForWrite

func (t *Target) VetForWrite(ctx context.Context, _ db.Reader, opType db.OpType, _ ...db.Option) error

VetForWrite implements db.VetForWrite() interface and validates the tcp target before it's written.