Documentation
¶
Overview ¶
Package domain is a generated GoMock package.
Index ¶
- Constants
- Variables
- type ArchivalEvent
- type ArchivalState
- type AttrValidatorImpl
- type Handler
- type HandlerImpl
- func (d *HandlerImpl) DeprecateDomain(ctx context.Context, deprecateRequest *shared.DeprecateDomainRequest) error
- func (d *HandlerImpl) DescribeDomain(ctx context.Context, describeRequest *shared.DescribeDomainRequest) (*shared.DescribeDomainResponse, error)
- func (d *HandlerImpl) ListDomains(ctx context.Context, listRequest *shared.ListDomainsRequest) (*shared.ListDomainsResponse, error)
- func (d *HandlerImpl) RegisterDomain(ctx context.Context, registerRequest *shared.RegisterDomainRequest) error
- func (d *HandlerImpl) UpdateDomain(ctx context.Context, updateRequest *shared.UpdateDomainRequest) (*shared.UpdateDomainResponse, error)
- type MockHandler
- func (m *MockHandler) DeprecateDomain(ctx context.Context, deprecateRequest *shared.DeprecateDomainRequest) error
- func (m *MockHandler) DescribeDomain(ctx context.Context, describeRequest *shared.DescribeDomainRequest) (*shared.DescribeDomainResponse, error)
- func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
- func (m *MockHandler) ListDomains(ctx context.Context, listRequest *shared.ListDomainsRequest) (*shared.ListDomainsResponse, error)
- func (m *MockHandler) RegisterDomain(ctx context.Context, registerRequest *shared.RegisterDomainRequest) error
- func (m *MockHandler) UpdateDomain(ctx context.Context, updateRequest *shared.UpdateDomainRequest) (*shared.UpdateDomainResponse, error)
- type MockHandlerMockRecorder
- func (mr *MockHandlerMockRecorder) DeprecateDomain(ctx, deprecateRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) DescribeDomain(ctx, describeRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) ListDomains(ctx, listRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) RegisterDomain(ctx, registerRequest interface{}) *gomock.Call
- func (mr *MockHandlerMockRecorder) UpdateDomain(ctx, updateRequest interface{}) *gomock.Call
- type Replicator
Constants ¶
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 ¶
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