federation

package
v0.0.0-...-28787c5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 26, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package federation is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	MetadataType_name = map[int32]string{
		0: "DataMap",
		1: "TextMap",
		2: "AttributeMap",
	}
	MetadataType_value = map[string]int32{
		"DataMap":      0,
		"TextMap":      1,
		"AttributeMap": 2,
	}
)

Enum value maps for MetadataType.

View Source 
var File_api_proto_federation_proto protoreflect.FileDescriptor

Functions

func RegisterFederationHandler 

func RegisterFederationHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterFederationHandler registers the http handlers for service Federation to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterFederationHandlerClient 

func RegisterFederationHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FederationClient) error

RegisterFederationHandlerClient registers the http handlers for service Federation to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "FederationClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "FederationClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "FederationClient" to call the correct interceptors.

func RegisterFederationHandlerFromEndpoint 

func RegisterFederationHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterFederationHandlerFromEndpoint is same as RegisterFederationHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterFederationHandlerServer 

func RegisterFederationHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FederationServer) error

RegisterFederationHandlerServer registers the http handlers for service Federation to "mux". UnaryRPC :call FederationServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterFederationHandlerFromEndpoint instead.

func RegisterFederationServer 

func RegisterFederationServer(s *grpc.Server, srv FederationServer)

Types

type FederationClient 

type FederationClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Pong, error)
	GetLocalMetadataItems(ctx context.Context, in *GetLocalMetadataItemRequest, opts ...grpc.CallOption) (*GetLocalMetadataItemRequestResponse, error)
	StreamRemoteMetadataItems(ctx context.Context, in *GetRemoteMetadataRequest, opts ...grpc.CallOption) (Federation_StreamRemoteMetadataItemsClient, error)
	StreamLocalFile(ctx context.Context, in *StreamLocalFileRequest, opts ...grpc.CallOption) (Federation_StreamLocalFileClient, error)
	StreamReportResults(ctx context.Context, in *StreamReportResultsRequest, opts ...grpc.CallOption) (Federation_StreamReportResultsClient, error)
	GetFederations(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetFederationsResponse, error)
	PostFederationObjects(ctx context.Context, in *PostFederationObjectsRequest, opts ...grpc.CallOption) (*PostFederationObjectsResponse, error)
	PostFederationStatus(ctx context.Context, in *PostFederationStatusRequest, opts ...grpc.CallOption) (*PostFederationStatusResponse, error)
	Replay(ctx context.Context, in *ReplayRequest, opts ...grpc.CallOption) (*ReplyStats, error)
}

FederationClient is the client API for Federation service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFederationClient 

func NewFederationClient(cc grpc.ClientConnInterface) FederationClient

type FederationServer 

type FederationServer interface {
	Ping(context.Context, *emptypb.Empty) (*Pong, error)
	GetLocalMetadataItems(context.Context, *GetLocalMetadataItemRequest) (*GetLocalMetadataItemRequestResponse, error)
	StreamRemoteMetadataItems(*GetRemoteMetadataRequest, Federation_StreamRemoteMetadataItemsServer) error
	StreamLocalFile(*StreamLocalFileRequest, Federation_StreamLocalFileServer) error
	StreamReportResults(*StreamReportResultsRequest, Federation_StreamReportResultsServer) error
	GetFederations(context.Context, *emptypb.Empty) (*GetFederationsResponse, error)
	PostFederationObjects(context.Context, *PostFederationObjectsRequest) (*PostFederationObjectsResponse, error)
	PostFederationStatus(context.Context, *PostFederationStatusRequest) (*PostFederationStatusResponse, error)
	Replay(context.Context, *ReplayRequest) (*ReplyStats, error)
}

FederationServer is the server API for Federation service.

type Federation_StreamLocalFileClient 

type Federation_StreamLocalFileClient interface {
	Recv() (*StreamDataFileResponse, error)
	grpc.ClientStream
}

type Federation_StreamLocalFileServer 

type Federation_StreamLocalFileServer interface {
	Send(*StreamDataFileResponse) error
	grpc.ServerStream
}

type Federation_StreamRemoteMetadataItemsClient 

type Federation_StreamRemoteMetadataItemsClient interface {
	Recv() (*StreamRemoteMetadataResponse, error)
	grpc.ClientStream
}

type Federation_StreamRemoteMetadataItemsServer 

type Federation_StreamRemoteMetadataItemsServer interface {
	Send(*StreamRemoteMetadataResponse) error
	grpc.ServerStream
}

type Federation_StreamReportResultsClient 

type Federation_StreamReportResultsClient interface {
	Recv() (*StreamDataFileResponse, error)
	grpc.ClientStream
}

type Federation_StreamReportResultsServer 

type Federation_StreamReportResultsServer interface {
	Send(*StreamDataFileResponse) error
	grpc.ServerStream
}

type Filter 

type Filter struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Condition string `protobuf:"bytes,2,opt,name=condition,proto3" json:"condition,omitempty"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

func (*Filter) Descriptor() ([]byte, []int)

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetCondition 

func (x *Filter) GetCondition() string

func (*Filter) GetName 

func (x *Filter) GetName() string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

func (x *Filter) ProtoReflect() protoreflect.Message

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type GetFederationsResponse 

type GetFederationsResponse struct {
	Results []*GetFederationsResponseEntry `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFederationsResponse) Descriptor deprecated 

