Documentation ¶
Overview ¶
Package ingestion_configsv1 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterIngestionConfigServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterIngestionConfigServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, ...) error
- func RegisterIngestionConfigServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterIngestionConfigServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, ...) error
- func RegisterIngestionConfigServiceServer(s grpc.ServiceRegistrar, srv IngestionConfigServiceServer)
- type ChannelConfig
- func (m *ChannelConfig) CloneMessageVT() proto.Message
- func (m *ChannelConfig) CloneVT() *ChannelConfig
- func (*ChannelConfig) Descriptor() ([]byte, []int)deprecated
- func (this *ChannelConfig) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ChannelConfig) EqualVT(that *ChannelConfig) bool
- func (x *ChannelConfig) GetBitFieldElements() []*v1.ChannelBitFieldElement
- func (x *ChannelConfig) GetComponent() string
- func (x *ChannelConfig) GetDataType() v1.ChannelDataType
- func (x *ChannelConfig) GetDescription() string
- func (x *ChannelConfig) GetEnumTypes() []*v1.ChannelEnumType
- func (x *ChannelConfig) GetName() string
- func (x *ChannelConfig) GetUnit() string
- func (m *ChannelConfig) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ChannelConfig) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *ChannelConfig) MarshalToVT(dAtA []byte) (int, error)
- func (m *ChannelConfig) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *ChannelConfig) MarshalVT() (dAtA []byte, err error)
- func (m *ChannelConfig) MarshalVTStrict() (dAtA []byte, err error)
- func (*ChannelConfig) ProtoMessage()
- func (x *ChannelConfig) ProtoReflect() protoreflect.Message
- func (x *ChannelConfig) Reset()
- func (m *ChannelConfig) SizeVT() (n int)
- func (x *ChannelConfig) String() string
- func (m *ChannelConfig) UnmarshalVT(dAtA []byte) error
- func (m *ChannelConfig) UnmarshalVTUnsafe(dAtA []byte) error
- type CreateIngestionConfigFlowsRequest
- func (m *CreateIngestionConfigFlowsRequest) CloneMessageVT() proto.Message
- func (m *CreateIngestionConfigFlowsRequest) CloneVT() *CreateIngestionConfigFlowsRequest
- func (*CreateIngestionConfigFlowsRequest) Descriptor() ([]byte, []int)deprecated
- func (this *CreateIngestionConfigFlowsRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *CreateIngestionConfigFlowsRequest) EqualVT(that *CreateIngestionConfigFlowsRequest) bool
- func (x *CreateIngestionConfigFlowsRequest) GetFlows() []*FlowConfig
- func (x *CreateIngestionConfigFlowsRequest) GetIngestionConfigId() string
- func (m *CreateIngestionConfigFlowsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigFlowsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigFlowsRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigFlowsRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigFlowsRequest) MarshalVT() (dAtA []byte, err error)
- func (m *CreateIngestionConfigFlowsRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*CreateIngestionConfigFlowsRequest) ProtoMessage()
- func (x *CreateIngestionConfigFlowsRequest) ProtoReflect() protoreflect.Message
- func (x *CreateIngestionConfigFlowsRequest) Reset()
- func (m *CreateIngestionConfigFlowsRequest) SizeVT() (n int)
- func (x *CreateIngestionConfigFlowsRequest) String() string
- func (m *CreateIngestionConfigFlowsRequest) UnmarshalVT(dAtA []byte) error
- func (m *CreateIngestionConfigFlowsRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type CreateIngestionConfigFlowsResponse
- func (m *CreateIngestionConfigFlowsResponse) CloneMessageVT() proto.Message
- func (m *CreateIngestionConfigFlowsResponse) CloneVT() *CreateIngestionConfigFlowsResponse
- func (*CreateIngestionConfigFlowsResponse) Descriptor() ([]byte, []int)deprecated
- func (this *CreateIngestionConfigFlowsResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *CreateIngestionConfigFlowsResponse) EqualVT(that *CreateIngestionConfigFlowsResponse) bool
- func (m *CreateIngestionConfigFlowsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigFlowsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigFlowsResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigFlowsResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigFlowsResponse) MarshalVT() (dAtA []byte, err error)
- func (m *CreateIngestionConfigFlowsResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*CreateIngestionConfigFlowsResponse) ProtoMessage()
- func (x *CreateIngestionConfigFlowsResponse) ProtoReflect() protoreflect.Message
- func (x *CreateIngestionConfigFlowsResponse) Reset()
- func (m *CreateIngestionConfigFlowsResponse) SizeVT() (n int)
- func (x *CreateIngestionConfigFlowsResponse) String() string
- func (m *CreateIngestionConfigFlowsResponse) UnmarshalVT(dAtA []byte) error
- func (m *CreateIngestionConfigFlowsResponse) UnmarshalVTUnsafe(dAtA []byte) error
- type CreateIngestionConfigRequest
- func (m *CreateIngestionConfigRequest) CloneMessageVT() proto.Message
- func (m *CreateIngestionConfigRequest) CloneVT() *CreateIngestionConfigRequest
- func (*CreateIngestionConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (this *CreateIngestionConfigRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *CreateIngestionConfigRequest) EqualVT(that *CreateIngestionConfigRequest) bool
- func (x *CreateIngestionConfigRequest) GetAssetName() string
- func (x *CreateIngestionConfigRequest) GetClientKey() string
- func (x *CreateIngestionConfigRequest) GetFlows() []*FlowConfig
- func (x *CreateIngestionConfigRequest) GetOrganizationId() string
- func (m *CreateIngestionConfigRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigRequest) MarshalVT() (dAtA []byte, err error)
- func (m *CreateIngestionConfigRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*CreateIngestionConfigRequest) ProtoMessage()
- func (x *CreateIngestionConfigRequest) ProtoReflect() protoreflect.Message
- func (x *CreateIngestionConfigRequest) Reset()
- func (m *CreateIngestionConfigRequest) SizeVT() (n int)
- func (x *CreateIngestionConfigRequest) String() string
- func (m *CreateIngestionConfigRequest) UnmarshalVT(dAtA []byte) error
- func (m *CreateIngestionConfigRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type CreateIngestionConfigResponse
- func (m *CreateIngestionConfigResponse) CloneMessageVT() proto.Message
- func (m *CreateIngestionConfigResponse) CloneVT() *CreateIngestionConfigResponse
- func (*CreateIngestionConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (this *CreateIngestionConfigResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *CreateIngestionConfigResponse) EqualVT(that *CreateIngestionConfigResponse) bool
- func (x *CreateIngestionConfigResponse) GetIngestionConfig() *IngestionConfig
- func (m *CreateIngestionConfigResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *CreateIngestionConfigResponse) MarshalVT() (dAtA []byte, err error)
- func (m *CreateIngestionConfigResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*CreateIngestionConfigResponse) ProtoMessage()
- func (x *CreateIngestionConfigResponse) ProtoReflect() protoreflect.Message
- func (x *CreateIngestionConfigResponse) Reset()
- func (m *CreateIngestionConfigResponse) SizeVT() (n int)
- func (x *CreateIngestionConfigResponse) String() string
- func (m *CreateIngestionConfigResponse) UnmarshalVT(dAtA []byte) error
- func (m *CreateIngestionConfigResponse) UnmarshalVTUnsafe(dAtA []byte) error
- type FlowConfig
- func (m *FlowConfig) CloneMessageVT() proto.Message
- func (m *FlowConfig) CloneVT() *FlowConfig
- func (*FlowConfig) Descriptor() ([]byte, []int)deprecated
- func (this *FlowConfig) EqualMessageVT(thatMsg proto.Message) bool
- func (this *FlowConfig) EqualVT(that *FlowConfig) bool
- func (x *FlowConfig) GetChannels() []*ChannelConfig
- func (x *FlowConfig) GetName() string
- func (m *FlowConfig) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *FlowConfig) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *FlowConfig) MarshalToVT(dAtA []byte) (int, error)
- func (m *FlowConfig) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *FlowConfig) MarshalVT() (dAtA []byte, err error)
- func (m *FlowConfig) MarshalVTStrict() (dAtA []byte, err error)
- func (*FlowConfig) ProtoMessage()
- func (x *FlowConfig) ProtoReflect() protoreflect.Message
- func (x *FlowConfig) Reset()
- func (m *FlowConfig) SizeVT() (n int)
- func (x *FlowConfig) String() string
- func (m *FlowConfig) UnmarshalVT(dAtA []byte) error
- func (m *FlowConfig) UnmarshalVTUnsafe(dAtA []byte) error
- type GetIngestionConfigRequest
- func (m *GetIngestionConfigRequest) CloneMessageVT() proto.Message
- func (m *GetIngestionConfigRequest) CloneVT() *GetIngestionConfigRequest
- func (*GetIngestionConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (this *GetIngestionConfigRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *GetIngestionConfigRequest) EqualVT(that *GetIngestionConfigRequest) bool
- func (x *GetIngestionConfigRequest) GetIngestionConfigId() string
- func (m *GetIngestionConfigRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetIngestionConfigRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *GetIngestionConfigRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetIngestionConfigRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *GetIngestionConfigRequest) MarshalVT() (dAtA []byte, err error)
- func (m *GetIngestionConfigRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*GetIngestionConfigRequest) ProtoMessage()
- func (x *GetIngestionConfigRequest) ProtoReflect() protoreflect.Message
- func (x *GetIngestionConfigRequest) Reset()
- func (m *GetIngestionConfigRequest) SizeVT() (n int)
- func (x *GetIngestionConfigRequest) String() string
- func (m *GetIngestionConfigRequest) UnmarshalVT(dAtA []byte) error
- func (m *GetIngestionConfigRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type GetIngestionConfigResponse
- func (m *GetIngestionConfigResponse) CloneMessageVT() proto.Message
- func (m *GetIngestionConfigResponse) CloneVT() *GetIngestionConfigResponse
- func (*GetIngestionConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (this *GetIngestionConfigResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *GetIngestionConfigResponse) EqualVT(that *GetIngestionConfigResponse) bool
- func (x *GetIngestionConfigResponse) GetIngestionConfig() *IngestionConfig
- func (m *GetIngestionConfigResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetIngestionConfigResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *GetIngestionConfigResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetIngestionConfigResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *GetIngestionConfigResponse) MarshalVT() (dAtA []byte, err error)
- func (m *GetIngestionConfigResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*GetIngestionConfigResponse) ProtoMessage()
- func (x *GetIngestionConfigResponse) ProtoReflect() protoreflect.Message
- func (x *GetIngestionConfigResponse) Reset()
- func (m *GetIngestionConfigResponse) SizeVT() (n int)
- func (x *GetIngestionConfigResponse) String() string
- func (m *GetIngestionConfigResponse) UnmarshalVT(dAtA []byte) error
- func (m *GetIngestionConfigResponse) UnmarshalVTUnsafe(dAtA []byte) error
- type IngestionConfig
- func (m *IngestionConfig) CloneMessageVT() proto.Message
- func (m *IngestionConfig) CloneVT() *IngestionConfig
- func (*IngestionConfig) Descriptor() ([]byte, []int)deprecated
- func (this *IngestionConfig) EqualMessageVT(thatMsg proto.Message) bool
- func (this *IngestionConfig) EqualVT(that *IngestionConfig) bool
- func (x *IngestionConfig) GetAssetId() string
- func (x *IngestionConfig) GetClientKey() string
- func (x *IngestionConfig) GetIngestionConfigId() string
- func (m *IngestionConfig) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *IngestionConfig) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *IngestionConfig) MarshalToVT(dAtA []byte) (int, error)
- func (m *IngestionConfig) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *IngestionConfig) MarshalVT() (dAtA []byte, err error)
- func (m *IngestionConfig) MarshalVTStrict() (dAtA []byte, err error)
- func (*IngestionConfig) ProtoMessage()
- func (x *IngestionConfig) ProtoReflect() protoreflect.Message
- func (x *IngestionConfig) Reset()
- func (m *IngestionConfig) SizeVT() (n int)
- func (x *IngestionConfig) String() string
- func (m *IngestionConfig) UnmarshalVT(dAtA []byte) error
- func (m *IngestionConfig) UnmarshalVTUnsafe(dAtA []byte) error
- type IngestionConfigServiceClient
- type IngestionConfigServiceServer
- type ListIngestionConfigFlowsRequest
- func (m *ListIngestionConfigFlowsRequest) CloneMessageVT() proto.Message
- func (m *ListIngestionConfigFlowsRequest) CloneVT() *ListIngestionConfigFlowsRequest
- func (*ListIngestionConfigFlowsRequest) Descriptor() ([]byte, []int)deprecated
- func (this *ListIngestionConfigFlowsRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ListIngestionConfigFlowsRequest) EqualVT(that *ListIngestionConfigFlowsRequest) bool
- func (x *ListIngestionConfigFlowsRequest) GetFilter() string
- func (x *ListIngestionConfigFlowsRequest) GetIngestionConfigId() string
- func (x *ListIngestionConfigFlowsRequest) GetPageSize() uint32
- func (x *ListIngestionConfigFlowsRequest) GetPageToken() string
- func (m *ListIngestionConfigFlowsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListIngestionConfigFlowsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *ListIngestionConfigFlowsRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListIngestionConfigFlowsRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *ListIngestionConfigFlowsRequest) MarshalVT() (dAtA []byte, err error)
- func (m *ListIngestionConfigFlowsRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*ListIngestionConfigFlowsRequest) ProtoMessage()
- func (x *ListIngestionConfigFlowsRequest) ProtoReflect() protoreflect.Message
- func (x *ListIngestionConfigFlowsRequest) Reset()
- func (m *ListIngestionConfigFlowsRequest) SizeVT() (n int)
- func (x *ListIngestionConfigFlowsRequest) String() string
- func (m *ListIngestionConfigFlowsRequest) UnmarshalVT(dAtA []byte) error
- func (m *ListIngestionConfigFlowsRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type ListIngestionConfigFlowsResponse
- func (m *ListIngestionConfigFlowsResponse) CloneMessageVT() proto.Message
- func (m *ListIngestionConfigFlowsResponse) CloneVT() *ListIngestionConfigFlowsResponse
- func (*ListIngestionConfigFlowsResponse) Descriptor() ([]byte, []int)deprecated
- func (this *ListIngestionConfigFlowsResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ListIngestionConfigFlowsResponse) EqualVT(that *ListIngestionConfigFlowsResponse) bool
- func (x *ListIngestionConfigFlowsResponse) GetFlows() []*FlowConfig
- func (x *ListIngestionConfigFlowsResponse) GetNextPageToken() string
- func (m *ListIngestionConfigFlowsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListIngestionConfigFlowsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *ListIngestionConfigFlowsResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListIngestionConfigFlowsResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *ListIngestionConfigFlowsResponse) MarshalVT() (dAtA []byte, err error)
- func (m *ListIngestionConfigFlowsResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*ListIngestionConfigFlowsResponse) ProtoMessage()
- func (x *ListIngestionConfigFlowsResponse) ProtoReflect() protoreflect.Message
- func (x *ListIngestionConfigFlowsResponse) Reset()
- func (m *ListIngestionConfigFlowsResponse) SizeVT() (n int)
- func (x *ListIngestionConfigFlowsResponse) String() string
- func (m *ListIngestionConfigFlowsResponse) UnmarshalVT(dAtA []byte) error
- func (m *ListIngestionConfigFlowsResponse) UnmarshalVTUnsafe(dAtA []byte) error
- type ListIngestionConfigsRequest
- func (m *ListIngestionConfigsRequest) CloneMessageVT() proto.Message
- func (m *ListIngestionConfigsRequest) CloneVT() *ListIngestionConfigsRequest
- func (*ListIngestionConfigsRequest) Descriptor() ([]byte, []int)deprecated
- func (this *ListIngestionConfigsRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ListIngestionConfigsRequest) EqualVT(that *ListIngestionConfigsRequest) bool
- func (x *ListIngestionConfigsRequest) GetFilter() string
- func (x *ListIngestionConfigsRequest) GetPageSize() uint32
- func (x *ListIngestionConfigsRequest) GetPageToken() string
- func (m *ListIngestionConfigsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListIngestionConfigsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *ListIngestionConfigsRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListIngestionConfigsRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *ListIngestionConfigsRequest) MarshalVT() (dAtA []byte, err error)
- func (m *ListIngestionConfigsRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*ListIngestionConfigsRequest) ProtoMessage()
- func (x *ListIngestionConfigsRequest) ProtoReflect() protoreflect.Message
- func (x *ListIngestionConfigsRequest) Reset()
- func (m *ListIngestionConfigsRequest) SizeVT() (n int)
- func (x *ListIngestionConfigsRequest) String() string
- func (m *ListIngestionConfigsRequest) UnmarshalVT(dAtA []byte) error
- func (m *ListIngestionConfigsRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type ListIngestionConfigsResponse
- func (m *ListIngestionConfigsResponse) CloneMessageVT() proto.Message
- func (m *ListIngestionConfigsResponse) CloneVT() *ListIngestionConfigsResponse
- func (*ListIngestionConfigsResponse) Descriptor() ([]byte, []int)deprecated
- func (this *ListIngestionConfigsResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ListIngestionConfigsResponse) EqualVT(that *ListIngestionConfigsResponse) bool
- func (x *ListIngestionConfigsResponse) GetIngestionConfigs() []*IngestionConfig
- func (x *ListIngestionConfigsResponse) GetNextPageToken() string
- func (m *ListIngestionConfigsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListIngestionConfigsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *ListIngestionConfigsResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListIngestionConfigsResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *ListIngestionConfigsResponse) MarshalVT() (dAtA []byte, err error)
- func (m *ListIngestionConfigsResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*ListIngestionConfigsResponse) ProtoMessage()
- func (x *ListIngestionConfigsResponse) ProtoReflect() protoreflect.Message
- func (x *ListIngestionConfigsResponse) Reset()
- func (m *ListIngestionConfigsResponse) SizeVT() (n int)
- func (x *ListIngestionConfigsResponse) String() string
- func (m *ListIngestionConfigsResponse) UnmarshalVT(dAtA []byte) error
- func (m *ListIngestionConfigsResponse) UnmarshalVTUnsafe(dAtA []byte) error
- type UnimplementedIngestionConfigServiceServer
- func (UnimplementedIngestionConfigServiceServer) CreateIngestionConfig(context.Context, *CreateIngestionConfigRequest) (*CreateIngestionConfigResponse, error)
- func (UnimplementedIngestionConfigServiceServer) CreateIngestionConfigFlows(context.Context, *CreateIngestionConfigFlowsRequest) (*CreateIngestionConfigFlowsResponse, error)
- func (UnimplementedIngestionConfigServiceServer) GetIngestionConfig(context.Context, *GetIngestionConfigRequest) (*GetIngestionConfigResponse, error)
- func (UnimplementedIngestionConfigServiceServer) ListIngestionConfigFlows(context.Context, *ListIngestionConfigFlowsRequest) (*ListIngestionConfigFlowsResponse, error)
- func (UnimplementedIngestionConfigServiceServer) ListIngestionConfigs(context.Context, *ListIngestionConfigsRequest) (*ListIngestionConfigsResponse, error)
- type UnsafeIngestionConfigServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_sift_ingestion_configs_v1_ingestion_configs_proto protoreflect.FileDescriptor
var IngestionConfigService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sift.ingestion_configs.v1.IngestionConfigService", HandlerType: (*IngestionConfigServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetIngestionConfig", Handler: _IngestionConfigService_GetIngestionConfig_Handler, }, { MethodName: "CreateIngestionConfig", Handler: _IngestionConfigService_CreateIngestionConfig_Handler, }, { MethodName: "ListIngestionConfigs", Handler: _IngestionConfigService_ListIngestionConfigs_Handler, }, { MethodName: "CreateIngestionConfigFlows", Handler: _IngestionConfigService_CreateIngestionConfigFlows_Handler, }, { MethodName: "ListIngestionConfigFlows", Handler: _IngestionConfigService_ListIngestionConfigFlows_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "sift/ingestion_configs/v1/ingestion_configs.proto", }
IngestionConfigService_ServiceDesc is the grpc.ServiceDesc for IngestionConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterIngestionConfigServiceHandler ¶
func RegisterIngestionConfigServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterIngestionConfigServiceHandler registers the http handlers for service IngestionConfigService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterIngestionConfigServiceHandlerClient ¶
func RegisterIngestionConfigServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client IngestionConfigServiceClient) error
RegisterIngestionConfigServiceHandlerClient registers the http handlers for service IngestionConfigService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "IngestionConfigServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "IngestionConfigServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "IngestionConfigServiceClient" to call the correct interceptors.
func RegisterIngestionConfigServiceHandlerFromEndpoint ¶
func RegisterIngestionConfigServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterIngestionConfigServiceHandlerFromEndpoint is same as RegisterIngestionConfigServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterIngestionConfigServiceHandlerServer ¶
func RegisterIngestionConfigServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server IngestionConfigServiceServer) error
RegisterIngestionConfigServiceHandlerServer registers the http handlers for service IngestionConfigService to "mux". UnaryRPC :call IngestionConfigServiceServer 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 RegisterIngestionConfigServiceHandlerFromEndpoint instead.
func RegisterIngestionConfigServiceServer ¶
func RegisterIngestionConfigServiceServer(s grpc.ServiceRegistrar, srv IngestionConfigServiceServer)
Types ¶
type ChannelConfig ¶
type ChannelConfig struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Component string `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"` Unit string `protobuf:"bytes,3,opt,name=unit,proto3" json:"unit,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` DataType v1.ChannelDataType `` /* 127-byte string literal not displayed */ EnumTypes []*v1.ChannelEnumType `protobuf:"bytes,6,rep,name=enum_types,json=enumTypes,proto3" json:"enum_types,omitempty"` BitFieldElements []*v1.ChannelBitFieldElement `protobuf:"bytes,7,rep,name=bit_field_elements,json=bitFieldElements,proto3" json:"bit_field_elements,omitempty"` // contains filtered or unexported fields }
func (*ChannelConfig) CloneMessageVT ¶
func (m *ChannelConfig) CloneMessageVT() proto.Message
func (*ChannelConfig) CloneVT ¶
func (m *ChannelConfig) CloneVT() *ChannelConfig
func (*ChannelConfig) Descriptor
deprecated
func (*ChannelConfig) Descriptor() ([]byte, []int)
Deprecated: Use ChannelConfig.ProtoReflect.Descriptor instead.
func (*ChannelConfig) EqualMessageVT ¶
func (this *ChannelConfig) EqualMessageVT(thatMsg proto.Message) bool
func (*ChannelConfig) EqualVT ¶
func (this *ChannelConfig) EqualVT(that *ChannelConfig) bool
func (*ChannelConfig) GetBitFieldElements ¶
func (x *ChannelConfig) GetBitFieldElements() []*v1.ChannelBitFieldElement
func (*ChannelConfig) GetComponent ¶
func (x *ChannelConfig) GetComponent() string
func (*ChannelConfig) GetDataType ¶
func (x *ChannelConfig) GetDataType() v1.ChannelDataType
func (*ChannelConfig) GetDescription ¶
func (x *ChannelConfig) GetDescription() string
func (*ChannelConfig) GetEnumTypes ¶
func (x *ChannelConfig) GetEnumTypes() []*v1.ChannelEnumType
func (*ChannelConfig) GetName ¶
func (x *ChannelConfig) GetName() string
func (*ChannelConfig) GetUnit ¶
func (x *ChannelConfig) GetUnit() string
func (*ChannelConfig) MarshalToSizedBufferVT ¶
func (m *ChannelConfig) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ChannelConfig) MarshalToSizedBufferVTStrict ¶
func (m *ChannelConfig) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*ChannelConfig) MarshalToVT ¶
func (m *ChannelConfig) MarshalToVT(dAtA []byte) (int, error)
func (*ChannelConfig) MarshalToVTStrict ¶
func (m *ChannelConfig) MarshalToVTStrict(dAtA []byte) (int, error)
func (*ChannelConfig) MarshalVT ¶
func (m *ChannelConfig) MarshalVT() (dAtA []byte, err error)
func (*ChannelConfig) MarshalVTStrict ¶
func (m *ChannelConfig) MarshalVTStrict() (dAtA []byte, err error)
func (*ChannelConfig) ProtoMessage ¶
func (*ChannelConfig) ProtoMessage()
func (*ChannelConfig) ProtoReflect ¶
func (x *ChannelConfig) ProtoReflect() protoreflect.Message
func (*ChannelConfig) Reset ¶
func (x *ChannelConfig) Reset()
func (*ChannelConfig) SizeVT ¶
func (m *ChannelConfig) SizeVT() (n int)
func (*ChannelConfig) String ¶
func (x *ChannelConfig) String() string
func (*ChannelConfig) UnmarshalVT ¶
func (m *ChannelConfig) UnmarshalVT(dAtA []byte) error
func (*ChannelConfig) UnmarshalVTUnsafe ¶
func (m *ChannelConfig) UnmarshalVTUnsafe(dAtA []byte) error
type CreateIngestionConfigFlowsRequest ¶
type CreateIngestionConfigFlowsRequest struct { IngestionConfigId string `protobuf:"bytes,1,opt,name=ingestion_config_id,json=ingestionConfigId,proto3" json:"ingestion_config_id,omitempty"` // These flows must have unique names. If you try to send a flow with a name that already exists for an ingestion config, it will return an error. Flows []*FlowConfig `protobuf:"bytes,2,rep,name=flows,proto3" json:"flows,omitempty"` // contains filtered or unexported fields }
The request for a call to `IngestionConfigService_CreateIngestionConfigFlows` to create ingestion config flows.
func (*CreateIngestionConfigFlowsRequest) CloneMessageVT ¶
func (m *CreateIngestionConfigFlowsRequest) CloneMessageVT() proto.Message
func (*CreateIngestionConfigFlowsRequest) CloneVT ¶
func (m *CreateIngestionConfigFlowsRequest) CloneVT() *CreateIngestionConfigFlowsRequest
func (*CreateIngestionConfigFlowsRequest) Descriptor
deprecated
func (*CreateIngestionConfigFlowsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateIngestionConfigFlowsRequest.ProtoReflect.Descriptor instead.
func (*CreateIngestionConfigFlowsRequest) EqualMessageVT ¶
func (this *CreateIngestionConfigFlowsRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*CreateIngestionConfigFlowsRequest) EqualVT ¶
func (this *CreateIngestionConfigFlowsRequest) EqualVT(that *CreateIngestionConfigFlowsRequest) bool
func (*CreateIngestionConfigFlowsRequest) GetFlows ¶
func (x *CreateIngestionConfigFlowsRequest) GetFlows() []*FlowConfig
func (*CreateIngestionConfigFlowsRequest) GetIngestionConfigId ¶
func (x *CreateIngestionConfigFlowsRequest) GetIngestionConfigId() string
func (*CreateIngestionConfigFlowsRequest) MarshalToSizedBufferVT ¶
func (m *CreateIngestionConfigFlowsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateIngestionConfigFlowsRequest) MarshalToSizedBufferVTStrict ¶
func (m *CreateIngestionConfigFlowsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*CreateIngestionConfigFlowsRequest) MarshalToVT ¶
func (m *CreateIngestionConfigFlowsRequest) MarshalToVT(dAtA []byte) (int, error)
func (*CreateIngestionConfigFlowsRequest) MarshalToVTStrict ¶
func (m *CreateIngestionConfigFlowsRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*CreateIngestionConfigFlowsRequest) MarshalVT ¶
func (m *CreateIngestionConfigFlowsRequest) MarshalVT() (dAtA []byte, err error)
func (*CreateIngestionConfigFlowsRequest) MarshalVTStrict ¶
func (m *CreateIngestionConfigFlowsRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*CreateIngestionConfigFlowsRequest) ProtoMessage ¶
func (*CreateIngestionConfigFlowsRequest) ProtoMessage()
func (*CreateIngestionConfigFlowsRequest) ProtoReflect ¶
func (x *CreateIngestionConfigFlowsRequest) ProtoReflect() protoreflect.Message
func (*CreateIngestionConfigFlowsRequest) Reset ¶
func (x *CreateIngestionConfigFlowsRequest) Reset()
func (*CreateIngestionConfigFlowsRequest) SizeVT ¶
func (m *CreateIngestionConfigFlowsRequest) SizeVT() (n int)
func (*CreateIngestionConfigFlowsRequest) String ¶
func (x *CreateIngestionConfigFlowsRequest) String() string
func (*CreateIngestionConfigFlowsRequest) UnmarshalVT ¶
func (m *CreateIngestionConfigFlowsRequest) UnmarshalVT(dAtA []byte) error
func (*CreateIngestionConfigFlowsRequest) UnmarshalVTUnsafe ¶
func (m *CreateIngestionConfigFlowsRequest) UnmarshalVTUnsafe(dAtA []byte) error
type CreateIngestionConfigFlowsResponse ¶
type CreateIngestionConfigFlowsResponse struct {
// contains filtered or unexported fields
}
The result of a call to `IngestionConfigService_CreateIngestionConfigFlows`.
func (*CreateIngestionConfigFlowsResponse) CloneMessageVT ¶
func (m *CreateIngestionConfigFlowsResponse) CloneMessageVT() proto.Message
func (*CreateIngestionConfigFlowsResponse) CloneVT ¶
func (m *CreateIngestionConfigFlowsResponse) CloneVT() *CreateIngestionConfigFlowsResponse
func (*CreateIngestionConfigFlowsResponse) Descriptor
deprecated
func (*CreateIngestionConfigFlowsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateIngestionConfigFlowsResponse.ProtoReflect.Descriptor instead.
func (*CreateIngestionConfigFlowsResponse) EqualMessageVT ¶
func (this *CreateIngestionConfigFlowsResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*CreateIngestionConfigFlowsResponse) EqualVT ¶
func (this *CreateIngestionConfigFlowsResponse) EqualVT(that *CreateIngestionConfigFlowsResponse) bool
func (*CreateIngestionConfigFlowsResponse) MarshalToSizedBufferVT ¶
func (m *CreateIngestionConfigFlowsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateIngestionConfigFlowsResponse) MarshalToSizedBufferVTStrict ¶
func (m *CreateIngestionConfigFlowsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*CreateIngestionConfigFlowsResponse) MarshalToVT ¶
func (m *CreateIngestionConfigFlowsResponse) MarshalToVT(dAtA []byte) (int, error)
func (*CreateIngestionConfigFlowsResponse) MarshalToVTStrict ¶
func (m *CreateIngestionConfigFlowsResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*CreateIngestionConfigFlowsResponse) MarshalVT ¶
func (m *CreateIngestionConfigFlowsResponse) MarshalVT() (dAtA []byte, err error)
func (*CreateIngestionConfigFlowsResponse) MarshalVTStrict ¶
func (m *CreateIngestionConfigFlowsResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*CreateIngestionConfigFlowsResponse) ProtoMessage ¶
func (*CreateIngestionConfigFlowsResponse) ProtoMessage()
func (*CreateIngestionConfigFlowsResponse) ProtoReflect ¶
func (x *CreateIngestionConfigFlowsResponse) ProtoReflect() protoreflect.Message
func (*CreateIngestionConfigFlowsResponse) Reset ¶
func (x *CreateIngestionConfigFlowsResponse) Reset()
func (*CreateIngestionConfigFlowsResponse) SizeVT ¶
func (m *CreateIngestionConfigFlowsResponse) SizeVT() (n int)
func (*CreateIngestionConfigFlowsResponse) String ¶
func (x *CreateIngestionConfigFlowsResponse) String() string
func (*CreateIngestionConfigFlowsResponse) UnmarshalVT ¶
func (m *CreateIngestionConfigFlowsResponse) UnmarshalVT(dAtA []byte) error
func (*CreateIngestionConfigFlowsResponse) UnmarshalVTUnsafe ¶
func (m *CreateIngestionConfigFlowsResponse) UnmarshalVTUnsafe(dAtA []byte) error
type CreateIngestionConfigRequest ¶
type CreateIngestionConfigRequest struct { AssetName string `protobuf:"bytes,1,opt,name=asset_name,json=assetName,proto3" json:"asset_name,omitempty"` Flows []*FlowConfig `protobuf:"bytes,2,rep,name=flows,proto3" json:"flows,omitempty"` OrganizationId string `protobuf:"bytes,3,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"` // The `client_key` field is a user-defined string you can supply to uniquely identify // an ingestion config (and retrieve it via `GetIngestionConfig`). // An error is returned if you try to create an ingestion config with a // client_key that already exists. ClientKey string `protobuf:"bytes,4,opt,name=client_key,json=clientKey,proto3" json:"client_key,omitempty"` // contains filtered or unexported fields }
The request for a call to `IngestionConfigService_ListIngestionConfigs` to retrieve ingestion configs.
func (*CreateIngestionConfigRequest) CloneMessageVT ¶
func (m *CreateIngestionConfigRequest) CloneMessageVT() proto.Message
func (*CreateIngestionConfigRequest) CloneVT ¶
func (m *CreateIngestionConfigRequest) CloneVT() *CreateIngestionConfigRequest
func (*CreateIngestionConfigRequest) Descriptor
deprecated
func (*CreateIngestionConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateIngestionConfigRequest.ProtoReflect.Descriptor instead.
func (*CreateIngestionConfigRequest) EqualMessageVT ¶
func (this *CreateIngestionConfigRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*CreateIngestionConfigRequest) EqualVT ¶
func (this *CreateIngestionConfigRequest) EqualVT(that *CreateIngestionConfigRequest) bool
func (*CreateIngestionConfigRequest) GetAssetName ¶
func (x *CreateIngestionConfigRequest) GetAssetName() string
func (*CreateIngestionConfigRequest) GetClientKey ¶
func (x *CreateIngestionConfigRequest) GetClientKey() string
func (*CreateIngestionConfigRequest) GetFlows ¶
func (x *CreateIngestionConfigRequest) GetFlows() []*FlowConfig
func (*CreateIngestionConfigRequest) GetOrganizationId ¶
func (x *CreateIngestionConfigRequest) GetOrganizationId() string
func (*CreateIngestionConfigRequest) MarshalToSizedBufferVT ¶
func (m *CreateIngestionConfigRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateIngestionConfigRequest) MarshalToSizedBufferVTStrict ¶
func (m *CreateIngestionConfigRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*CreateIngestionConfigRequest) MarshalToVT ¶
func (m *CreateIngestionConfigRequest) MarshalToVT(dAtA []byte) (int, error)
func (*CreateIngestionConfigRequest) MarshalToVTStrict ¶
func (m *CreateIngestionConfigRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*CreateIngestionConfigRequest) MarshalVT ¶
func (m *CreateIngestionConfigRequest) MarshalVT() (dAtA []byte, err error)
func (*CreateIngestionConfigRequest) MarshalVTStrict ¶
func (m *CreateIngestionConfigRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*CreateIngestionConfigRequest) ProtoMessage ¶
func (*CreateIngestionConfigRequest) ProtoMessage()
func (*CreateIngestionConfigRequest) ProtoReflect ¶
func (x *CreateIngestionConfigRequest) ProtoReflect() protoreflect.Message
func (*CreateIngestionConfigRequest) Reset ¶
func (x *CreateIngestionConfigRequest) Reset()
func (*CreateIngestionConfigRequest) SizeVT ¶
func (m *CreateIngestionConfigRequest) SizeVT() (n int)
func (*CreateIngestionConfigRequest) String ¶
func (x *CreateIngestionConfigRequest) String() string
func (*CreateIngestionConfigRequest) UnmarshalVT ¶
func (m *CreateIngestionConfigRequest) UnmarshalVT(dAtA []byte) error
func (*CreateIngestionConfigRequest) UnmarshalVTUnsafe ¶
func (m *CreateIngestionConfigRequest) UnmarshalVTUnsafe(dAtA []byte) error
type CreateIngestionConfigResponse ¶
type CreateIngestionConfigResponse struct { IngestionConfig *IngestionConfig `protobuf:"bytes,1,opt,name=ingestion_config,json=ingestionConfig,proto3" json:"ingestion_config,omitempty"` // contains filtered or unexported fields }
The result of a call to `IngestionConfigService_CreateIngestionConfig`.
func (*CreateIngestionConfigResponse) CloneMessageVT ¶
func (m *CreateIngestionConfigResponse) CloneMessageVT() proto.Message
func (*CreateIngestionConfigResponse) CloneVT ¶
func (m *CreateIngestionConfigResponse) CloneVT() *CreateIngestionConfigResponse
func (*CreateIngestionConfigResponse) Descriptor
deprecated
func (*CreateIngestionConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateIngestionConfigResponse.ProtoReflect.Descriptor instead.
func (*CreateIngestionConfigResponse) EqualMessageVT ¶
func (this *CreateIngestionConfigResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*CreateIngestionConfigResponse) EqualVT ¶
func (this *CreateIngestionConfigResponse) EqualVT(that *CreateIngestionConfigResponse) bool
func (*CreateIngestionConfigResponse) GetIngestionConfig ¶
func (x *CreateIngestionConfigResponse) GetIngestionConfig() *IngestionConfig
func (*CreateIngestionConfigResponse) MarshalToSizedBufferVT ¶
func (m *CreateIngestionConfigResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateIngestionConfigResponse) MarshalToSizedBufferVTStrict ¶
func (m *CreateIngestionConfigResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*CreateIngestionConfigResponse) MarshalToVT ¶
func (m *CreateIngestionConfigResponse) MarshalToVT(dAtA []byte) (int, error)
func (*CreateIngestionConfigResponse) MarshalToVTStrict ¶
func (m *CreateIngestionConfigResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*CreateIngestionConfigResponse) MarshalVT ¶
func (m *CreateIngestionConfigResponse) MarshalVT() (dAtA []byte, err error)
func (*CreateIngestionConfigResponse) MarshalVTStrict ¶
func (m *CreateIngestionConfigResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*CreateIngestionConfigResponse) ProtoMessage ¶
func (*CreateIngestionConfigResponse) ProtoMessage()
func (*CreateIngestionConfigResponse) ProtoReflect ¶
func (x *CreateIngestionConfigResponse) ProtoReflect() protoreflect.Message
func (*CreateIngestionConfigResponse) Reset ¶
func (x *CreateIngestionConfigResponse) Reset()
func (*CreateIngestionConfigResponse) SizeVT ¶
func (m *CreateIngestionConfigResponse) SizeVT() (n int)
func (*CreateIngestionConfigResponse) String ¶
func (x *CreateIngestionConfigResponse) String() string
func (*CreateIngestionConfigResponse) UnmarshalVT ¶
func (m *CreateIngestionConfigResponse) UnmarshalVT(dAtA []byte) error
func (*CreateIngestionConfigResponse) UnmarshalVTUnsafe ¶
func (m *CreateIngestionConfigResponse) UnmarshalVTUnsafe(dAtA []byte) error
type FlowConfig ¶
type FlowConfig struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Channels []*ChannelConfig `protobuf:"bytes,2,rep,name=channels,proto3" json:"channels,omitempty"` // contains filtered or unexported fields }
func (*FlowConfig) CloneMessageVT ¶
func (m *FlowConfig) CloneMessageVT() proto.Message
func (*FlowConfig) CloneVT ¶
func (m *FlowConfig) CloneVT() *FlowConfig
func (*FlowConfig) Descriptor
deprecated
func (*FlowConfig) Descriptor() ([]byte, []int)
Deprecated: Use FlowConfig.ProtoReflect.Descriptor instead.
func (*FlowConfig) EqualMessageVT ¶
func (this *FlowConfig) EqualMessageVT(thatMsg proto.Message) bool
func (*FlowConfig) EqualVT ¶
func (this *FlowConfig) EqualVT(that *FlowConfig) bool
func (*FlowConfig) GetChannels ¶
func (x *FlowConfig) GetChannels() []*ChannelConfig
func (*FlowConfig) GetName ¶
func (x *FlowConfig) GetName() string
func (*FlowConfig) MarshalToSizedBufferVT ¶
func (m *FlowConfig) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*FlowConfig) MarshalToSizedBufferVTStrict ¶
func (m *FlowConfig) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*FlowConfig) MarshalToVT ¶
func (m *FlowConfig) MarshalToVT(dAtA []byte) (int, error)
func (*FlowConfig) MarshalToVTStrict ¶
func (m *FlowConfig) MarshalToVTStrict(dAtA []byte) (int, error)
func (*FlowConfig) MarshalVT ¶
func (m *FlowConfig) MarshalVT() (dAtA []byte, err error)
func (*FlowConfig) MarshalVTStrict ¶
func (m *FlowConfig) MarshalVTStrict() (dAtA []byte, err error)
func (*FlowConfig) ProtoMessage ¶
func (*FlowConfig) ProtoMessage()
func (*FlowConfig) ProtoReflect ¶
func (x *FlowConfig) ProtoReflect() protoreflect.Message
func (*FlowConfig) Reset ¶
func (x *FlowConfig) Reset()
func (*FlowConfig) SizeVT ¶
func (m *FlowConfig) SizeVT() (n int)
func (*FlowConfig) String ¶
func (x *FlowConfig) String() string
func (*FlowConfig) UnmarshalVT ¶
func (m *FlowConfig) UnmarshalVT(dAtA []byte) error
func (*FlowConfig) UnmarshalVTUnsafe ¶
func (m *FlowConfig) UnmarshalVTUnsafe(dAtA []byte) error
type GetIngestionConfigRequest ¶
type GetIngestionConfigRequest struct { IngestionConfigId string `protobuf:"bytes,1,opt,name=ingestion_config_id,json=ingestionConfigId,proto3" json:"ingestion_config_id,omitempty"` // contains filtered or unexported fields }
The request for a call to `IngestionConfigService_GetIngestionConfig` to retrieve an ingestion config.
func (*GetIngestionConfigRequest) CloneMessageVT ¶
func (m *GetIngestionConfigRequest) CloneMessageVT() proto.Message
func (*GetIngestionConfigRequest) CloneVT ¶
func (m *GetIngestionConfigRequest) CloneVT() *GetIngestionConfigRequest
func (*GetIngestionConfigRequest) Descriptor
deprecated
func (*GetIngestionConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetIngestionConfigRequest.ProtoReflect.Descriptor instead.
func (*GetIngestionConfigRequest) EqualMessageVT ¶
func (this *GetIngestionConfigRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*GetIngestionConfigRequest) EqualVT ¶
func (this *GetIngestionConfigRequest) EqualVT(that *GetIngestionConfigRequest) bool
func (*GetIngestionConfigRequest) GetIngestionConfigId ¶
func (x *GetIngestionConfigRequest) GetIngestionConfigId() string
func (*GetIngestionConfigRequest) MarshalToSizedBufferVT ¶
func (m *GetIngestionConfigRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*GetIngestionConfigRequest) MarshalToSizedBufferVTStrict ¶
func (m *GetIngestionConfigRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*GetIngestionConfigRequest) MarshalToVT ¶
func (m *GetIngestionConfigRequest) MarshalToVT(dAtA []byte) (int, error)
func (*GetIngestionConfigRequest) MarshalToVTStrict ¶
func (m *GetIngestionConfigRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*GetIngestionConfigRequest) MarshalVT ¶
func (m *GetIngestionConfigRequest) MarshalVT() (dAtA []byte, err error)
func (*GetIngestionConfigRequest) MarshalVTStrict ¶
func (m *GetIngestionConfigRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*GetIngestionConfigRequest) ProtoMessage ¶
func (*GetIngestionConfigRequest) ProtoMessage()
func (*GetIngestionConfigRequest) ProtoReflect ¶
func (x *GetIngestionConfigRequest) ProtoReflect() protoreflect.Message
func (*GetIngestionConfigRequest) Reset ¶
func (x *GetIngestionConfigRequest) Reset()
func (*GetIngestionConfigRequest) SizeVT ¶
func (m *GetIngestionConfigRequest) SizeVT() (n int)
func (*GetIngestionConfigRequest) String ¶
func (x *GetIngestionConfigRequest) String() string
func (*GetIngestionConfigRequest) UnmarshalVT ¶
func (m *GetIngestionConfigRequest) UnmarshalVT(dAtA []byte) error
func (*GetIngestionConfigRequest) UnmarshalVTUnsafe ¶
func (m *GetIngestionConfigRequest) UnmarshalVTUnsafe(dAtA []byte) error
type GetIngestionConfigResponse ¶
type GetIngestionConfigResponse struct { IngestionConfig *IngestionConfig `protobuf:"bytes,1,opt,name=ingestion_config,json=ingestionConfig,proto3" json:"ingestion_config,omitempty"` // contains filtered or unexported fields }
The result of a call to `IngestionConfigService_GetIngestionConfig`.
func (*GetIngestionConfigResponse) CloneMessageVT ¶
func (m *GetIngestionConfigResponse) CloneMessageVT() proto.Message
func (*GetIngestionConfigResponse) CloneVT ¶
func (m *GetIngestionConfigResponse) CloneVT() *GetIngestionConfigResponse
func (*GetIngestionConfigResponse) Descriptor
deprecated
func (*GetIngestionConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetIngestionConfigResponse.ProtoReflect.Descriptor instead.
func (*GetIngestionConfigResponse) EqualMessageVT ¶
func (this *GetIngestionConfigResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*GetIngestionConfigResponse) EqualVT ¶
func (this *GetIngestionConfigResponse) EqualVT(that *GetIngestionConfigResponse) bool
func (*GetIngestionConfigResponse) GetIngestionConfig ¶
func (x *GetIngestionConfigResponse) GetIngestionConfig() *IngestionConfig
func (*GetIngestionConfigResponse) MarshalToSizedBufferVT ¶
func (m *GetIngestionConfigResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*GetIngestionConfigResponse) MarshalToSizedBufferVTStrict ¶
func (m *GetIngestionConfigResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*GetIngestionConfigResponse) MarshalToVT ¶
func (m *GetIngestionConfigResponse) MarshalToVT(dAtA []byte) (int, error)
func (*GetIngestionConfigResponse) MarshalToVTStrict ¶
func (m *GetIngestionConfigResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*GetIngestionConfigResponse) MarshalVT ¶
func (m *GetIngestionConfigResponse) MarshalVT() (dAtA []byte, err error)
func (*GetIngestionConfigResponse) MarshalVTStrict ¶
func (m *GetIngestionConfigResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*GetIngestionConfigResponse) ProtoMessage ¶
func (*GetIngestionConfigResponse) ProtoMessage()
func (*GetIngestionConfigResponse) ProtoReflect ¶
func (x *GetIngestionConfigResponse) ProtoReflect() protoreflect.Message
func (*GetIngestionConfigResponse) Reset ¶
func (x *GetIngestionConfigResponse) Reset()
func (*GetIngestionConfigResponse) SizeVT ¶
func (m *GetIngestionConfigResponse) SizeVT() (n int)
func (*GetIngestionConfigResponse) String ¶
func (x *GetIngestionConfigResponse) String() string
func (*GetIngestionConfigResponse) UnmarshalVT ¶
func (m *GetIngestionConfigResponse) UnmarshalVT(dAtA []byte) error
func (*GetIngestionConfigResponse) UnmarshalVTUnsafe ¶
func (m *GetIngestionConfigResponse) UnmarshalVTUnsafe(dAtA []byte) error
type IngestionConfig ¶
type IngestionConfig struct { IngestionConfigId string `protobuf:"bytes,1,opt,name=ingestion_config_id,json=ingestionConfigId,proto3" json:"ingestion_config_id,omitempty"` AssetId string `protobuf:"bytes,2,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"` ClientKey string `protobuf:"bytes,3,opt,name=client_key,json=clientKey,proto3" json:"client_key,omitempty"` // contains filtered or unexported fields }
func (*IngestionConfig) CloneMessageVT ¶
func (m *IngestionConfig) CloneMessageVT() proto.Message
func (*IngestionConfig) CloneVT ¶
func (m *IngestionConfig) CloneVT() *IngestionConfig
func (*IngestionConfig) Descriptor
deprecated
func (*IngestionConfig) Descriptor() ([]byte, []int)
Deprecated: Use IngestionConfig.ProtoReflect.Descriptor instead.
func (*IngestionConfig) EqualMessageVT ¶
func (this *IngestionConfig) EqualMessageVT(thatMsg proto.Message) bool
func (*IngestionConfig) EqualVT ¶
func (this *IngestionConfig) EqualVT(that *IngestionConfig) bool
func (*IngestionConfig) GetAssetId ¶
func (x *IngestionConfig) GetAssetId() string
func (*IngestionConfig) GetClientKey ¶
func (x *IngestionConfig) GetClientKey() string
func (*IngestionConfig) GetIngestionConfigId ¶
func (x *IngestionConfig) GetIngestionConfigId() string
func (*IngestionConfig) MarshalToSizedBufferVT ¶
func (m *IngestionConfig) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*IngestionConfig) MarshalToSizedBufferVTStrict ¶
func (m *IngestionConfig) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*IngestionConfig) MarshalToVT ¶
func (m *IngestionConfig) MarshalToVT(dAtA []byte) (int, error)
func (*IngestionConfig) MarshalToVTStrict ¶
func (m *IngestionConfig) MarshalToVTStrict(dAtA []byte) (int, error)
func (*IngestionConfig) MarshalVT ¶
func (m *IngestionConfig) MarshalVT() (dAtA []byte, err error)
func (*IngestionConfig) MarshalVTStrict ¶
func (m *IngestionConfig) MarshalVTStrict() (dAtA []byte, err error)
func (*IngestionConfig) ProtoMessage ¶
func (*IngestionConfig) ProtoMessage()
func (*IngestionConfig) ProtoReflect ¶
func (x *IngestionConfig) ProtoReflect() protoreflect.Message
func (*IngestionConfig) Reset ¶
func (x *IngestionConfig) Reset()
func (*IngestionConfig) SizeVT ¶
func (m *IngestionConfig) SizeVT() (n int)
func (*IngestionConfig) String ¶
func (x *IngestionConfig) String() string
func (*IngestionConfig) UnmarshalVT ¶
func (m *IngestionConfig) UnmarshalVT(dAtA []byte) error
func (*IngestionConfig) UnmarshalVTUnsafe ¶
func (m *IngestionConfig) UnmarshalVTUnsafe(dAtA []byte) error
type IngestionConfigServiceClient ¶
type IngestionConfigServiceClient interface { // Retrieves an ingestion config. GetIngestionConfig(ctx context.Context, in *GetIngestionConfigRequest, opts ...grpc.CallOption) (*GetIngestionConfigResponse, error) // Create an ingestion config. CreateIngestionConfig(ctx context.Context, in *CreateIngestionConfigRequest, opts ...grpc.CallOption) (*CreateIngestionConfigResponse, error) // List ingestion configs using an optional filter. ListIngestionConfigs(ctx context.Context, in *ListIngestionConfigsRequest, opts ...grpc.CallOption) (*ListIngestionConfigsResponse, error) // Create ingestion config [flows](/glossary#flow). CreateIngestionConfigFlows(ctx context.Context, in *CreateIngestionConfigFlowsRequest, opts ...grpc.CallOption) (*CreateIngestionConfigFlowsResponse, error) // List ingestion config [flows](/glossary#flow) using an optional filter. ListIngestionConfigFlows(ctx context.Context, in *ListIngestionConfigFlowsRequest, opts ...grpc.CallOption) (*ListIngestionConfigFlowsResponse, error) }
IngestionConfigServiceClient is the client API for IngestionConfigService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewIngestionConfigServiceClient ¶
func NewIngestionConfigServiceClient(cc grpc.ClientConnInterface) IngestionConfigServiceClient
type IngestionConfigServiceServer ¶
type IngestionConfigServiceServer interface { // Retrieves an ingestion config. GetIngestionConfig(context.Context, *GetIngestionConfigRequest) (*GetIngestionConfigResponse, error) // Create an ingestion config. CreateIngestionConfig(context.Context, *CreateIngestionConfigRequest) (*CreateIngestionConfigResponse, error) // List ingestion configs using an optional filter. ListIngestionConfigs(context.Context, *ListIngestionConfigsRequest) (*ListIngestionConfigsResponse, error) // Create ingestion config [flows](/glossary#flow). CreateIngestionConfigFlows(context.Context, *CreateIngestionConfigFlowsRequest) (*CreateIngestionConfigFlowsResponse, error) // List ingestion config [flows](/glossary#flow) using an optional filter. ListIngestionConfigFlows(context.Context, *ListIngestionConfigFlowsRequest) (*ListIngestionConfigFlowsResponse, error) // contains filtered or unexported methods }
IngestionConfigServiceServer is the server API for IngestionConfigService service. All implementations must embed UnimplementedIngestionConfigServiceServer for forward compatibility
type ListIngestionConfigFlowsRequest ¶
type ListIngestionConfigFlowsRequest struct { IngestionConfigId string `protobuf:"bytes,1,opt,name=ingestion_config_id,json=ingestionConfigId,proto3" json:"ingestion_config_id,omitempty"` // The maximum number of ingestion config flows to return. The service may return fewer than this value. // If unspecified, at most 50 ingestion config flows will be returned. The maximum value is 1000; values above // 1000 will be coerced to 1000. Optional. PageSize uint32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // A page token, received from a previous `ListIngestionConfigFlows` call. // Provide this to retrieve the subsequent page. // When paginating, all other parameters provided to `ListIngestionConfigFlows` must match // the call that provided the page token. Optional. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // A [Common Expression Language (CEL)](https://github.com/google/cel-spec) filter string. // Available fields to filter by are `flow_name`, `flow_id`, `created_date`, and `modified_date`. // For further information about how to use CELs, please refer to [this guide](https://github.com/google/cel-spec/blob/master/doc/langdef.md#standard-definitions). // For more information about the fields used for filtering, please refer to [this definition](/ingestion/api#sift_ingestion_configs_v1-proto). Optional. Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
The request for a call to `IngestionConfigService_ListIngestionConfigFlows` to retrieve ingestion config flows.
func (*ListIngestionConfigFlowsRequest) CloneMessageVT ¶
func (m *ListIngestionConfigFlowsRequest) CloneMessageVT() proto.Message
func (*ListIngestionConfigFlowsRequest) CloneVT ¶
func (m *ListIngestionConfigFlowsRequest) CloneVT() *ListIngestionConfigFlowsRequest
func (*ListIngestionConfigFlowsRequest) Descriptor
deprecated
func (*ListIngestionConfigFlowsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListIngestionConfigFlowsRequest.ProtoReflect.Descriptor instead.
func (*ListIngestionConfigFlowsRequest) EqualMessageVT ¶
func (this *ListIngestionConfigFlowsRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*ListIngestionConfigFlowsRequest) EqualVT ¶
func (this *ListIngestionConfigFlowsRequest) EqualVT(that *ListIngestionConfigFlowsRequest) bool
func (*ListIngestionConfigFlowsRequest) GetFilter ¶
func (x *ListIngestionConfigFlowsRequest) GetFilter() string
func (*ListIngestionConfigFlowsRequest) GetIngestionConfigId ¶
func (x *ListIngestionConfigFlowsRequest) GetIngestionConfigId() string
func (*ListIngestionConfigFlowsRequest) GetPageSize ¶
func (x *ListIngestionConfigFlowsRequest) GetPageSize() uint32
func (*ListIngestionConfigFlowsRequest) GetPageToken ¶
func (x *ListIngestionConfigFlowsRequest) GetPageToken() string
func (*ListIngestionConfigFlowsRequest) MarshalToSizedBufferVT ¶
func (m *ListIngestionConfigFlowsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ListIngestionConfigFlowsRequest) MarshalToSizedBufferVTStrict ¶
func (m *ListIngestionConfigFlowsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*ListIngestionConfigFlowsRequest) MarshalToVT ¶
func (m *ListIngestionConfigFlowsRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ListIngestionConfigFlowsRequest) MarshalToVTStrict ¶
func (m *ListIngestionConfigFlowsRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*ListIngestionConfigFlowsRequest) MarshalVT ¶
func (m *ListIngestionConfigFlowsRequest) MarshalVT() (dAtA []byte, err error)
func (*ListIngestionConfigFlowsRequest) MarshalVTStrict ¶
func (m *ListIngestionConfigFlowsRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*ListIngestionConfigFlowsRequest) ProtoMessage ¶
func (*ListIngestionConfigFlowsRequest) ProtoMessage()
func (*ListIngestionConfigFlowsRequest) ProtoReflect ¶
func (x *ListIngestionConfigFlowsRequest) ProtoReflect() protoreflect.Message
func (*ListIngestionConfigFlowsRequest) Reset ¶
func (x *ListIngestionConfigFlowsRequest) Reset()
func (*ListIngestionConfigFlowsRequest) SizeVT ¶
func (m *ListIngestionConfigFlowsRequest) SizeVT() (n int)
func (*ListIngestionConfigFlowsRequest) String ¶
func (x *ListIngestionConfigFlowsRequest) String() string
func (*ListIngestionConfigFlowsRequest) UnmarshalVT ¶
func (m *ListIngestionConfigFlowsRequest) UnmarshalVT(dAtA []byte) error
func (*ListIngestionConfigFlowsRequest) UnmarshalVTUnsafe ¶
func (m *ListIngestionConfigFlowsRequest) UnmarshalVTUnsafe(dAtA []byte) error
type ListIngestionConfigFlowsResponse ¶
type ListIngestionConfigFlowsResponse struct { Flows []*FlowConfig `protobuf:"bytes,1,rep,name=flows,proto3" json:"flows,omitempty"` NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
The result of a call to `IngestionConfigService_ListIngestionConfigFlows`.
func (*ListIngestionConfigFlowsResponse) CloneMessageVT ¶
func (m *ListIngestionConfigFlowsResponse) CloneMessageVT() proto.Message
func (*ListIngestionConfigFlowsResponse) CloneVT ¶
func (m *ListIngestionConfigFlowsResponse) CloneVT() *ListIngestionConfigFlowsResponse
func (*ListIngestionConfigFlowsResponse) Descriptor
deprecated
func (*ListIngestionConfigFlowsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListIngestionConfigFlowsResponse.ProtoReflect.Descriptor instead.
func (*ListIngestionConfigFlowsResponse) EqualMessageVT ¶
func (this *ListIngestionConfigFlowsResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*ListIngestionConfigFlowsResponse) EqualVT ¶
func (this *ListIngestionConfigFlowsResponse) EqualVT(that *ListIngestionConfigFlowsResponse) bool
func (*ListIngestionConfigFlowsResponse) GetFlows ¶
func (x *ListIngestionConfigFlowsResponse) GetFlows() []*FlowConfig
func (*ListIngestionConfigFlowsResponse) GetNextPageToken ¶
func (x *ListIngestionConfigFlowsResponse) GetNextPageToken() string
func (*ListIngestionConfigFlowsResponse) MarshalToSizedBufferVT ¶
func (m *ListIngestionConfigFlowsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ListIngestionConfigFlowsResponse) MarshalToSizedBufferVTStrict ¶
func (m *ListIngestionConfigFlowsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*ListIngestionConfigFlowsResponse) MarshalToVT ¶
func (m *ListIngestionConfigFlowsResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ListIngestionConfigFlowsResponse) MarshalToVTStrict ¶
func (m *ListIngestionConfigFlowsResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*ListIngestionConfigFlowsResponse) MarshalVT ¶
func (m *ListIngestionConfigFlowsResponse) MarshalVT() (dAtA []byte, err error)
func (*ListIngestionConfigFlowsResponse) MarshalVTStrict ¶
func (m *ListIngestionConfigFlowsResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*ListIngestionConfigFlowsResponse) ProtoMessage ¶
func (*ListIngestionConfigFlowsResponse) ProtoMessage()
func (*ListIngestionConfigFlowsResponse) ProtoReflect ¶
func (x *ListIngestionConfigFlowsResponse) ProtoReflect() protoreflect.Message
func (*ListIngestionConfigFlowsResponse) Reset ¶
func (x *ListIngestionConfigFlowsResponse) Reset()
func (*ListIngestionConfigFlowsResponse) SizeVT ¶
func (m *ListIngestionConfigFlowsResponse) SizeVT() (n int)
func (*ListIngestionConfigFlowsResponse) String ¶
func (x *ListIngestionConfigFlowsResponse) String() string
func (*ListIngestionConfigFlowsResponse) UnmarshalVT ¶
func (m *ListIngestionConfigFlowsResponse) UnmarshalVT(dAtA []byte) error
func (*ListIngestionConfigFlowsResponse) UnmarshalVTUnsafe ¶
func (m *ListIngestionConfigFlowsResponse) UnmarshalVTUnsafe(dAtA []byte) error
type ListIngestionConfigsRequest ¶
type ListIngestionConfigsRequest struct { // The maximum number of ingestion configs to return. The service may return fewer than this value. // If unspecified, at most 50 ingestion configs will be returned. The maximum value is 1000; values above // 1000 will be coerced to 1000. Optional. PageSize uint32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // A page token, received from a previous `ListIngestionConfigs` call. // Provide this to retrieve the subsequent page. // When paginating, all other parameters provided to `ListIngestionConfigs` must match // the call that provided the page token. Optional. PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // A [Common Expression Language (CEL)](https://github.com/google/cel-spec) filter string. // Available fields to filter by are `ingestion_config_id`, `client_key`, `asset_id`, `created_date`, and `modified_date`. // For further information about how to use CELs, please refer to [this guide](https://github.com/google/cel-spec/blob/master/doc/langdef.md#standard-definitions). // For more information about the fields used for filtering, please refer to [this definition](/protocol-buffers/documentation#ingestionconfigservice). Optional. Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
The request for a call to `IngestionConfigService_ListIngestionConfigs` to retrieve ingestion configs.
func (*ListIngestionConfigsRequest) CloneMessageVT ¶
func (m *ListIngestionConfigsRequest) CloneMessageVT() proto.Message
func (*ListIngestionConfigsRequest) CloneVT ¶
func (m *ListIngestionConfigsRequest) CloneVT() *ListIngestionConfigsRequest
func (*ListIngestionConfigsRequest) Descriptor
deprecated
func (*ListIngestionConfigsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListIngestionConfigsRequest.ProtoReflect.Descriptor instead.
func (*ListIngestionConfigsRequest) EqualMessageVT ¶
func (this *ListIngestionConfigsRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*ListIngestionConfigsRequest) EqualVT ¶
func (this *ListIngestionConfigsRequest) EqualVT(that *ListIngestionConfigsRequest) bool
func (*ListIngestionConfigsRequest) GetFilter ¶
func (x *ListIngestionConfigsRequest) GetFilter() string
func (*ListIngestionConfigsRequest) GetPageSize ¶
func (x *ListIngestionConfigsRequest) GetPageSize() uint32
func (*ListIngestionConfigsRequest) GetPageToken ¶
func (x *ListIngestionConfigsRequest) GetPageToken() string
func (*ListIngestionConfigsRequest) MarshalToSizedBufferVT ¶
func (m *ListIngestionConfigsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ListIngestionConfigsRequest) MarshalToSizedBufferVTStrict ¶
func (m *ListIngestionConfigsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*ListIngestionConfigsRequest) MarshalToVT ¶
func (m *ListIngestionConfigsRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ListIngestionConfigsRequest) MarshalToVTStrict ¶
func (m *ListIngestionConfigsRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*ListIngestionConfigsRequest) MarshalVT ¶
func (m *ListIngestionConfigsRequest) MarshalVT() (dAtA []byte, err error)
func (*ListIngestionConfigsRequest) MarshalVTStrict ¶
func (m *ListIngestionConfigsRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*ListIngestionConfigsRequest) ProtoMessage ¶
func (*ListIngestionConfigsRequest) ProtoMessage()
func (*ListIngestionConfigsRequest) ProtoReflect ¶
func (x *ListIngestionConfigsRequest) ProtoReflect() protoreflect.Message
func (*ListIngestionConfigsRequest) Reset ¶
func (x *ListIngestionConfigsRequest) Reset()
func (*ListIngestionConfigsRequest) SizeVT ¶
func (m *ListIngestionConfigsRequest) SizeVT() (n int)
func (*ListIngestionConfigsRequest) String ¶
func (x *ListIngestionConfigsRequest) String() string
func (*ListIngestionConfigsRequest) UnmarshalVT ¶
func (m *ListIngestionConfigsRequest) UnmarshalVT(dAtA []byte) error
func (*ListIngestionConfigsRequest) UnmarshalVTUnsafe ¶
func (m *ListIngestionConfigsRequest) UnmarshalVTUnsafe(dAtA []byte) error
type ListIngestionConfigsResponse ¶
type ListIngestionConfigsResponse struct { IngestionConfigs []*IngestionConfig `protobuf:"bytes,1,rep,name=ingestion_configs,json=ingestionConfigs,proto3" json:"ingestion_configs,omitempty"` NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
The result of a call to `IngestionConfigService_ListIngestionConfigs`.
func (*ListIngestionConfigsResponse) CloneMessageVT ¶
func (m *ListIngestionConfigsResponse) CloneMessageVT() proto.Message
func (*ListIngestionConfigsResponse) CloneVT ¶
func (m *ListIngestionConfigsResponse) CloneVT() *ListIngestionConfigsResponse
func (*ListIngestionConfigsResponse) Descriptor
deprecated
func (*ListIngestionConfigsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListIngestionConfigsResponse.ProtoReflect.Descriptor instead.
func (*ListIngestionConfigsResponse) EqualMessageVT ¶
func (this *ListIngestionConfigsResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*ListIngestionConfigsResponse) EqualVT ¶
func (this *ListIngestionConfigsResponse) EqualVT(that *ListIngestionConfigsResponse) bool
func (*ListIngestionConfigsResponse) GetIngestionConfigs ¶
func (x *ListIngestionConfigsResponse) GetIngestionConfigs() []*IngestionConfig
func (*ListIngestionConfigsResponse) GetNextPageToken ¶
func (x *ListIngestionConfigsResponse) GetNextPageToken() string
func (*ListIngestionConfigsResponse) MarshalToSizedBufferVT ¶
func (m *ListIngestionConfigsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ListIngestionConfigsResponse) MarshalToSizedBufferVTStrict ¶
func (m *ListIngestionConfigsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*ListIngestionConfigsResponse) MarshalToVT ¶
func (m *ListIngestionConfigsResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ListIngestionConfigsResponse) MarshalToVTStrict ¶
func (m *ListIngestionConfigsResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*ListIngestionConfigsResponse) MarshalVT ¶
func (m *ListIngestionConfigsResponse) MarshalVT() (dAtA []byte, err error)
func (*ListIngestionConfigsResponse) MarshalVTStrict ¶
func (m *ListIngestionConfigsResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*ListIngestionConfigsResponse) ProtoMessage ¶
func (*ListIngestionConfigsResponse) ProtoMessage()
func (*ListIngestionConfigsResponse) ProtoReflect ¶
func (x *ListIngestionConfigsResponse) ProtoReflect() protoreflect.Message
func (*ListIngestionConfigsResponse) Reset ¶
func (x *ListIngestionConfigsResponse) Reset()
func (*ListIngestionConfigsResponse) SizeVT ¶
func (m *ListIngestionConfigsResponse) SizeVT() (n int)
func (*ListIngestionConfigsResponse) String ¶
func (x *ListIngestionConfigsResponse) String() string
func (*ListIngestionConfigsResponse) UnmarshalVT ¶
func (m *ListIngestionConfigsResponse) UnmarshalVT(dAtA []byte) error
func (*ListIngestionConfigsResponse) UnmarshalVTUnsafe ¶
func (m *ListIngestionConfigsResponse) UnmarshalVTUnsafe(dAtA []byte) error
type UnimplementedIngestionConfigServiceServer ¶
type UnimplementedIngestionConfigServiceServer struct { }
UnimplementedIngestionConfigServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedIngestionConfigServiceServer) CreateIngestionConfig ¶
func (UnimplementedIngestionConfigServiceServer) CreateIngestionConfig(context.Context, *CreateIngestionConfigRequest) (*CreateIngestionConfigResponse, error)
func (UnimplementedIngestionConfigServiceServer) CreateIngestionConfigFlows ¶
func (UnimplementedIngestionConfigServiceServer) CreateIngestionConfigFlows(context.Context, *CreateIngestionConfigFlowsRequest) (*CreateIngestionConfigFlowsResponse, error)
func (UnimplementedIngestionConfigServiceServer) GetIngestionConfig ¶
func (UnimplementedIngestionConfigServiceServer) GetIngestionConfig(context.Context, *GetIngestionConfigRequest) (*GetIngestionConfigResponse, error)
func (UnimplementedIngestionConfigServiceServer) ListIngestionConfigFlows ¶
func (UnimplementedIngestionConfigServiceServer) ListIngestionConfigFlows(context.Context, *ListIngestionConfigFlowsRequest) (*ListIngestionConfigFlowsResponse, error)
func (UnimplementedIngestionConfigServiceServer) ListIngestionConfigs ¶
func (UnimplementedIngestionConfigServiceServer) ListIngestionConfigs(context.Context, *ListIngestionConfigsRequest) (*ListIngestionConfigsResponse, error)
type UnsafeIngestionConfigServiceServer ¶
type UnsafeIngestionConfigServiceServer interface {
// contains filtered or unexported methods
}
UnsafeIngestionConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IngestionConfigServiceServer will result in compilation errors.