cluster

Documentation

Index

• func GenerateNodeId() string
• func GetShards(clusterState state.ClusterState, index string, id string) state.IndexShardRoutingTable
• func IndexShard(clusterState state.ClusterState, index string, id string) state.IndexShardRoutingTable
• type AliasAction
• type AllocationService
  • func NewAllocationService() *AllocationService
• type ApplierService
  • func (s *ApplierService) AddApplier(applier func(event state.ClusterChangedEvent))
  • func (s *ApplierService) OnNewState(clusterState *state.ClusterState)
• type CreateIndexClusterStateUpdateRequest
• type DeleteIndexClusterStateUpdateRequest
• type IndicesAliasesClusterStateUpdateRequest
• type MasterService
• type MetadataCreateIndexService
  • func NewMetadataCreateIndexService(clusterService state.ClusterService, allocationService *AllocationService) *MetadataCreateIndexService
  • func (s *MetadataCreateIndexService) CreateIndex(req CreateIndexClusterStateUpdateRequest)
• type MetadataDeleteIndexService
  • func NewMetadataDeleteIndexService(clusterService state.ClusterService, allocationService *AllocationService) *MetadataDeleteIndexService
  • func (s *MetadataDeleteIndexService) DeleteIndex(req DeleteIndexClusterStateUpdateRequest)
• type MetadataIndexAliasService
  • func NewMetadataIndexAliasService(clusterService state.ClusterService) *MetadataIndexAliasService
  • func (s *MetadataIndexAliasService) IndicesAliases(req IndicesAliasesClusterStateUpdateRequest)
• type Service
  • func NewService() *Service
  • func (s *Service) State() *state.ClusterState
  • func (s *Service) SubmitStateUpdateTask(task state.ClusterStateUpdateTask)
• type Settings

Functions

func GenerateNodeId

func GenerateNodeId() string

func GetShards

func GetShards(clusterState state.ClusterState, index string, id string) state.IndexShardRoutingTable

func IndexShard

func IndexShard(clusterState state.ClusterState, index string, id string) state.IndexShardRoutingTable

Types

type AliasAction

type AliasAction struct {
	Type  string
	Index string
	Alias string
}

type AllocationService

type AllocationService struct {
}

func NewAllocationService

func NewAllocationService() *AllocationService

type ApplierService

type ApplierService struct {
	ClusterState         *state.ClusterState
	ClusterStateAppliers []func(event state.ClusterChangedEvent)
}

func (*ApplierService) AddApplier

func (s *ApplierService) AddApplier(applier func(event state.ClusterChangedEvent))

func (*ApplierService) OnNewState

func (s *ApplierService) OnNewState(clusterState *state.ClusterState)

type CreateIndexClusterStateUpdateRequest

type CreateIndexClusterStateUpdateRequest struct {
	Index    string
	Mappings []byte
	Settings map[string]interface{}
}

type DeleteIndexClusterStateUpdateRequest

type DeleteIndexClusterStateUpdateRequest struct {
	Indices []state.Index
}

type IndicesAliasesClusterStateUpdateRequest

type IndicesAliasesClusterStateUpdateRequest struct {
	Actions []AliasAction
}

type MasterService

type MasterService struct {
	ClusterState        *state.ClusterState
	ClusterStatePublish func(event state.ClusterChangedEvent)
}

type MetadataCreateIndexService

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

func NewMetadataCreateIndexService

func NewMetadataCreateIndexService(clusterService state.ClusterService, allocationService *AllocationService) *MetadataCreateIndexService

func (*MetadataCreateIndexService) CreateIndex

func (s *MetadataCreateIndexService) CreateIndex(req CreateIndexClusterStateUpdateRequest)

type MetadataDeleteIndexService

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

func NewMetadataDeleteIndexService

func NewMetadataDeleteIndexService(clusterService state.ClusterService, allocationService *AllocationService) *MetadataDeleteIndexService

func (*MetadataDeleteIndexService) DeleteIndex

func (s *MetadataDeleteIndexService) DeleteIndex(req DeleteIndexClusterStateUpdateRequest)

type MetadataIndexAliasService

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

func NewMetadataIndexAliasService

func NewMetadataIndexAliasService(clusterService state.ClusterService) *MetadataIndexAliasService

func (*MetadataIndexAliasService) IndicesAliases

func (s *MetadataIndexAliasService) IndicesAliases(req IndicesAliasesClusterStateUpdateRequest)

type Service

type Service struct {
	//Settings       Settings
	ApplierService *ApplierService
	MasterService  *MasterService
}

func NewService

func NewService() *Service

func (*Service) State

func (s *Service) State() *state.ClusterState

func (*Service) SubmitStateUpdateTask

func (s *Service) SubmitStateUpdateTask(task state.ClusterStateUpdateTask)

type Settings

type Settings struct {
}