activities

Documentation

Index

• Constants
• Variables
• func Register(w worker.Worker, activities *Activities)
• type Activities
  • func NewActivities(client *api.Client) *Activities
  • func (a *Activities) CreateNamespace(ctx context.Context, in *cloudservice.CreateNamespaceRequest) (*cloudservice.CreateNamespaceResponse, error)
  • func (a *Activities) CreateUser(ctx context.Context, in *cloudservice.CreateUserRequest) (*cloudservice.CreateUserResponse, error)
  • func (a *Activities) DeleteNamespace(ctx context.Context, in *cloudservice.DeleteNamespaceRequest) (*cloudservice.DeleteNamespaceResponse, error)
  • func (a *Activities) DeleteUser(ctx context.Context, in *cloudservice.DeleteUserRequest) (*cloudservice.DeleteUserResponse, error)
  • func (a *Activities) GetAsyncOperation(ctx context.Context, in *cloudservice.GetAsyncOperationRequest) (*cloudservice.GetAsyncOperationResponse, error)
  • func (a *Activities) GetNamespace(ctx context.Context, in *cloudservice.GetNamespaceRequest) (*cloudservice.GetNamespaceResponse, error)
  • func (a *Activities) GetNamespaces(ctx context.Context, in *cloudservice.GetNamespacesRequest) (*cloudservice.GetNamespacesResponse, error)
  • func (a *Activities) GetRegion(ctx context.Context, in *cloudservice.GetRegionRequest) (*cloudservice.GetRegionResponse, error)
  • func (a *Activities) GetRegions(ctx context.Context, in *cloudservice.GetRegionsRequest) (*cloudservice.GetRegionsResponse, error)
  • func (a *Activities) GetUser(ctx context.Context, in *cloudservice.GetUserRequest) (*cloudservice.GetUserResponse, error)
  • func (a *Activities) GetUsers(ctx context.Context, in *cloudservice.GetUsersRequest) (*cloudservice.GetUsersResponse, error)
  • func (a *Activities) UpdateNamespace(ctx context.Context, in *cloudservice.UpdateNamespaceRequest) (*cloudservice.UpdateNamespaceResponse, error)
  • func (a *Activities) UpdateUser(ctx context.Context, in *cloudservice.UpdateUserRequest) (*cloudservice.UpdateUserResponse, error)
• type ExecuteActivity

Constants

const (
	CloudAPIRequestFailure = "temporal-cloud-api-request-failure"
)

Variables

var (
	GetNamespace    = executeActivityFn[*cloudservice.GetNamespaceRequest, *cloudservice.GetNamespaceResponse](activitiesPrefix + "GetNamespace")
	GetNamespaces   = executeActivityFn[*cloudservice.GetNamespacesRequest, *cloudservice.GetNamespacesResponse](activitiesPrefix + "GetNamespaces")
	CreateNamespace = executeActivityFn[*cloudservice.CreateNamespaceRequest, *cloudservice.CreateNamespaceResponse](activitiesPrefix + "CreateNamespace")
	UpdateNamespace = executeActivityFn[*cloudservice.UpdateNamespaceRequest, *cloudservice.UpdateNamespaceResponse](activitiesPrefix + "UpdateNamespace")
	DeleteNamespace = executeActivityFn[*cloudservice.DeleteNamespaceRequest, *cloudservice.DeleteNamespaceResponse](activitiesPrefix + "DeleteNamespace")
)

var (
	GetRegion  = executeActivityFn[*cloudservice.GetRegionRequest, *cloudservice.GetRegionResponse](activitiesPrefix + "GetRegion")
	GetRegions = executeActivityFn[*cloudservice.GetRegionsRequest, *cloudservice.GetRegionsResponse](activitiesPrefix + "GetRegions")
)

var (
	GetUser    = executeActivityFn[*cloudservice.GetUserRequest, *cloudservice.GetUserResponse](activitiesPrefix + "GetUser")
	GetUsers   = executeActivityFn[*cloudservice.GetUsersRequest, *cloudservice.GetUsersResponse](activitiesPrefix + "GetUsers")
	CreateUser = executeActivityFn[*cloudservice.CreateUserRequest, *cloudservice.CreateUserResponse](activitiesPrefix + "CreateUser")
	UpdateUser = executeActivityFn[*cloudservice.UpdateUserRequest, *cloudservice.UpdateUserResponse](activitiesPrefix + "UpdateUser")
	DeleteUser = executeActivityFn[*cloudservice.DeleteUserRequest, *cloudservice.DeleteUserResponse](activitiesPrefix + "DeleteUser")
)

var GetAsyncOperation = executeActivityFn[*cloudservice.GetAsyncOperationRequest, *cloudservice.GetAsyncOperationResponse](activitiesPrefix + "GetAsyncOperation")

Functions

func Register

func Register(w worker.Worker, activities *Activities)

Types

type Activities

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

func NewActivities

func NewActivities(client *api.Client) *Activities

func (*Activities) CreateNamespace

func (a *Activities) CreateNamespace(ctx context.Context, in *cloudservice.CreateNamespaceRequest) (*cloudservice.CreateNamespaceResponse, error)

func (*Activities) CreateUser

func (a *Activities) CreateUser(ctx context.Context, in *cloudservice.CreateUserRequest) (*cloudservice.CreateUserResponse, error)

func (*Activities) DeleteNamespace

func (a *Activities) DeleteNamespace(ctx context.Context, in *cloudservice.DeleteNamespaceRequest) (*cloudservice.DeleteNamespaceResponse, error)

func (*Activities) DeleteUser

func (a *Activities) DeleteUser(ctx context.Context, in *cloudservice.DeleteUserRequest) (*cloudservice.DeleteUserResponse, error)

func (*Activities) GetAsyncOperation

func (a *Activities) GetAsyncOperation(ctx context.Context, in *cloudservice.GetAsyncOperationRequest) (*cloudservice.GetAsyncOperationResponse, error)

func (*Activities) GetNamespace

func (a *Activities) GetNamespace(ctx context.Context, in *cloudservice.GetNamespaceRequest) (*cloudservice.GetNamespaceResponse, error)

func (*Activities) GetNamespaces

func (a *Activities) GetNamespaces(ctx context.Context, in *cloudservice.GetNamespacesRequest) (*cloudservice.GetNamespacesResponse, error)

func (*Activities) GetRegion

func (a *Activities) GetRegion(ctx context.Context, in *cloudservice.GetRegionRequest) (*cloudservice.GetRegionResponse, error)

func (*Activities) GetRegions

func (a *Activities) GetRegions(ctx context.Context, in *cloudservice.GetRegionsRequest) (*cloudservice.GetRegionsResponse, error)

func (*Activities) GetUser

func (a *Activities) GetUser(ctx context.Context, in *cloudservice.GetUserRequest) (*cloudservice.GetUserResponse, error)

func (*Activities) GetUsers

func (a *Activities) GetUsers(ctx context.Context, in *cloudservice.GetUsersRequest) (*cloudservice.GetUsersResponse, error)

func (*Activities) UpdateNamespace

func (a *Activities) UpdateNamespace(ctx context.Context, in *cloudservice.UpdateNamespaceRequest) (*cloudservice.UpdateNamespaceResponse, error)

func (*Activities) UpdateUser

func (a *Activities) UpdateUser(ctx context.Context, in *cloudservice.UpdateUserRequest) (*cloudservice.UpdateUserResponse, error)

type ExecuteActivity

type ExecuteActivity[Req any, Resp any] func(workflow.Context, Req) (Resp, error)