tcp

package
v0.13.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 9, 2023 License: MPL-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package tcp provides a Target subtype for a TCP Target. Importing this package will register it with the target package and allow the target.Repository to support tcp.Targets.

Index

Constants

View Source
const (
	Subtype = subtypes.Subtype("tcp")
)
View Source
const (
	// TargetPrefix is the prefix for public ids of a tcp.Target.
	TargetPrefix = "ttcp"
)

Variables

This section is empty.

Functions

func TestTarget

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

TestTarget is used to create a Target that can be used by tests in other packages.

Types

type Target

type Target struct {
	*store.Target
	// Network address assigned to the Target.
	Address string `json:"address,omitempty" gorm:"-"`

	HostSource        []target.HostSource       `gorm:"-"`
	CredentialSources []target.CredentialSource `gorm:"-"`
	// contains filtered or unexported fields
}

Target is a resources that represets a networked service that can be accessed via TCP. It is a subtype of target.Target.

func (*Target) Clone

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

Clone creates a clone of the Target

func (*Target) GetAddress added in v0.12.0

func (t *Target) GetAddress() string

func (*Target) GetCredentialSources added in v0.13.0

func (t *Target) GetCredentialSources() []target.CredentialSource

func (*Target) GetEnableSessionRecording added in v0.13.0

func (t *Target) GetEnableSessionRecording() bool

func (*Target) GetHostSources added in v0.13.0

func (t *Target) GetHostSources() []target.HostSource

func (*Target) GetStorageBucketId added in v0.13.0

func (t *Target) GetStorageBucketId() string

func (*Target) GetType

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

func (*Target) Oplog

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

Oplog provides the oplog.Metadata for recording operations taken on a Target.

func (*Target) SetAddress added in v0.12.0

func (t *Target) SetAddress(address string)

func (*Target) SetCreateTime

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

func (*Target) SetCredentialSources added in v0.13.0

func (t *Target) SetCredentialSources(sources []target.CredentialSource)

func (*Target) SetDefaultClientPort added in v0.13.0

func (t *Target) SetDefaultClientPort(port uint32)

func (*Target) SetDefaultPort

func (t *Target) SetDefaultPort(port uint32)

func (*Target) SetDescription

func (t *Target) SetDescription(description string)

func (*Target) SetEgressWorkerFilter added in v0.12.0

func (t *Target) SetEgressWorkerFilter(filter string)

func (*Target) SetEnableSessionRecording added in v0.13.0

func (t *Target) SetEnableSessionRecording(_ bool)

func (*Target) SetHostSources added in v0.13.0

func (t *Target) SetHostSources(sources []target.HostSource)

func (*Target) SetIngressWorkerFilter added in v0.12.0

func (t *Target) SetIngressWorkerFilter(filter string)

func (*Target) SetName

func (t *Target) SetName(name string)

func (*Target) SetProjectId added in v0.10.2

func (t *Target) SetProjectId(projectId string)

func (*Target) SetPublicId

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

func (*Target) SetSessionConnectionLimit

func (t *Target) SetSessionConnectionLimit(limit int32)

func (*Target) SetSessionMaxSeconds

func (t *Target) SetSessionMaxSeconds(s uint32)

func (*Target) SetStorageBucketId added in v0.13.0

func (t *Target) SetStorageBucketId(_ string)

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(filter 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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL