distributed_session.h

Go to the documentation of this file.

#pragma once

 
#include "fwd.h"
 
#include <yt/cpp/mapreduce/interface/common.h>
 
#include <library/cpp/yt/misc/strong_typedef.h>
 
#include <util/datetime/base.h>
 
namespace NYT {


YT_DEFINE_STRONG_TYPEDEF(TDistributedWriteTableSession, TNode);

YT_DEFINE_STRONG_TYPEDEF(TDistributedWriteTableCookie, TNode);

YT_DEFINE_STRONG_TYPEDEF(TWriteTableFragmentResult, TNode);


YT_DEFINE_STRONG_TYPEDEF(TDistributedWriteFileSession, TNode);

YT_DEFINE_STRONG_TYPEDEF(TDistributedWriteFileCookie, TNode);

YT_DEFINE_STRONG_TYPEDEF(TWriteFileFragmentResult, TNode);

 
struct TDistributedWriteTableSessionWithCookies
{
    using TSelf = TDistributedWriteTableSessionWithCookies;
 
    FLUENT_FIELD(TDistributedWriteTableSession, Session);
 
    FLUENT_FIELD(TVector<TDistributedWriteTableCookie>, Cookies);
};
 
struct TStartDistributedWriteTableOptions
{
    using TSelf = TStartDistributedWriteTableOptions;

    FLUENT_FIELD_OPTION(TDuration, SessionTimeout);
};
 
struct TPingDistributedWriteTableOptions
{
    using TSelf = TPingDistributedWriteTableOptions;
};
 
struct TFinishDistributedWriteTableOptions
{
    using TSelf = TFinishDistributedWriteTableOptions;
};

 
struct TDistributedWriteFileSessionWithCookies
{
    using TSelf = TDistributedWriteFileSessionWithCookies;
 
    FLUENT_FIELD(TDistributedWriteFileSession, Session);
 
    FLUENT_FIELD(TVector<TDistributedWriteFileCookie>, Cookies);
};
 
struct TStartDistributedWriteFileOptions
{
    using TSelf = TStartDistributedWriteFileOptions;

    FLUENT_FIELD_OPTION(TDuration, SessionTimeout);
};
 
struct TPingDistributedWriteFileOptions
{
    using TSelf = TPingDistributedWriteFileOptions;
};
 
struct TFinishDistributedWriteFileOptions
{
    using TSelf = TFinishDistributedWriteFileOptions;
};

 
} // namespace NYT