Sha256: 3887a83ea89de73073f10ef5466634b6bcf3e7dd2b0324c20ab6ff0d55df6cc7

Contents?: true

Size: 1.11 KB

Versions: 4

Compression:

Stored size: 1.11 KB

Contents

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

namespace java org.apache.flume.thrift

struct ThriftFlumeEvent {
  1: required map <string, string> headers,
  2: required binary body,
}

enum Status {
  OK,
  FAILED,
  ERROR,
  UNKNOWN
}

service ThriftSourceProtocol {
  Status append(1: ThriftFlumeEvent event),
  Status appendBatch(1: list<ThriftFlumeEvent> events),
}

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
fluent-plugin-flume-1.0.0.rc1 lib/fluent/plugin/thrift/flume.thrift
fluent-plugin-flume-0.2.0 lib/fluent/plugin/thrift/flume.thrift
fluent-plugin-flume-0.1.3 lib/fluent/plugin/thrift/flume.thrift
fluent-plugin-flume-0.1.2 lib/fluent/plugin/thrift/flume.thrift