domain

package
v0.11.0 Latest Latest
Warning

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

Go to latest
Published: Feb 15, 2020 License: MIT Imports: 18 Imported by: 0

Documentation

Overview

Package domain is a generated GoMock package.

Index

Constants

View Source
const (
	// MinRetentionDays is the minimal retention days for any domain
	MinRetentionDays = 1

	// MaxBadBinaries is the maximal number of bad client binaries stored in a domain
	MaxBadBinaries = 10
)

Variables

View Source
var (
	// ErrInvalidDomainStatus is the error to indicate invalid domain status
	ErrInvalidDomainStatus = errors.New("invalid domain status attribute")
)

Functions

This section is empty.

Types

type ArchivalEvent

type ArchivalEvent struct {
	URI string
	// contains filtered or unexported fields
}

ArchivalEvent represents a change request to archival config state the only restriction placed on events is that defaultURI is not empty status can be nil, enabled, or disabled (nil indicates no update by user is being attempted)

type ArchivalState

type ArchivalState struct {
	Status shared.ArchivalStatus
	URI    string
}

ArchivalState represents the state of archival config the only invalid state is {URI="", status=enabled} once URI is set it is immutable

type AttrValidatorImpl

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

AttrValidatorImpl is domain attr validator

type Handler

type Handler interface {
	DeprecateDomain(
		ctx context.Context,
		deprecateRequest *shared.DeprecateDomainRequest,
	) error
	DescribeDomain(
		ctx context.Context,
		describeRequest *shared.DescribeDomainRequest,
	) (*shared.DescribeDomainResponse, error)
	ListDomains(
		ctx context.Context,
		listRequest *shared.ListDomainsRequest,
	) (*shared.ListDomainsResponse, error)
	RegisterDomain(
		ctx context.Context,
		registerRequest *shared.RegisterDomainRequest,
	) error
	UpdateDomain(
		ctx context.Context,
		updateRequest *shared.UpdateDomainRequest,
	) (*shared.UpdateDomainResponse, error)
}

Handler is the domain operation handler

type HandlerImpl

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

HandlerImpl is the domain operation handler implementation

func NewHandler

func NewHandler(
	minRetentionDays int,
	maxBadBinaryCount dynamicconfig.IntPropertyFnWithDomainFilter,
	logger log.Logger,
	metadataMgr persistence.MetadataManager,
	clusterMetadata cluster.Metadata,
	domainReplicator Replicator,
	archivalMetadata archiver.ArchivalMetadata,
	archiverProvider provider.ArchiverProvider,
) *HandlerImpl

NewHandler create a new domain handler

func (*HandlerImpl) DeprecateDomain

func (d *HandlerImpl) DeprecateDomain(
	ctx context.Context,
	deprecateRequest *shared.DeprecateDomainRequest,
) error

DeprecateDomain deprecates a domain

func (*HandlerImpl) DescribeDomain

func (d *HandlerImpl) DescribeDomain(
	ctx context.Context,
	describeRequest *shared.DescribeDomainRequest,
) (*shared.DescribeDomainResponse, error)

DescribeDomain describe the domain

func (*HandlerImpl) ListDomains

func (d *HandlerImpl) ListDomains(
	ctx context.Context,
	listRequest *shared.ListDomainsRequest,
) (*shared.ListDomainsResponse, error)

ListDomains list all domains

func (*HandlerImpl) RegisterDomain

func (d *HandlerImpl) RegisterDomain(
	ctx context.Context,
	registerRequest *shared.RegisterDomainRequest,
) error

RegisterDomain register a new domain

func (*HandlerImpl) UpdateDomain

func (d *HandlerImpl) UpdateDomain(
	ctx context.Context,
	updateRequest *shared.UpdateDomainRequest,
) (*shared.UpdateDomainResponse, error)

UpdateDomain update the domain

type MockHandler added in v0.11.0

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

MockHandler is a mock of Handler interface

func NewMockHandler added in v0.11.0

func NewMockHandler(ctrl *gomock.Controller) *MockHandler

NewMockHandler creates a new mock instance

func (*MockHandler) DeprecateDomain added in v0.11.0

func (m *MockHandler) DeprecateDomain(ctx context.Context, deprecateRequest *shared.DeprecateDomainRequest) error

DeprecateDomain mocks base method

func (*MockHandler) DescribeDomain added in v0.11.0

func (m *MockHandler) DescribeDomain(ctx context.Context, describeRequest *shared.DescribeDomainRequest) (*shared.DescribeDomainResponse, error)

DescribeDomain mocks base method

func (*MockHandler) EXPECT added in v0.11.0

func (m *MockHandler) EXPECT() *MockHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockHandler) ListDomains added in v0.11.0

func (m *MockHandler) ListDomains(ctx context.Context, listRequest *shared.ListDomainsRequest) (*shared.ListDomainsResponse, error)

ListDomains mocks base method

func (*MockHandler) RegisterDomain added in v0.11.0

func (m *MockHandler) RegisterDomain(ctx context.Context, registerRequest *shared.RegisterDomainRequest) error

RegisterDomain mocks base method

func (*MockHandler) UpdateDomain added in v0.11.0

func (m *MockHandler) UpdateDomain(ctx context.Context, updateRequest *shared.UpdateDomainRequest) (*shared.UpdateDomainResponse, error)

UpdateDomain mocks base method

type MockHandlerMockRecorder added in v0.11.0

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

MockHandlerMockRecorder is the mock recorder for MockHandler

func (*MockHandlerMockRecorder) DeprecateDomain added in v0.11.0

func (mr *MockHandlerMockRecorder) DeprecateDomain(ctx, deprecateRequest interface{}) *gomock.Call

DeprecateDomain indicates an expected call of DeprecateDomain

func (*MockHandlerMockRecorder) DescribeDomain added in v0.11.0

func (mr *MockHandlerMockRecorder) DescribeDomain(ctx, describeRequest interface{}) *gomock.Call

DescribeDomain indicates an expected call of DescribeDomain

func (*MockHandlerMockRecorder) ListDomains added in v0.11.0

func (mr *MockHandlerMockRecorder) ListDomains(ctx, listRequest interface{}) *gomock.Call

ListDomains indicates an expected call of ListDomains

func (*MockHandlerMockRecorder) RegisterDomain added in v0.11.0

func (mr *MockHandlerMockRecorder) RegisterDomain(ctx, registerRequest interface{}) *gomock.Call

RegisterDomain indicates an expected call of RegisterDomain

func (*MockHandlerMockRecorder) UpdateDomain added in v0.11.0

func (mr *MockHandlerMockRecorder) UpdateDomain(ctx, updateRequest interface{}) *gomock.Call

UpdateDomain indicates an expected call of UpdateDomain

type Replicator

type Replicator interface {
	HandleTransmissionTask(domainOperation replicator.DomainOperation, info *persistence.DomainInfo,
		config *persistence.DomainConfig, replicationConfig *persistence.DomainReplicationConfig,
		configVersion int64, failoverVersion int64, isGlobalDomainEnabled bool) error
}

Replicator is the interface which can replicate the domain

func NewDomainReplicator

func NewDomainReplicator(replicationMessageSink messaging.Producer, logger log.Logger) Replicator

NewDomainReplicator create a new instance of domain replicator

Jump to

Keyboard shortcuts

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