clients

Documentation

Index

• type NamespaceCompare
• type NamespaceService
  • func NewNamespaceService(configData []byte) (NamespaceService, error)
• type SearchAttributeCompare
• type SearchAttributeService
  • func NewSearchAttributeService(configData []byte) (SearchAttributeService, error)
• type TemporalServiceConfig
• type TemporalServiceImpl
  • func NewTemporalService(configData []byte) (*TemporalServiceImpl, error)
  • func (s *TemporalServiceImpl) CreateNamespace(ctx context.Context, namespace *core.TemporalNamespaceParameters) error
  • func (s *TemporalServiceImpl) CreateSearchAttribute(ctx context.Context, searchAttribute *core.SearchAttributeParameters) error
  • func (s *TemporalServiceImpl) DeleteAllNamespaces(ctx context.Context) ([]*string, error)
  • func (s *TemporalServiceImpl) DeleteNamespaceByName(ctx context.Context, name string) (*string, error)
  • func (s *TemporalServiceImpl) DeleteSearchAttributeByName(ctx context.Context, namespace string, name string) error
  • func (s *TemporalServiceImpl) DescribeNamespaceByName(ctx context.Context, name string) (*core.TemporalNamespaceObservation, error)
  • func (s *TemporalServiceImpl) DescribeSearchAttributeByName(ctx context.Context, namespace string, name string) (*core.SearchAttributeObservation, error)
  • func (s *TemporalServiceImpl) ListAllNamespaces(ctx context.Context) ([]*core.TemporalNamespaceObservation, error)
  • func (s *TemporalServiceImpl) ListSearchAttributesByNamespace(ctx context.Context, namespace string) ([]*core.SearchAttributeObservation, error)
  • func (s *TemporalServiceImpl) MapToNamespaceCompare(namespace interface{}) (*NamespaceCompare, error)
  • func (s *TemporalServiceImpl) MapToSearchAttributeCompare(searchAttribute interface{}) (*SearchAttributeCompare, error)
  • func (s *TemporalServiceImpl) UpdateNamespaceByName(ctx context.Context, namespace *core.TemporalNamespaceParameters) error

Types

type NamespaceCompare

type NamespaceCompare struct {
	Name                           string             `json:"name"`
	Description                    *string            `json:"description,omitempty"`
	OwnerEmail                     *string            `json:"ownerEmail,omitempty"`
	WorkflowExecutionRetentionDays int                `json:"workflowExecutionRetentionDays,omitempty"`
	Data                           *map[string]string `json:"data,omitempty"`
	HistoryArchivalState           string             `json:"historyArchivalState,omitempty"`
	HistoryArchivalUri             *string            `json:"historyArchivalUri,omitempty"`
	VisibilityArchivalState        string             `json:"visibilityArchivalState,omitempty"`
	VisibilityArchivalUri          *string            `json:"visibilityArchivalUri,omitempty"`
}

type NamespaceService

type NamespaceService interface {
	DescribeNamespaceByName(ctx context.Context, name string) (*core.TemporalNamespaceObservation, error)

	CreateNamespace(ctx context.Context, namespace *core.TemporalNamespaceParameters) error
	UpdateNamespaceByName(ctx context.Context, namespace *core.TemporalNamespaceParameters) error
	DeleteNamespaceByName(ctx context.Context, name string) (*string, error)

	MapToNamespaceCompare(namespace interface{}) (*NamespaceCompare, error)
}

func NewNamespaceService

func NewNamespaceService(configData []byte) (NamespaceService, error)

type SearchAttributeCompare

type SearchAttributeCompare struct {
	Name                  string  `json:"name"`
	Type                  string  `json:"type"`
	TemporalNamespaceName *string `json:"temporalNamespaceName,omitempty"`
}

type SearchAttributeService

type SearchAttributeService interface {
	DescribeSearchAttributeByName(ctx context.Context, namespace string, name string) (*core.SearchAttributeObservation, error)

	CreateSearchAttribute(ctx context.Context, searchAttribute *core.SearchAttributeParameters) error
	DeleteSearchAttributeByName(ctx context.Context, namespace string, name string) error

	MapToSearchAttributeCompare(searchAttribute interface{}) (*SearchAttributeCompare, error)
}

func NewSearchAttributeService

func NewSearchAttributeService(configData []byte) (SearchAttributeService, error)

type TemporalServiceConfig

type TemporalServiceConfig struct {
	HostPort string `json:"hostPort"`
}

type TemporalServiceImpl

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

func NewTemporalService

func NewTemporalService(configData []byte) (*TemporalServiceImpl, error)

func (*TemporalServiceImpl) CreateNamespace

func (s *TemporalServiceImpl) CreateNamespace(ctx context.Context, namespace *core.TemporalNamespaceParameters) error

func (*TemporalServiceImpl) CreateSearchAttribute

func (s *TemporalServiceImpl) CreateSearchAttribute(ctx context.Context, searchAttribute *core.SearchAttributeParameters) error

func (*TemporalServiceImpl) DeleteAllNamespaces

func (s *TemporalServiceImpl) DeleteAllNamespaces(ctx context.Context) ([]*string, error)

func (*TemporalServiceImpl) DeleteNamespaceByName

func (s *TemporalServiceImpl) DeleteNamespaceByName(ctx context.Context, name string) (*string, error)

func (*TemporalServiceImpl) DeleteSearchAttributeByName

func (s *TemporalServiceImpl) DeleteSearchAttributeByName(ctx context.Context, namespace string, name string) error

func (*TemporalServiceImpl) DescribeNamespaceByName

func (s *TemporalServiceImpl) DescribeNamespaceByName(ctx context.Context, name string) (*core.TemporalNamespaceObservation, error)

func (*TemporalServiceImpl) DescribeSearchAttributeByName

func (s *TemporalServiceImpl) DescribeSearchAttributeByName(ctx context.Context, namespace string, name string) (*core.SearchAttributeObservation, error)

func (*TemporalServiceImpl) ListAllNamespaces

func (s *TemporalServiceImpl) ListAllNamespaces(ctx context.Context) ([]*core.TemporalNamespaceObservation, error)

func (*TemporalServiceImpl) ListSearchAttributesByNamespace

func (s *TemporalServiceImpl) ListSearchAttributesByNamespace(ctx context.Context, namespace string) ([]*core.SearchAttributeObservation, error)

func (*TemporalServiceImpl) MapToNamespaceCompare

func (s *TemporalServiceImpl) MapToNamespaceCompare(namespace interface{}) (*NamespaceCompare, error)

func (*TemporalServiceImpl) MapToSearchAttributeCompare

func (s *TemporalServiceImpl) MapToSearchAttributeCompare(searchAttribute interface{}) (*SearchAttributeCompare, error)

func (*TemporalServiceImpl) UpdateNamespaceByName

func (s *TemporalServiceImpl) UpdateNamespaceByName(ctx context.Context, namespace *core.TemporalNamespaceParameters) error