Navigation Menu

Skip to content

Commit

Permalink
Revert "Fix indent"
Browse files Browse the repository at this point in the history
This reverts commit 1593ab1.
Because these methods should be defined as unimportable.
  • Loading branch information
piroor committed Apr 22, 2015
1 parent 7e84a83 commit 3731abb
Showing 1 changed file with 28 additions and 28 deletions.
56 changes: 28 additions & 28 deletions lib/droonga/serf/tag.rb
Expand Up @@ -17,43 +17,43 @@ module Droonga
class Serf
module Tag
module_function
def node_type
"type"
end
def node_type
"type"
end

def node_role
"role"
end
def node_role
"role"
end

def internal_node_name
"internal-name"
end
def internal_node_name
"internal-name"
end

def cluster_id
"cluster_id"
end
def cluster_id
"cluster_id"
end

def accept_messages_newer_than
"accept-newer-than"
end
def accept_messages_newer_than
"accept-newer-than"
end

def last_processed_message_timestamp
"last-timestamp"
end
def last_processed_message_timestamp
"last-timestamp"
end

HAVE_UNPROCESSED_MESSAGES_TAG_PREFIX = "buffered-for-"
HAVE_UNPROCESSED_MESSAGES_TAG_PREFIX = "buffered-for-"

def have_unprocessed_messages_tag_for(node_name)
"#{HAVE_UNPROCESSED_MESSAGES_TAG_PREFIX}#{node_name}"
end
def have_unprocessed_messages_tag_for(node_name)
"#{HAVE_UNPROCESSED_MESSAGES_TAG_PREFIX}#{node_name}"
end

def have_unprocessed_messages_tag?(tag)
tag.start_with?(HAVE_UNPROCESSED_MESSAGES_TAG_PREFIX)
end
def have_unprocessed_messages_tag?(tag)
tag.start_with?(HAVE_UNPROCESSED_MESSAGES_TAG_PREFIX)
end

def extract_node_name_from_have_unprocessed_messages_tag(tag)
tag.sub(HAVE_UNPROCESSED_MESSAGES_TAG_PREFIX, "")
end
def extract_node_name_from_have_unprocessed_messages_tag(tag)
tag.sub(HAVE_UNPROCESSED_MESSAGES_TAG_PREFIX, "")
end
end
end
end

0 comments on commit 3731abb

Please sign in to comment.