func (*GetFederationsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetFederationsResponse.ProtoReflect.Descriptor instead.

func (*GetFederationsResponse) GetResults 

func (x *GetFederationsResponse) GetResults() []*GetFederationsResponseEntry

func (*GetFederationsResponse) ProtoMessage 

func (*GetFederationsResponse) ProtoMessage()

func (*GetFederationsResponse) ProtoReflect 

func (x *GetFederationsResponse) ProtoReflect() protoreflect.Message

func (*GetFederationsResponse) Reset 

func (x *GetFederationsResponse) Reset()

func (*GetFederationsResponse) String 

func (x *GetFederationsResponse) String() string

type GetFederationsResponseEntry 

type GetFederationsResponseEntry struct {
	Name  string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Nodes []*Node `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFederationsResponseEntry) Descriptor deprecated 

func (*GetFederationsResponseEntry) Descriptor() ([]byte, []int)

Deprecated: Use GetFederationsResponseEntry.ProtoReflect.Descriptor instead.

func (*GetFederationsResponseEntry) GetName 

func (x *GetFederationsResponseEntry) GetName() string

func (*GetFederationsResponseEntry) GetNodes 

func (x *GetFederationsResponseEntry) GetNodes() []*Node

func (*GetFederationsResponseEntry) ProtoMessage 

func (*GetFederationsResponseEntry) ProtoMessage()

func (*GetFederationsResponseEntry) ProtoReflect 

func (x *GetFederationsResponseEntry) ProtoReflect() protoreflect.Message

func (*GetFederationsResponseEntry) Reset 

func (x *GetFederationsResponseEntry) Reset()

func (*GetFederationsResponseEntry) String 

func (x *GetFederationsResponseEntry) String() string

type GetLocalMetadataItemRequest 

type GetLocalMetadataItemRequest struct {
	MetadataType MetadataType `protobuf:"varint,1,opt,name=metadataType,proto3,enum=federation.MetadataType" json:"metadataType,omitempty"`
	Destination  string       `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	Namespace    string       `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Keys         []string     `protobuf:"bytes,4,rep,name=keys,proto3" json:"keys,omitempty"`
	Val          string       `protobuf:"bytes,5,opt,name=val,proto3" json:"val,omitempty"`
	Interval     int64        `protobuf:"varint,6,opt,name=interval,proto3" json:"interval,omitempty"`
	Stems        []string     `protobuf:"bytes,7,rep,name=stems,proto3" json:"stems,omitempty"`
	ActualStems  []string     `protobuf:"bytes,8,rep,name=actualStems,proto3" json:"actualStems,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLocalMetadataItemRequest) Descriptor deprecated 

func (*GetLocalMetadataItemRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetLocalMetadataItemRequest.ProtoReflect.Descriptor instead.

func (*GetLocalMetadataItemRequest) GetActualStems 

func (x *GetLocalMetadataItemRequest) GetActualStems() []string

func (*GetLocalMetadataItemRequest) GetDestination 

func (x *GetLocalMetadataItemRequest) GetDestination() string

func (*GetLocalMetadataItemRequest) GetInterval 

func (x *GetLocalMetadataItemRequest) GetInterval() int64

func (*GetLocalMetadataItemRequest) GetKeys 

func (x *GetLocalMetadataItemRequest) GetKeys() []string

func (*GetLocalMetadataItemRequest) GetMetadataType 

func (x *GetLocalMetadataItemRequest) GetMetadataType() MetadataType

func (*GetLocalMetadataItemRequest) GetNamespace 

func (x *GetLocalMetadataItemRequest) GetNamespace() string

func (*GetLocalMetadataItemRequest) GetStems 

func (x *GetLocalMetadataItemRequest) GetStems() []string

func (*GetLocalMetadataItemRequest) GetVal 

func (x *GetLocalMetadataItemRequest) GetVal() string

func (*GetLocalMetadataItemRequest) ProtoMessage 

func (*GetLocalMetadataItemRequest) ProtoMessage()

func (*GetLocalMetadataItemRequest) ProtoReflect 

func (x *GetLocalMetadataItemRequest) ProtoReflect() protoreflect.Message

func (*GetLocalMetadataItemRequest) Reset 

func (x *GetLocalMetadataItemRequest) Reset()

func (*GetLocalMetadataItemRequest) String 

func (x *GetLocalMetadataItemRequest) String() string

type GetLocalMetadataItemRequestResponse 

type GetLocalMetadataItemRequestResponse struct {
	Items         *LocalMetadataItems `protobuf:"bytes,1,opt,name=items,proto3" json:"items,omitempty"`
	SkipIntervals []int64             `protobuf:"varint,2,rep,packed,name=skipIntervals,proto3" json:"skipIntervals,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLocalMetadataItemRequestResponse) Descriptor deprecated 

func (*GetLocalMetadataItemRequestResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetLocalMetadataItemRequestResponse.ProtoReflect.Descriptor instead.

func (*GetLocalMetadataItemRequestResponse) GetItems 

func (x *GetLocalMetadataItemRequestResponse) GetItems() *LocalMetadataItems

func (*GetLocalMetadataItemRequestResponse) GetSkipIntervals 

func (x *GetLocalMetadataItemRequestResponse) GetSkipIntervals() []int64

func (*GetLocalMetadataItemRequestResponse) ProtoMessage 

func (*GetLocalMetadataItemRequestResponse) ProtoMessage()

func (*GetLocalMetadataItemRequestResponse) ProtoReflect 

func (x *GetLocalMetadataItemRequestResponse) ProtoReflect() protoreflect.Message

func (*GetLocalMetadataItemRequestResponse) Reset 

func (x *GetLocalMetadataItemRequestResponse) Reset()

func (*GetLocalMetadataItemRequestResponse) String 

func (x *GetLocalMetadataItemRequestResponse) String() string

type GetRemoteMetadataRequest 

type GetRemoteMetadataRequest struct {
	QueryId               string        `protobuf:"bytes,1,opt,name=queryId,proto3" json:"queryId,omitempty"`
	Destination           string        `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	Namespace             string        `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Key                   string        `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	LogStartTime          int64         `protobuf:"varint,5,opt,name=logStartTime,proto3" json:"logStartTime,omitempty"`
	ActualStems           []string      `protobuf:"bytes,6,rep,name=actualStems,proto3" json:"actualStems,omitempty"`
	CompareStems          bool          `protobuf:"varint,7,opt,name=compareStems,proto3" json:"compareStems,omitempty"`
	DailyBitsetFileName   string        `protobuf:"bytes,9,opt,name=dailyBitsetFileName,proto3" json:"dailyBitsetFileName,omitempty"`
	GetFromCache          bool          `protobuf:"varint,10,opt,name=getFromCache,proto3" json:"getFromCache,omitempty"`
	IndexIntervalFileName string        `protobuf:"bytes,11,opt,name=indexIntervalFileName,proto3" json:"indexIntervalFileName,omitempty"`
	QueryRequest          *QueryRequest `protobuf:"bytes,12,opt,name=queryRequest,proto3" json:"queryRequest,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRemoteMetadataRequest) Descriptor deprecated 

func (*GetRemoteMetadataRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRemoteMetadataRequest.ProtoReflect.Descriptor instead.

func (*GetRemoteMetadataRequest) GetActualStems 

func (x *GetRemoteMetadataRequest) GetActualStems() []string

func (*GetRemoteMetadataRequest) GetCompareStems 

func (x *GetRemoteMetadataRequest) GetCompareStems() bool

func (*GetRemoteMetadataRequest) GetDailyBitsetFileName 

func (x *GetRemoteMetadataRequest) GetDailyBitsetFileName() string

func (*GetRemoteMetadataRequest) GetDestination 

func (x *GetRemoteMetadataRequest) GetDestination() string

func (*GetRemoteMetadataRequest) GetGetFromCache 

func (x *GetRemoteMetadataRequest) GetGetFromCache() bool

func (*GetRemoteMetadataRequest) GetIndexIntervalFileName 

func (x *GetRemoteMetadataRequest) GetIndexIntervalFileName() string

func (*GetRemoteMetadataRequest) GetKey 

func (x *GetRemoteMetadataRequest) GetKey() string

func (*GetRemoteMetadataRequest) GetLogStartTime 

func (x *GetRemoteMetadataRequest) GetLogStartTime() int64

func (*GetRemoteMetadataRequest) GetNamespace 

func (x *GetRemoteMetadataRequest) GetNamespace() string

func (*GetRemoteMetadataRequest) GetQueryId 

func (x *GetRemoteMetadataRequest) GetQueryId() string

func (*GetRemoteMetadataRequest) GetQueryRequest 

func (x *GetRemoteMetadataRequest) GetQueryRequest() *QueryRequest

func (*GetRemoteMetadataRequest) ProtoMessage 

func (*GetRemoteMetadataRequest) ProtoMessage()

func (*GetRemoteMetadataRequest) ProtoReflect 

func (x *GetRemoteMetadataRequest) ProtoReflect() protoreflect.Message

func (*GetRemoteMetadataRequest) Reset 

func (x *GetRemoteMetadataRequest) Reset()

func (*GetRemoteMetadataRequest) String 

func (x *GetRemoteMetadataRequest) String() string

type LocalMetadataItem 

type LocalMetadataItem struct {
	MetadataType  MetadataType `protobuf:"varint,1,opt,name=metadataType,proto3,enum=federation.MetadataType" json:"metadataType,omitempty"`
	Destination   string       `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	Namespace     string       `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Key           string       `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Val           string       `protobuf:"bytes,5,opt,name=val,proto3" json:"val,omitempty"`
	LogStartTime  int64        `protobuf:"varint,6,opt,name=logStartTime,proto3" json:"logStartTime,omitempty"`
	DataLocations []string     `protobuf:"bytes,7,rep,name=dataLocations,proto3" json:"dataLocations,omitempty"`
	Stems         []string     `protobuf:"bytes,8,rep,name=stems,proto3" json:"stems,omitempty"`
	// contains filtered or unexported fields
}

func (*LocalMetadataItem) Descriptor deprecated 

func (*LocalMetadataItem) Descriptor() ([]byte, []int)

Deprecated: Use LocalMetadataItem.ProtoReflect.Descriptor instead.

func (*LocalMetadataItem) GetDataLocations 

func (x *LocalMetadataItem) GetDataLocations() []string

func (*LocalMetadataItem) GetDestination 

func (x *LocalMetadataItem) GetDestination() string

func (*LocalMetadataItem) GetKey 

func (x *LocalMetadataItem) GetKey() string

func (*LocalMetadataItem) GetLogStartTime 

func (x *LocalMetadataItem) GetLogStartTime() int64

func (*LocalMetadataItem) GetMetadataType 

func (x *LocalMetadataItem) GetMetadataType() MetadataType

func (*LocalMetadataItem) GetNamespace 

func (x *LocalMetadataItem) GetNamespace() string

func (*LocalMetadataItem) GetStems 

func (x *LocalMetadataItem) GetStems() []string

func (*LocalMetadataItem) GetVal 

func (x *LocalMetadataItem) GetVal() string

func (*LocalMetadataItem) ProtoMessage 

func (*LocalMetadataItem) ProtoMessage()

func (*LocalMetadataItem) ProtoReflect 

func (x *LocalMetadataItem) ProtoReflect() protoreflect.Message

func (*LocalMetadataItem) Reset 

func (x *LocalMetadataItem) Reset()

func (*LocalMetadataItem) String 

func (x *LocalMetadataItem) String() string

type LocalMetadataItems 

type LocalMetadataItems struct {
	Items []*LocalMetadataItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*LocalMetadataItems) Descriptor deprecated 

func (*LocalMetadataItems) Descriptor() ([]byte, []int)

Deprecated: Use LocalMetadataItems.ProtoReflect.Descriptor instead.

func (*LocalMetadataItems) GetItems 

func (x *LocalMetadataItems) GetItems() []*LocalMetadataItem

func (*LocalMetadataItems) ProtoMessage 

func (*LocalMetadataItems) ProtoMessage()

func (*LocalMetadataItems) ProtoReflect 

func (x *LocalMetadataItems) ProtoReflect() protoreflect.Message

func (*LocalMetadataItems) Reset 

func (x *LocalMetadataItems) Reset()

func (*LocalMetadataItems) String 

func (x *LocalMetadataItems) String() string

type MetadataType 

type MetadataType int32
const (
	MetadataType_DataMap      MetadataType = 0
	MetadataType_TextMap      MetadataType = 1
	MetadataType_AttributeMap MetadataType = 2
)

func (MetadataType) Descriptor 

func (MetadataType) Descriptor() protoreflect.EnumDescriptor

func (MetadataType) Enum 

func (x MetadataType) Enum() *MetadataType

func (MetadataType) EnumDescriptor deprecated 

func (MetadataType) EnumDescriptor() ([]byte, []int)

Deprecated: Use MetadataType.Descriptor instead.

func (MetadataType) Number 

func (x MetadataType) Number() protoreflect.EnumNumber

func (MetadataType) String 

func (x MetadataType) String() string

func (MetadataType) Type 

func (MetadataType) Type() protoreflect.EnumType

type Node 

type Node struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

func (*Node) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetAddress 

func (x *Node) GetAddress() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type Pong 

type Pong struct {
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Pong) Descriptor deprecated 

func (*Pong) Descriptor() ([]byte, []int)

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GetData 

func (x *Pong) GetData() string

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect 

func (x *Pong) ProtoReflect() protoreflect.Message

func (*Pong) Reset 

func (x *Pong) Reset()

func (*Pong) String 

func (x *Pong) String() string

type PostFederationObjectsRequest 

type PostFederationObjectsRequest struct {
	Type    string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`       // What object type is being requested
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`       // Name of the federation
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` // Which address to query in the federation
	// contains filtered or unexported fields
}

func (*PostFederationObjectsRequest) Descriptor deprecated 

func (*PostFederationObjectsRequest) Descriptor() ([]byte, []int)

Deprecated: Use PostFederationObjectsRequest.ProtoReflect.Descriptor instead.

func (*PostFederationObjectsRequest) GetAddress 

func (x *PostFederationObjectsRequest) GetAddress() string

func (*PostFederationObjectsRequest) GetName 

func (x *PostFederationObjectsRequest) GetName() string

func (*PostFederationObjectsRequest) GetType 

func (x *PostFederationObjectsRequest) GetType() string

func (*PostFederationObjectsRequest) ProtoMessage 

func (*PostFederationObjectsRequest) ProtoMessage()

func (*PostFederationObjectsRequest) ProtoReflect 

func (x *PostFederationObjectsRequest) ProtoReflect() protoreflect.Message

func (*PostFederationObjectsRequest) Reset 

func (x *PostFederationObjectsRequest) Reset()

func (*PostFederationObjectsRequest) String 

func (x *PostFederationObjectsRequest) String() string

type PostFederationObjectsResponse 

type PostFederationObjectsResponse struct {
	Results []*PostFederationObjectsResponseEntry `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*PostFederationObjectsResponse) Descriptor deprecated 

func (*PostFederationObjectsResponse) Descriptor() ([]byte, []int)

Deprecated: Use PostFederationObjectsResponse.ProtoReflect.Descriptor instead.

func (*PostFederationObjectsResponse) GetResults 

func (x *PostFederationObjectsResponse) GetResults() []*PostFederationObjectsResponseEntry

func (*PostFederationObjectsResponse) ProtoMessage 

func (*PostFederationObjectsResponse) ProtoMessage()

func (*PostFederationObjectsResponse) ProtoReflect 

func (x *PostFederationObjectsResponse) ProtoReflect() protoreflect.Message

func (*PostFederationObjectsResponse) Reset 

func (x *PostFederationObjectsResponse) Reset()

func (*PostFederationObjectsResponse) String 

func (x *PostFederationObjectsResponse) String() string

type PostFederationObjectsResponseEntry 

type PostFederationObjectsResponseEntry struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ObjectPath string `protobuf:"bytes,2,opt,name=object_path,json=objectPath,proto3" json:"object_path,omitempty"`
	Dirty      int32  `protobuf:"varint,3,opt,name=dirty,proto3" json:"dirty,omitempty"`
	UpdatedAt  string `protobuf:"bytes,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*PostFederationObjectsResponseEntry) Descriptor deprecated 

func (*PostFederationObjectsResponseEntry) Descriptor() ([]byte, []int)

Deprecated: Use PostFederationObjectsResponseEntry.ProtoReflect.Descriptor instead.

func (*PostFederationObjectsResponseEntry) GetDirty 

func (x *PostFederationObjectsResponseEntry) GetDirty() int32

func (*PostFederationObjectsResponseEntry) GetId 

func (x *PostFederationObjectsResponseEntry) GetId() string

func (*PostFederationObjectsResponseEntry) GetObjectPath 

func (x *PostFederationObjectsResponseEntry) GetObjectPath() string

func (*PostFederationObjectsResponseEntry) GetUpdatedAt 

func (x *PostFederationObjectsResponseEntry) GetUpdatedAt() string

func (*PostFederationObjectsResponseEntry) ProtoMessage 

func (*PostFederationObjectsResponseEntry) ProtoMessage()

func (*PostFederationObjectsResponseEntry) ProtoReflect 

func (x *PostFederationObjectsResponseEntry) ProtoReflect() protoreflect.Message

func (*PostFederationObjectsResponseEntry) Reset 

func (x *PostFederationObjectsResponseEntry) Reset()

func (*PostFederationObjectsResponseEntry) String 

func (x *PostFederationObjectsResponseEntry) String() string

type PostFederationStatusRequest 

type PostFederationStatusRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name of the federation
	// contains filtered or unexported fields
}

func (*PostFederationStatusRequest) Descriptor deprecated 

func (*PostFederationStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use PostFederationStatusRequest.ProtoReflect.Descriptor instead.

func (*PostFederationStatusRequest) GetName 

func (x *PostFederationStatusRequest) GetName() string

func (*PostFederationStatusRequest) ProtoMessage 

func (*PostFederationStatusRequest) ProtoMessage()

func (*PostFederationStatusRequest) ProtoReflect 

func (x *PostFederationStatusRequest) ProtoReflect() protoreflect.Message

func (*PostFederationStatusRequest) Reset 

func (x *PostFederationStatusRequest) Reset()

func (*PostFederationStatusRequest) String 

func (x *PostFederationStatusRequest) String() string

type PostFederationStatusResponse 

type PostFederationStatusResponse struct {
	Results []*PostFederationStatusResponseEntry `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*PostFederationStatusResponse) Descriptor deprecated 

func (*PostFederationStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use PostFederationStatusResponse.ProtoReflect.Descriptor instead.

func (*PostFederationStatusResponse) GetResults 

func (x *PostFederationStatusResponse) GetResults() []*PostFederationStatusResponseEntry

func (*PostFederationStatusResponse) ProtoMessage 

func (*PostFederationStatusResponse) ProtoMessage()

func (*PostFederationStatusResponse) ProtoReflect 

func (x *PostFederationStatusResponse) ProtoReflect() protoreflect.Message

func (*PostFederationStatusResponse) Reset 

func (x *PostFederationStatusResponse) Reset()

func (*PostFederationStatusResponse) String 

func (x *PostFederationStatusResponse) String() string

type PostFederationStatusResponseEntry 

type PostFederationStatusResponseEntry struct {
	Address    string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	StatusCode int32  `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Error      string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*PostFederationStatusResponseEntry) Descriptor deprecated 

func (*PostFederationStatusResponseEntry) Descriptor() ([]byte, []int)

Deprecated: Use PostFederationStatusResponseEntry.ProtoReflect.Descriptor instead.

func (*PostFederationStatusResponseEntry) GetAddress 

func (x *PostFederationStatusResponseEntry) GetAddress() string

func (*PostFederationStatusResponseEntry) GetError 

func (x *PostFederationStatusResponseEntry) GetError() string

func (*PostFederationStatusResponseEntry) GetStatusCode 

func (x *PostFederationStatusResponseEntry) GetStatusCode() int32

func (*PostFederationStatusResponseEntry) ProtoMessage 

func (*PostFederationStatusResponseEntry) ProtoMessage()

func (*PostFederationStatusResponseEntry) ProtoReflect 

func (x *PostFederationStatusResponseEntry) ProtoReflect() protoreflect.Message

func (*PostFederationStatusResponseEntry) Reset 

func (x *PostFederationStatusResponseEntry) Reset()

func (*PostFederationStatusResponseEntry) String 

func (x *PostFederationStatusResponseEntry) String() string

type QueryRequest 

type QueryRequest struct {
	Id               string   `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Destination      string   `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	Namespace        string   `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ApplicationNames []string `protobuf:"bytes,4,rep,name=applicationNames,proto3" json:"applicationNames,omitempty"`
	OriginStartTime  string   `protobuf:"bytes,5,opt,name=originStartTime,proto3" json:"originStartTime,omitempty"`
	KeyWord          string   `protobuf:"bytes,6,opt,name=keyWord,proto3" json:"keyWord,omitempty"`
	Filters          string   `protobuf:"bytes,7,opt,name=filters,proto3" json:"filters,omitempty"`
	StartTime        int64    `protobuf:"varint,8,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime          int64    `protobuf:"varint,9,opt,name=endTime,proto3" json:"endTime,omitempty"`
	ActualStems      []string `protobuf:"bytes,10,rep,name=actualStems,proto3" json:"actualStems,omitempty"`
	IntentID         string   `protobuf:"bytes,11,opt,name=intentID,proto3" json:"intentID,omitempty"`
	ActualStemsV3    []string `protobuf:"bytes,12,rep,name=actualStemsV3,proto3" json:"actualStemsV3,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

func (*QueryRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetActualStems 

func (x *QueryRequest) GetActualStems() []string

func (*QueryRequest) GetActualStemsV3 

func (x *QueryRequest) GetActualStemsV3() []string

func (*QueryRequest) GetApplicationNames 

func (x *QueryRequest) GetApplicationNames() []string

func (*QueryRequest) GetDestination 

func (x *QueryRequest) GetDestination() string

func (*QueryRequest) GetEndTime 

func (x *QueryRequest) GetEndTime() int64

func (*QueryRequest) GetFilters 

func (x *QueryRequest) GetFilters() string

func (*QueryRequest) GetId 

func (x *QueryRequest) GetId() string

func (*QueryRequest) GetIntentID 

func (x *QueryRequest) GetIntentID() string

func (*QueryRequest) GetKeyWord 

func (x *QueryRequest) GetKeyWord() string

func (*QueryRequest) GetNamespace 

func (x *QueryRequest) GetNamespace() string

func (*QueryRequest) GetOriginStartTime 

func (x *QueryRequest) GetOriginStartTime() string

func (*QueryRequest) GetStartTime 

func (x *QueryRequest) GetStartTime() int64

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

func (x *QueryRequest) ProtoReflect() protoreflect.Message

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type ReplayRequest 

type ReplayRequest struct {
	Id                 string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	FileName           string `protobuf:"bytes,2,opt,name=fileName,proto3" json:"fileName,omitempty"`
	Expression         string `protobuf:"bytes,3,opt,name=expression,proto3" json:"expression,omitempty"`
	StartTime          string `protobuf:"bytes,4,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime            string `protobuf:"bytes,5,opt,name=endTime,proto3" json:"endTime,omitempty"`
	ForwardDestination string `protobuf:"bytes,6,opt,name=forwardDestination,proto3" json:"forwardDestination,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplayRequest) Descriptor deprecated 

func (*ReplayRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplayRequest.ProtoReflect.Descriptor instead.

func (*ReplayRequest) GetEndTime 

func (x *ReplayRequest) GetEndTime() string

func (*ReplayRequest) GetExpression 

func (x *ReplayRequest) GetExpression() string

func (*ReplayRequest) GetFileName 

func (x *ReplayRequest) GetFileName() string

func (*ReplayRequest) GetForwardDestination 

func (x *ReplayRequest) GetForwardDestination() string

func (*ReplayRequest) GetId 

func (x *ReplayRequest) GetId() string

func (*ReplayRequest) GetStartTime 

func (x *ReplayRequest) GetStartTime() string

func (*ReplayRequest) ProtoMessage 

func (*ReplayRequest) ProtoMessage()

func (*ReplayRequest) ProtoReflect 

func (x *ReplayRequest) ProtoReflect() protoreflect.Message

func (*ReplayRequest) Reset 

func (x *ReplayRequest) Reset()

func (*ReplayRequest) String 

func (x *ReplayRequest) String() string

type ReplyStats 

type ReplyStats struct {
	Lines int64 `protobuf:"varint,1,opt,name=lines,proto3" json:"lines,omitempty"`
	Bytes int64 `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplyStats) Descriptor deprecated 

func (*ReplyStats) Descriptor() ([]byte, []int)

Deprecated: Use ReplyStats.ProtoReflect.Descriptor instead.

func (*ReplyStats) GetBytes 

func (x *ReplyStats) GetBytes() int64

func (*ReplyStats) GetLines 

func (x *ReplyStats) GetLines() int64

func (*ReplyStats) ProtoMessage 

func (*ReplyStats) ProtoMessage()

func (*ReplyStats) ProtoReflect 

func (x *ReplyStats) ProtoReflect() protoreflect.Message

func (*ReplyStats) Reset 

func (x *ReplyStats) Reset()

func (*ReplyStats) String 

func (x *ReplyStats) String() string

type ReportDefinition 

type ReportDefinition struct {
	QueryId        string   `protobuf:"bytes,1,opt,name=queryId,proto3" json:"queryId,omitempty"`
	Namespace      string   `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	Application    string   `protobuf:"bytes,3,opt,name=Application,proto3" json:"Application,omitempty"`
	Expression     string   `protobuf:"bytes,4,opt,name=Expression,proto3" json:"Expression,omitempty"`
	ValueField     string   `protobuf:"bytes,5,opt,name=ValueField,proto3" json:"ValueField,omitempty"`
	AggregateFn    string   `protobuf:"bytes,6,opt,name=AggregateFn,proto3" json:"AggregateFn,omitempty"`
	GroupBy        []string `protobuf:"bytes,7,rep,name=GroupBy,proto3" json:"GroupBy,omitempty"`
	GroupByPattern []string `protobuf:"bytes,8,rep,name=GroupByPattern,proto3" json:"GroupByPattern,omitempty"`
	StartTime      int64    `protobuf:"varint,9,opt,name=StartTime,proto3" json:"StartTime,omitempty"`
	EndTime        int64    `protobuf:"varint,10,opt,name=EndTime,proto3" json:"EndTime,omitempty"`
	Step           string   `protobuf:"bytes,11,opt,name=Step,proto3" json:"Step,omitempty"`
	TimestampField string   `protobuf:"bytes,12,opt,name=TimestampField,proto3" json:"TimestampField,omitempty"`
	AllowEmpty     bool     `protobuf:"varint,13,opt,name=AllowEmpty,proto3" json:"AllowEmpty,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportDefinition) Descriptor deprecated 

func (*ReportDefinition) Descriptor() ([]byte, []int)

Deprecated: Use ReportDefinition.ProtoReflect.Descriptor instead.

func (*ReportDefinition) GetAggregateFn 

func (x *ReportDefinition) GetAggregateFn() string

func (*ReportDefinition) GetAllowEmpty 

func (x *ReportDefinition) GetAllowEmpty() bool

func (*ReportDefinition) GetApplication 

func (x *ReportDefinition) GetApplication() string

func (*ReportDefinition) GetEndTime 

func (x *ReportDefinition) GetEndTime() int64

func (*ReportDefinition) GetExpression 

func (x *ReportDefinition) GetExpression() string

func (*ReportDefinition) GetGroupBy 

func (x *ReportDefinition) GetGroupBy() []string

func (*ReportDefinition) GetGroupByPattern 

func (x *ReportDefinition) GetGroupByPattern() []string

func (*ReportDefinition) GetNamespace 

func (x *ReportDefinition) GetNamespace() string

func (*ReportDefinition) GetQueryId 

func (x *ReportDefinition) GetQueryId() string

func (*ReportDefinition) GetStartTime 

func (x *ReportDefinition) GetStartTime() int64

func (*ReportDefinition) GetStep 

func (x *ReportDefinition) GetStep() string

func (*ReportDefinition) GetTimestampField 

func (x *ReportDefinition) GetTimestampField() string

func (*ReportDefinition) GetValueField 

func (x *ReportDefinition) GetValueField() string

func (*ReportDefinition) ProtoMessage 

func (*ReportDefinition) ProtoMessage()

func (*ReportDefinition) ProtoReflect 

func (x *ReportDefinition) ProtoReflect() protoreflect.Message

func (*ReportDefinition) Reset 

func (x *ReportDefinition) Reset()

func (*ReportDefinition) String 

func (x *ReportDefinition) String() string

type S3MetaDataDump 

type S3MetaDataDump struct {
	Intervals    map[string]*LocalMetadataItems `` /* 159-byte string literal not displayed */
	Destination  string                         `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	Namespace    string                         `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Key          string                         `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Val          string                         `protobuf:"bytes,5,opt,name=val,proto3" json:"val,omitempty"`
	MetadataType MetadataType                   `protobuf:"varint,6,opt,name=metadataType,proto3,enum=federation.MetadataType" json:"metadataType,omitempty"`
	Year         int64                          `protobuf:"varint,7,opt,name=year,proto3" json:"year,omitempty"`
	// contains filtered or unexported fields
}

S3MetaDataDump

func (*S3MetaDataDump) Descriptor deprecated 

func (*S3MetaDataDump) Descriptor() ([]byte, []int)

Deprecated: Use S3MetaDataDump.ProtoReflect.Descriptor instead.

func (*S3MetaDataDump) GetDestination 

func (x *S3MetaDataDump) GetDestination() string

func (*S3MetaDataDump) GetIntervals 

func (x *S3MetaDataDump) GetIntervals() map[string]*LocalMetadataItems

func (*S3MetaDataDump) GetKey 

func (x *S3MetaDataDump) GetKey() string

func (*S3MetaDataDump) GetMetadataType 

func (x *S3MetaDataDump) GetMetadataType() MetadataType

func (*S3MetaDataDump) GetNamespace 

func (x *S3MetaDataDump) GetNamespace() string

func (*S3MetaDataDump) GetVal 

func (x *S3MetaDataDump) GetVal() string

func (*S3MetaDataDump) GetYear 

func (x *S3MetaDataDump) GetYear() int64

func (*S3MetaDataDump) ProtoMessage 

func (*S3MetaDataDump) ProtoMessage()

func (*S3MetaDataDump) ProtoReflect 

func (x *S3MetaDataDump) ProtoReflect() protoreflect.Message

func (*S3MetaDataDump) Reset 

func (x *S3MetaDataDump) Reset()

func (*S3MetaDataDump) String 

func (x *S3MetaDataDump) String() string

type StreamDataFileResponse 

type StreamDataFileResponse struct {
	Lines []string `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamDataFileResponse) Descriptor deprecated 

func (*StreamDataFileResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamDataFileResponse.ProtoReflect.Descriptor instead.

func (*StreamDataFileResponse) GetLines 

func (x *StreamDataFileResponse) GetLines() []string

func (*StreamDataFileResponse) ProtoMessage 

func (*StreamDataFileResponse) ProtoMessage()

func (*StreamDataFileResponse) ProtoReflect 

func (x *StreamDataFileResponse) ProtoReflect() protoreflect.Message

func (*StreamDataFileResponse) Reset 

func (x *StreamDataFileResponse) Reset()

func (*StreamDataFileResponse) String 

func (x *StreamDataFileResponse) String() string

type StreamLocalFileRequest 

type StreamLocalFileRequest struct {
	FileName string                                   `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
	Params   map[string]*StreamLocalFileRequestFilter `` /* 153-byte string literal not displayed */
	QueryId  string                                   `protobuf:"bytes,3,opt,name=queryId,proto3" json:"queryId,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamLocalFileRequest) Descriptor deprecated 

func (*StreamLocalFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamLocalFileRequest.ProtoReflect.Descriptor instead.

func (*StreamLocalFileRequest) GetFileName 

func (x *StreamLocalFileRequest) GetFileName() string

func (*StreamLocalFileRequest) GetParams 

func (x *StreamLocalFileRequest) GetParams() map[string]*StreamLocalFileRequestFilter

func (*StreamLocalFileRequest) GetQueryId 

func (x *StreamLocalFileRequest) GetQueryId() string

func (*StreamLocalFileRequest) ProtoMessage 

func (*StreamLocalFileRequest) ProtoMessage()

func (*StreamLocalFileRequest) ProtoReflect 

func (x *StreamLocalFileRequest) ProtoReflect() protoreflect.Message

func (*StreamLocalFileRequest) Reset 

func (x *StreamLocalFileRequest) Reset()

func (*StreamLocalFileRequest) String 

func (x *StreamLocalFileRequest) String() string

type StreamLocalFileRequestFilter 

type StreamLocalFileRequestFilter struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamLocalFileRequestFilter) Descriptor deprecated 

func (*StreamLocalFileRequestFilter) Descriptor() ([]byte, []int)

Deprecated: Use StreamLocalFileRequestFilter.ProtoReflect.Descriptor instead.

func (*StreamLocalFileRequestFilter) GetValues 

func (x *StreamLocalFileRequestFilter) GetValues() []string

func (*StreamLocalFileRequestFilter) ProtoMessage 

func (*StreamLocalFileRequestFilter) ProtoMessage()

func (*StreamLocalFileRequestFilter) ProtoReflect 

func (x *StreamLocalFileRequestFilter) ProtoReflect() protoreflect.Message

func (*StreamLocalFileRequestFilter) Reset 

func (x *StreamLocalFileRequestFilter) Reset()

func (*StreamLocalFileRequestFilter) String 

func (x *StreamLocalFileRequestFilter) String() string

type StreamRemoteMetadataResponse 

type StreamRemoteMetadataResponse struct {
	LogStartTime int64    `protobuf:"varint,1,opt,name=logStartTime,proto3" json:"logStartTime,omitempty"`
	DataLocation []string `protobuf:"bytes,2,rep,name=dataLocation,proto3" json:"dataLocation,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRemoteMetadataResponse) Descriptor deprecated 

func (*StreamRemoteMetadataResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamRemoteMetadataResponse.ProtoReflect.Descriptor instead.

func (*StreamRemoteMetadataResponse) GetDataLocation 

func (x *StreamRemoteMetadataResponse) GetDataLocation() []string

func (*StreamRemoteMetadataResponse) GetLogStartTime 

func (x *StreamRemoteMetadataResponse) GetLogStartTime() int64

func (*StreamRemoteMetadataResponse) ProtoMessage 

func (*StreamRemoteMetadataResponse) ProtoMessage()

func (*StreamRemoteMetadataResponse) ProtoReflect 

func (x *StreamRemoteMetadataResponse) ProtoReflect() protoreflect.Message

func (*StreamRemoteMetadataResponse) Reset 

func (x *StreamRemoteMetadataResponse) Reset()

func (*StreamRemoteMetadataResponse) String 

func (x *StreamRemoteMetadataResponse) String() string

type StreamReportResultsRequest 

type StreamReportResultsRequest struct {
	FileName string                                   `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
	Params   map[string]*StreamLocalFileRequestFilter `` /* 153-byte string literal not displayed */
	QueryId  string                                   `protobuf:"bytes,3,opt,name=queryId,proto3" json:"queryId,omitempty"`
	Rd       *ReportDefinition                        `protobuf:"bytes,4,opt,name=rd,proto3" json:"rd,omitempty"`
	IntentID string                                   `protobuf:"bytes,11,opt,name=intentID,proto3" json:"intentID,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamReportResultsRequest) Descriptor deprecated 

func (*StreamReportResultsRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamReportResultsRequest.ProtoReflect.Descriptor instead.

func (*StreamReportResultsRequest) GetFileName 

func (x *StreamReportResultsRequest) GetFileName() string

func (*StreamReportResultsRequest) GetIntentID 

func (x *StreamReportResultsRequest) GetIntentID() string

func (*StreamReportResultsRequest) GetParams 

func (x *StreamReportResultsRequest) GetParams() map[string]*StreamLocalFileRequestFilter

func (*StreamReportResultsRequest) GetQueryId 

func (x *StreamReportResultsRequest) GetQueryId() string

func (*StreamReportResultsRequest) GetRd 

func (x *StreamReportResultsRequest) GetRd() *ReportDefinition

func (*StreamReportResultsRequest) ProtoMessage 

func (*StreamReportResultsRequest) ProtoMessage()

func (*StreamReportResultsRequest) ProtoReflect 

func (x *StreamReportResultsRequest) ProtoReflect() protoreflect.Message

func (*StreamReportResultsRequest) Reset 

func (x *StreamReportResultsRequest) Reset()

func (*StreamReportResultsRequest) String 

func (x *StreamReportResultsRequest) String() string

type UnimplementedFederationServer 

type UnimplementedFederationServer struct {
}

UnimplementedFederationServer can be embedded to have forward compatible implementations.

func (*UnimplementedFederationServer) GetFederations 

func (*UnimplementedFederationServer) GetFederations(context.Context, *emptypb.Empty) (*GetFederationsResponse, error)

func (*UnimplementedFederationServer) GetLocalMetadataItems 

func (*UnimplementedFederationServer) GetLocalMetadataItems(context.Context, *GetLocalMetadataItemRequest) (*GetLocalMetadataItemRequestResponse, error)

func (*UnimplementedFederationServer) Ping 

func (*UnimplementedFederationServer) Ping(context.Context, *emptypb.Empty) (*Pong, error)

func (*UnimplementedFederationServer) PostFederationObjects 

func (*UnimplementedFederationServer) PostFederationObjects(context.Context, *PostFederationObjectsRequest) (*PostFederationObjectsResponse, error)

func (*UnimplementedFederationServer) PostFederationStatus 

func (*UnimplementedFederationServer) PostFederationStatus(context.Context, *PostFederationStatusRequest) (*PostFederationStatusResponse, error)

func (*UnimplementedFederationServer) Replay 

func (*UnimplementedFederationServer) Replay(context.Context, *ReplayRequest) (*ReplyStats, error)

func (*UnimplementedFederationServer) StreamLocalFile 

func (*UnimplementedFederationServer) StreamLocalFile(*StreamLocalFileRequest, Federation_StreamLocalFileServer) error

func (*UnimplementedFederationServer) StreamRemoteMetadataItems 

func (*UnimplementedFederationServer) StreamRemoteMetadataItems(*GetRemoteMetadataRequest, Federation_StreamRemoteMetadataItemsServer) error

func (*UnimplementedFederationServer) StreamReportResults 

func (*UnimplementedFederationServer) StreamReportResults(*StreamReportResultsRequest, Federation_StreamReportResultsServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.