Navigation Menu

Skip to content

Commit

Permalink
Fix indent
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 21, 2015
1 parent 4c0c1aa commit 1593ab1
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 1593ab1

Please sign in to comment.