data_feed

package
v0.0.0-...-33704e8 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package data_feed is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_external_data_feed_data_feed_proto protoreflect.FileDescriptor

Functions

func RegisterDatafeedServiceHandler 

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

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

func RegisterDatafeedServiceHandlerClient 

func RegisterDatafeedServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DatafeedServiceClient) error

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

func RegisterDatafeedServiceHandlerFromEndpoint 

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

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

func RegisterDatafeedServiceHandlerServer 

func RegisterDatafeedServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DatafeedServiceServer) error

RegisterDatafeedServiceHandlerServer registers the http handlers for service DatafeedService to "mux". UnaryRPC :call DatafeedServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterDatafeedServiceServer 

func RegisterDatafeedServiceServer(s *grpc.Server, srv DatafeedServiceServer)

Types

type AWS 

type AWS struct {
	AccessKey       string `protobuf:"bytes,1,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretAccessKey string `protobuf:"bytes,2,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"`
	Bucket          string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Region          string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"`
	// contains filtered or unexported fields
}

func (*AWS) Descriptor deprecated 

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

Deprecated: Use AWS.ProtoReflect.Descriptor instead.

func (*AWS) GetAccessKey 

func (x *AWS) GetAccessKey() string

func (*AWS) GetBucket 

func (x *AWS) GetBucket() string

func (*AWS) GetRegion 

func (x *AWS) GetRegion() string

func (*AWS) GetSecretAccessKey 

func (x *AWS) GetSecretAccessKey() string

func (*AWS) ProtoMessage 

func (*AWS) ProtoMessage()

func (*AWS) ProtoReflect 

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

func (*AWS) Reset 

func (x *AWS) Reset()

func (*AWS) String 

func (x *AWS) String() string

type AWSMetaData 

type AWSMetaData struct {
	Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	// contains filtered or unexported fields
}

func (*AWSMetaData) Descriptor deprecated 

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

Deprecated: Use AWSMetaData.ProtoReflect.Descriptor instead.

func (*AWSMetaData) GetBucket 

func (x *AWSMetaData) GetBucket() string

func (*AWSMetaData) GetRegion 

func (x *AWSMetaData) GetRegion() string

func (*AWSMetaData) ProtoMessage 

func (*AWSMetaData) ProtoMessage()

func (*AWSMetaData) ProtoReflect 

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

func (*AWSMetaData) Reset 

func (x *AWSMetaData) Reset()

func (*AWSMetaData) String 

func (x *AWSMetaData) String() string

type AddDestinationRequest 

type AddDestinationRequest struct {
	Id               int64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name             string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Url              string      `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Secret           string      `protobuf:"bytes,4,opt,name=secret,proto3" json:"secret,omitempty"`
	Services         string      `protobuf:"bytes,5,opt,name=services,proto3" json:"services,omitempty"`
	IntegrationTypes string      `protobuf:"bytes,6,opt,name=integration_types,json=integrationTypes,proto3" json:"integration_types,omitempty"`
	Enable           bool        `protobuf:"varint,7,opt,name=enable,proto3" json:"enable,omitempty"`
	MetaData         []*query.Kv `protobuf:"bytes,8,rep,name=meta_data,json=metaData,proto3" json:"meta_data,omitempty"`
	// contains filtered or unexported fields
}

func (*AddDestinationRequest) Descriptor deprecated 

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

Deprecated: Use AddDestinationRequest.ProtoReflect.Descriptor instead.

func (*AddDestinationRequest) GetEnable 

func (x *AddDestinationRequest) GetEnable() bool

func (*AddDestinationRequest) GetId 

func (x *AddDestinationRequest) GetId() int64

func (*AddDestinationRequest) GetIntegrationTypes 

func (x *AddDestinationRequest) GetIntegrationTypes() string

func (*AddDestinationRequest) GetMetaData 

func (x *AddDestinationRequest) GetMetaData() []*query.Kv

func (*AddDestinationRequest) GetName 

func (x *AddDestinationRequest) GetName() string

func (*AddDestinationRequest) GetSecret 

func (x *AddDestinationRequest) GetSecret() string

func (*AddDestinationRequest) GetServices 

func (x *AddDestinationRequest) GetServices() string

func (*AddDestinationRequest) GetUrl 

func (x *AddDestinationRequest) GetUrl() string

func (*AddDestinationRequest) ProtoMessage 

func (*AddDestinationRequest) ProtoMessage()

func (*AddDestinationRequest) ProtoReflect 

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

func (*AddDestinationRequest) Reset 

func (x *AddDestinationRequest) Reset()

func (*AddDestinationRequest) String 

func (x *AddDestinationRequest) String() string

type AddDestinationResponse 

type AddDestinationResponse struct {
	Id               int64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name             string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Url              string      `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Secret           string      `protobuf:"bytes,4,opt,name=secret,proto3" json:"secret,omitempty"`
	Services         string      `protobuf:"bytes,5,opt,name=services,proto3" json:"services,omitempty"`
	IntegrationTypes string      `protobuf:"bytes,6,opt,name=integration_types,json=integrationTypes,proto3" json:"integration_types,omitempty"`
	Enable           bool        `protobuf:"varint,7,opt,name=enable,proto3" json:"enable,omitempty"`
	MetaData         []*query.Kv `protobuf:"bytes,8,rep,name=meta_data,json=metaData,proto3" json:"meta_data,omitempty"`
	// contains filtered or unexported fields
}

func (*AddDestinationResponse) Descriptor deprecated 

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

Deprecated: Use AddDestinationResponse.ProtoReflect.Descriptor instead.

func (*AddDestinationResponse) GetEnable 

func (x *AddDestinationResponse) GetEnable() bool

func (*AddDestinationResponse) GetId 

func (x *AddDestinationResponse) GetId() int64

func (*AddDestinationResponse) GetIntegrationTypes 

func (x *AddDestinationResponse) GetIntegrationTypes() string

func (*AddDestinationResponse) GetMetaData 

func (x *AddDestinationResponse) GetMetaData() []*query.Kv

func (*AddDestinationResponse) GetName 

func (x *AddDestinationResponse) GetName() string

func (*AddDestinationResponse) GetSecret 

func (x *AddDestinationResponse) GetSecret() string

func (*AddDestinationResponse) GetServices 

func (x *AddDestinationResponse) GetServices() string

func (*AddDestinationResponse) GetUrl 

func (x *AddDestinationResponse) GetUrl() string

func (*AddDestinationResponse) ProtoMessage 

func (*AddDestinationResponse) ProtoMessage()

func (*AddDestinationResponse) ProtoReflect 

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

func (*AddDestinationResponse) Reset 

func (x *AddDestinationResponse) Reset()

func (*AddDestinationResponse) String 

func (x *AddDestinationResponse) String() string

type DatafeedServiceClient 

type DatafeedServiceClient interface {
	AddDestination(ctx context.Context, in *AddDestinationRequest, opts ...grpc.CallOption) (*AddDestinationResponse, error)
	GetDestination(ctx context.Context, in *GetDestinationRequest, opts ...grpc.CallOption) (*GetDestinationResponse, error)
	DeleteDestination(ctx context.Context, in *DeleteDestinationRequest, opts ...grpc.CallOption) (*DeleteDestinationResponse, error)
	UpdateDestination(ctx context.Context, in *UpdateDestinationRequest, opts ...grpc.CallOption) (*UpdateDestinationResponse, error)
	ListDestinations(ctx context.Context, in *ListDestinationRequest, opts ...grpc.CallOption) (*ListDestinationResponse, error)
	TestDestination(ctx context.Context, in *URLValidationRequest, opts ...grpc.CallOption) (*TestDestinationResponse, error)
	EnableDestination(ctx context.Context, in *UpdateDestinationEnableRequest, opts ...grpc.CallOption) (*GetDestinationResponse, error)
	GlobalDataFeedConfig(ctx context.Context, in *GlobalDataFeedConfigRequest, opts ...grpc.CallOption) (*GlobalDataFeedConfigResponse, error)
}

DatafeedServiceClient is the client API for DatafeedService service.

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

func NewDatafeedServiceClient 

func NewDatafeedServiceClient(cc grpc.ClientConnInterface) DatafeedServiceClient

type DatafeedServiceServer 

type DatafeedServiceServer interface {
	AddDestination(context.Context, *AddDestinationRequest) (*AddDestinationResponse, error)
	GetDestination(context.Context, *GetDestinationRequest) (*GetDestinationResponse, error)
	DeleteDestination(context.Context, *DeleteDestinationRequest) (*DeleteDestinationResponse, error)
	UpdateDestination(context.Context, *UpdateDestinationRequest) (*UpdateDestinationResponse, error)
	ListDestinations(context.Context, *ListDestinationRequest) (*ListDestinationResponse, error)
	TestDestination(context.Context, *URLValidationRequest) (*TestDestinationResponse, error)
	EnableDestination(context.Context, *UpdateDestinationEnableRequest) (*GetDestinationResponse, error)
	GlobalDataFeedConfig(context.Context, *GlobalDataFeedConfigRequest) (*GlobalDataFeedConfigResponse, error)
}

DatafeedServiceServer is the server API for DatafeedService service.

type DeleteDestinationRequest 

type DeleteDestinationRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDestinationRequest) Descriptor deprecated 

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

Deprecated: Use DeleteDestinationRequest.ProtoReflect.Descriptor instead.

func (*DeleteDestinationRequest) GetId 

func (x *DeleteDestinationRequest) GetId() int64

func (*DeleteDestinationRequest) ProtoMessage 

func (*DeleteDestinationRequest) ProtoMessage()

func (*DeleteDestinationRequest) ProtoReflect 

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

func (*DeleteDestinationRequest) Reset 

func (x *DeleteDestinationRequest) Reset()

func (*DeleteDestinationRequest) String 

func (x *DeleteDestinationRequest) String() string

type DeleteDestinationResponse 

type DeleteDestinationResponse struct {
	Id               int64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name             string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Url              string      `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Secret           string      `protobuf:"bytes,4,opt,name=secret,proto3" json:"secret,omitempty"`
	Services         string      `protobuf:"bytes,5,opt,name=services,proto3" json:"services,omitempty"`
	IntegrationTypes string      `protobuf:"bytes,6,opt,name=integration_types,json=integrationTypes,proto3" json:"integration_types,omitempty"`
	Enable           bool        `protobuf:"varint,7,opt,name=enable,proto3" json:"enable,omitempty"`
	MetaData         []*query.Kv `protobuf:"bytes,8,rep,name=meta_data,json=metaData,proto3" json:"meta_data,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDestinationResponse) Descriptor deprecated 

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

Deprecated: Use DeleteDestinationResponse.ProtoReflect.Descriptor instead.

func (*DeleteDestinationResponse) GetEnable 

func (x *DeleteDestinationResponse) GetEnable() bool

func (*DeleteDestinationResponse) GetId 

func (x *DeleteDestinationResponse) GetId() int64

func (*DeleteDestinationResponse) GetIntegrationTypes 

func (x *DeleteDestinationResponse) GetIntegrationTypes() string

func (*DeleteDestinationResponse) GetMetaData 

func (x *DeleteDestinationResponse) GetMetaData() []*query.Kv

func (*DeleteDestinationResponse) GetName 

func (x *DeleteDestinationResponse) GetName() string

func (*DeleteDestinationResponse) GetSecret 

func (x *DeleteDestinationResponse) GetSecret() string

func (*DeleteDestinationResponse) GetServices 

func (x *DeleteDestinationResponse) GetServices() string

func (*DeleteDestinationResponse) GetUrl 

func (x *DeleteDestinationResponse) GetUrl() string

func (*DeleteDestinationResponse) ProtoMessage 

func (*DeleteDestinationResponse) ProtoMessage()

func (*DeleteDestinationResponse) ProtoReflect 

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

func (*DeleteDestinationResponse) Reset 

func (x *DeleteDestinationResponse) Reset()

func (*DeleteDestinationResponse) String 

func (x *DeleteDestinationResponse) String() string

type GetDestinationRequest 

type GetDestinationRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDestinationRequest) Descriptor deprecated 

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

Deprecated: Use GetDestinationRequest.ProtoReflect.Descriptor instead.

func (*GetDestinationRequest) GetId 

func (x *GetDestinationRequest) GetId() int64

func (*GetDestinationRequest) ProtoMessage 

func (*GetDestinationRequest) ProtoMessage()

func (*GetDestinationRequest) ProtoReflect 

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

func (*GetDestinationRequest) Reset 

func (x *GetDestinationRequest) Reset()

func (*GetDestinationRequest) String 

func (x *GetDestinationRequest) String() string

type GetDestinationResponse 

type GetDestinationResponse struct {
	Id               int64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name             string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Url              string      `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Secret           string      `protobuf:"bytes,4,opt,name=secret,proto3" json:"secret,omitempty"`
	Services         string      `protobuf:"bytes,5,opt,name=services,proto3" json:"services,omitempty"`
	IntegrationTypes string      `protobuf:"bytes,6,opt,name=integration_types,json=integrationTypes,proto3" json:"integration_types,omitempty"`
	Enable           bool        `protobuf:"varint,7,opt,name=enable,proto3" json:"enable,omitempty"`
	MetaData         []*query.Kv `protobuf:"bytes,8,rep,name=meta_data,json=metaData,proto3" json:"meta_data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDestinationResponse) Descriptor deprecated 

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

Deprecated: Use GetDestinationResponse.ProtoReflect.Descriptor instead.

func (*GetDestinationResponse) GetEnable 

func (x *GetDestinationResponse) GetEnable() bool

func (*GetDestinationResponse) GetId 

func (x *GetDestinationResponse) GetId() int64

func (*GetDestinationResponse) GetIntegrationTypes 

func (x *GetDestinationResponse) GetIntegrationTypes() string

func (*GetDestinationResponse) GetMetaData 

func (x *GetDestinationResponse) GetMetaData() []*query.Kv

func (*GetDestinationResponse) GetName 

func (x *GetDestinationResponse) GetName() string

func (*GetDestinationResponse) GetSecret 

func (x *GetDestinationResponse) GetSecret() string

func (*GetDestinationResponse) GetServices 

func (x *GetDestinationResponse) GetServices() string

func (*GetDestinationResponse) GetUrl 

func (x *GetDestinationResponse) GetUrl() string

func (*GetDestinationResponse) ProtoMessage 

func (*GetDestinationResponse) ProtoMessage()

func (*GetDestinationResponse) ProtoReflect 

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

func (*GetDestinationResponse) Reset 

func (x *GetDestinationResponse) Reset()

func (*GetDestinationResponse) String 

func (x *GetDestinationResponse) String() string

type GlobalDataFeedConfigRequest 

type GlobalDataFeedConfigRequest struct {
	// contains filtered or unexported fields
}

func (*GlobalDataFeedConfigRequest) Descriptor deprecated 

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

Deprecated: Use GlobalDataFeedConfigRequest.ProtoReflect.Descriptor instead.

func (*GlobalDataFeedConfigRequest) ProtoMessage 

func (*GlobalDataFeedConfigRequest) ProtoMessage()

func (*GlobalDataFeedConfigRequest) ProtoReflect 

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

func (*GlobalDataFeedConfigRequest) Reset 

func (x *GlobalDataFeedConfigRequest) Reset()

func (*GlobalDataFeedConfigRequest) String 

func (x *GlobalDataFeedConfigRequest) String() string

type GlobalDataFeedConfigResponse 

type GlobalDataFeedConfigResponse struct {
	FeedInterval        string   `protobuf:"bytes,1,opt,name=feed_interval,json=feedInterval,proto3" json:"feed_interval,omitempty"`
	NodeBatchSize       int64    `protobuf:"varint,2,opt,name=node_batch_size,json=nodeBatchSize,proto3" json:"node_batch_size,omitempty"`
	UpdatedNodesOnly    bool     `protobuf:"varint,3,opt,name=updated_nodes_only,json=updatedNodesOnly,proto3" json:"updated_nodes_only,omitempty"`
	DisableCidrFilter   bool     `protobuf:"varint,4,opt,name=disable_cidr_filter,json=disableCidrFilter,proto3" json:"disable_cidr_filter,omitempty"`
	CidrFilter          []string `protobuf:"bytes,5,rep,name=cidr_filter,json=cidrFilter,proto3" json:"cidr_filter,omitempty"`
	AcceptedStatusCodes []int32  `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GlobalDataFeedConfigResponse) Descriptor deprecated 

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

Deprecated: Use GlobalDataFeedConfigResponse.ProtoReflect.Descriptor instead.

func (*GlobalDataFeedConfigResponse) GetAcceptedStatusCodes 

func (x *GlobalDataFeedConfigResponse) GetAcceptedStatusCodes() []int32

func (*GlobalDataFeedConfigResponse) GetCidrFilter 

func (x *GlobalDataFeedConfigResponse) GetCidrFilter() []string

func (*GlobalDataFeedConfigResponse) GetDisableCidrFilter 

func (x *GlobalDataFeedConfigResponse) GetDisableCidrFilter() bool

func (*GlobalDataFeedConfigResponse) GetFeedInterval 

func (x *GlobalDataFeedConfigResponse) GetFeedInterval() string

func (*GlobalDataFeedConfigResponse) GetNodeBatchSize 

func (x *GlobalDataFeedConfigResponse) GetNodeBatchSize() int64

func (*GlobalDataFeedConfigResponse) GetUpdatedNodesOnly 

func (x *GlobalDataFeedConfigResponse) GetUpdatedNodesOnly() bool

func (*GlobalDataFeedConfigResponse) ProtoMessage 

func (*GlobalDataFeedConfigResponse) ProtoMessage()

func (*GlobalDataFeedConfigResponse) ProtoReflect 

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

func (*GlobalDataFeedConfigResponse) Reset 

func (x *GlobalDataFeedConfigResponse) Reset()

func (*GlobalDataFeedConfigResponse) String 

func (x *GlobalDataFeedConfigResponse) String() string
type Header struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetValue 

func (x *Header) GetValue() string

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type ListDestinationRequest 

type ListDestinationRequest struct {
	// contains filtered or unexported fields
}

func (*ListDestinationRequest) Descriptor deprecated 

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

Deprecated: Use ListDestinationRequest.ProtoReflect.Descriptor instead.

func (*ListDestinationRequest) ProtoMessage 

func (*ListDestinationRequest) ProtoMessage()

func (*ListDestinationRequest) ProtoReflect 

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

func (*ListDestinationRequest) Reset 

func (x *ListDestinationRequest) Reset()

func (*ListDestinationRequest) String 

func (x *ListDestinationRequest) String() string

type ListDestinationResponse 

type ListDestinationResponse struct {
	Destinations []*GetDestinationResponse `protobuf:"bytes,1,rep,name=destinations,proto3" json:"destinations,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDestinationResponse) Descriptor deprecated 

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

Deprecated: Use ListDestinationResponse.ProtoReflect.Descriptor instead.

func (*ListDestinationResponse) GetDestinations 

func (x *ListDestinationResponse) GetDestinations() []*GetDestinationResponse

func (*ListDestinationResponse) ProtoMessage 

func (*ListDestinationResponse) ProtoMessage()

func (*ListDestinationResponse) ProtoReflect 

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

func (*ListDestinationResponse) Reset 

func (x *ListDestinationResponse) Reset()

func (*ListDestinationResponse) String 

func (x *ListDestinationResponse) String() string

type SecretId 

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

func (*SecretId) Descriptor deprecated 

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

Deprecated: Use SecretId.ProtoReflect.Descriptor instead.

func (*SecretId) GetId 

func (x *SecretId) GetId() string

func (*SecretId) ProtoMessage 

func (*SecretId) ProtoMessage()

func (*SecretId) ProtoReflect 

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

func (*SecretId) Reset 

func (x *SecretId) Reset()

func (*SecretId) String 

func (x *SecretId) String() string

type SecretIdWithExtraPrams 

type SecretIdWithExtraPrams struct {
	Id               string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Services         string      `protobuf:"bytes,2,opt,name=services,proto3" json:"services,omitempty"`
	IntegrationTypes string      `protobuf:"bytes,3,opt,name=integration_types,json=integrationTypes,proto3" json:"integration_types,omitempty"`
	Enable           bool        `protobuf:"varint,4,opt,name=enable,proto3" json:"enable,omitempty"`
	MetaData         []*query.Kv `protobuf:"bytes,5,rep,name=meta_data,json=metaData,proto3" json:"meta_data,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretIdWithExtraPrams) Descriptor deprecated 

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

Deprecated: Use SecretIdWithExtraPrams.ProtoReflect.Descriptor instead.

func (*SecretIdWithExtraPrams) GetEnable 

func (x *SecretIdWithExtraPrams) GetEnable() bool

func (*SecretIdWithExtraPrams) GetId 

func (x *SecretIdWithExtraPrams) GetId() string

func (*SecretIdWithExtraPrams) GetIntegrationTypes 

func (x *SecretIdWithExtraPrams) GetIntegrationTypes() string

func (*SecretIdWithExtraPrams) GetMetaData 

func (x *SecretIdWithExtraPrams) GetMetaData() []*query.Kv

func (*SecretIdWithExtraPrams) GetServices 

func (x *SecretIdWithExtraPrams) GetServices() string

func (*SecretIdWithExtraPrams) ProtoMessage 

func (*SecretIdWithExtraPrams) ProtoMessage()

func (*SecretIdWithExtraPrams) ProtoReflect 

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

func (*SecretIdWithExtraPrams) Reset 

func (x *SecretIdWithExtraPrams) Reset()

func (*SecretIdWithExtraPrams) String 

func (x *SecretIdWithExtraPrams) String() string

type TestDestinationResponse 

type TestDestinationResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*TestDestinationResponse) Descriptor deprecated 

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

Deprecated: Use TestDestinationResponse.ProtoReflect.Descriptor instead.

func (*TestDestinationResponse) GetSuccess 

func (x *TestDestinationResponse) GetSuccess() bool

func (*TestDestinationResponse) ProtoMessage 

func (*TestDestinationResponse) ProtoMessage()

func (*TestDestinationResponse) ProtoReflect 

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

func (*TestDestinationResponse) Reset 

func (x *TestDestinationResponse) Reset()

func (*TestDestinationResponse) String 

func (x *TestDestinationResponse) String() string

type URLValidationRequest 

type URLValidationRequest struct {
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Types that are assignable to Credentials:
	//
	//	*URLValidationRequest_UsernamePassword
	//	*URLValidationRequest_SecretId
	//	*URLValidationRequest_SecretIdWithAddon
	//	*URLValidationRequest_Header
	//	*URLValidationRequest_Aws
	Credentials isURLValidationRequest_Credentials `protobuf_oneof:"credentials"`
	// contains filtered or unexported fields
}

func (*URLValidationRequest) Descriptor deprecated 

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

Deprecated: Use URLValidationRequest.ProtoReflect.Descriptor instead.

func (*URLValidationRequest) GetAws 

func (x *URLValidationRequest) GetAws() *AWS

func (*URLValidationRequest) GetCredentials 

func (m *URLValidationRequest) GetCredentials() isURLValidationRequest_Credentials

func (*URLValidationRequest) GetHeader 

func (x *URLValidationRequest) GetHeader() *Header

func (*URLValidationRequest) GetSecretId 

func (x *URLValidationRequest) GetSecretId() *SecretId

func (*URLValidationRequest) GetSecretIdWithAddon 

func (x *URLValidationRequest) GetSecretIdWithAddon() *SecretIdWithExtraPrams

func (*URLValidationRequest) GetUrl 

func (x *URLValidationRequest) GetUrl() string

func (*URLValidationRequest) GetUsernamePassword 

func (x *URLValidationRequest) GetUsernamePassword() *UsernamePassword

func (*URLValidationRequest) ProtoMessage 

func (*URLValidationRequest) ProtoMessage()

func (*URLValidationRequest) ProtoReflect 

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

func (*URLValidationRequest) Reset 

func (x *URLValidationRequest) Reset()

func (*URLValidationRequest) String 

func (x *URLValidationRequest) String() string

type URLValidationRequest_Aws 

type URLValidationRequest_Aws struct {
	Aws *AWS `protobuf:"bytes,6,opt,name=aws,proto3,oneof"`
}

type URLValidationRequest_Header 

type URLValidationRequest_Header struct {
	Header *Header `protobuf:"bytes,5,opt,name=header,proto3,oneof"`
}

type URLValidationRequest_SecretId 

type URLValidationRequest_SecretId struct {
	SecretId *SecretId `protobuf:"bytes,3,opt,name=secret_id,json=secretId,proto3,oneof"`
}

type URLValidationRequest_SecretIdWithAddon 

type URLValidationRequest_SecretIdWithAddon struct {
	SecretIdWithAddon *SecretIdWithExtraPrams `protobuf:"bytes,4,opt,name=secret_id_with_addon,json=secretIdWithAddon,proto3,oneof"`
}

type URLValidationRequest_UsernamePassword 

type URLValidationRequest_UsernamePassword struct {
	UsernamePassword *UsernamePassword `protobuf:"bytes,2,opt,name=username_password,json=usernamePassword,proto3,oneof"`
}

type UnimplementedDatafeedServiceServer 

type UnimplementedDatafeedServiceServer struct {
}

UnimplementedDatafeedServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDatafeedServiceServer) AddDestination 

func (*UnimplementedDatafeedServiceServer) AddDestination(context.Context, *AddDestinationRequest) (*AddDestinationResponse, error)

func (*UnimplementedDatafeedServiceServer) DeleteDestination 

func (*UnimplementedDatafeedServiceServer) DeleteDestination(context.Context, *DeleteDestinationRequest) (*DeleteDestinationResponse, error)

func (*UnimplementedDatafeedServiceServer) EnableDestination 

func (*UnimplementedDatafeedServiceServer) EnableDestination(context.Context, *UpdateDestinationEnableRequest) (*GetDestinationResponse, error)

func (*UnimplementedDatafeedServiceServer) GetDestination 

func (*UnimplementedDatafeedServiceServer) GetDestination(context.Context, *GetDestinationRequest) (*GetDestinationResponse, error)

func (*UnimplementedDatafeedServiceServer) GlobalDataFeedConfig 

func (*UnimplementedDatafeedServiceServer) GlobalDataFeedConfig(context.Context, *GlobalDataFeedConfigRequest) (*GlobalDataFeedConfigResponse, error)

func (*UnimplementedDatafeedServiceServer) ListDestinations 

func (*UnimplementedDatafeedServiceServer) ListDestinations(context.Context, *ListDestinationRequest) (*ListDestinationResponse, error)

func (*UnimplementedDatafeedServiceServer) TestDestination 

func (*UnimplementedDatafeedServiceServer) TestDestination(context.Context, *URLValidationRequest) (*TestDestinationResponse, error)

func (*UnimplementedDatafeedServiceServer) UpdateDestination 

func (*UnimplementedDatafeedServiceServer) UpdateDestination(context.Context, *UpdateDestinationRequest) (*UpdateDestinationResponse, error)

type UpdateDestinationEnableRequest 

type UpdateDestinationEnableRequest struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Enable bool   `protobuf:"varint,2,opt,name=enable,proto3" json:"enable,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDestinationEnableRequest) Descriptor deprecated 

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

Deprecated: Use UpdateDestinationEnableRequest.ProtoReflect.Descriptor instead.

func (*UpdateDestinationEnableRequest) GetEnable 

func (x *UpdateDestinationEnableRequest) GetEnable() bool

func (*UpdateDestinationEnableRequest) GetId 

func (x *UpdateDestinationEnableRequest) GetId() string

func (*UpdateDestinationEnableRequest) ProtoMessage 

func (*UpdateDestinationEnableRequest) ProtoMessage()

func (*UpdateDestinationEnableRequest) ProtoReflect 

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

func (*UpdateDestinationEnableRequest) Reset 

func (x *UpdateDestinationEnableRequest) Reset()

func (*UpdateDestinationEnableRequest) String 

func (x *UpdateDestinationEnableRequest) String() string

type UpdateDestinationRequest 

type UpdateDestinationRequest struct {
	Id               string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name             string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Url              string      `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Secret           string      `protobuf:"bytes,4,opt,name=secret,proto3" json:"secret,omitempty"`
	Services         string      `protobuf:"bytes,5,opt,name=services,proto3" json:"services,omitempty"`
	IntegrationTypes string      `protobuf:"bytes,6,opt,name=integration_types,json=integrationTypes,proto3" json:"integration_types,omitempty"`
	Enable           bool        `protobuf:"varint,7,opt,name=enable,proto3" json:"enable,omitempty"`
	MetaData         []*query.Kv `protobuf:"bytes,8,rep,name=meta_data,json=metaData,proto3" json:"meta_data,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDestinationRequest) Descriptor deprecated 

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

Deprecated: Use UpdateDestinationRequest.ProtoReflect.Descriptor instead.

func (*UpdateDestinationRequest) GetEnable 

func (x *UpdateDestinationRequest) GetEnable() bool

func (*UpdateDestinationRequest) GetId 

func (x *UpdateDestinationRequest) GetId() string

func (*UpdateDestinationRequest) GetIntegrationTypes 

func (x *UpdateDestinationRequest) GetIntegrationTypes() string

func (*UpdateDestinationRequest) GetMetaData 

func (x *UpdateDestinationRequest) GetMetaData() []*query.Kv

func (*UpdateDestinationRequest) GetName 

func (x *UpdateDestinationRequest) GetName() string

func (*UpdateDestinationRequest) GetSecret 

func (x *UpdateDestinationRequest) GetSecret() string

func (*UpdateDestinationRequest) GetServices 

func (x *UpdateDestinationRequest) GetServices() string

func (*UpdateDestinationRequest) GetUrl 

func (x *UpdateDestinationRequest) GetUrl() string

func (*UpdateDestinationRequest) ProtoMessage 

func (*UpdateDestinationRequest) ProtoMessage()

func (*UpdateDestinationRequest) ProtoReflect 

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

func (*UpdateDestinationRequest) Reset 

func (x *UpdateDestinationRequest) Reset()

func (*UpdateDestinationRequest) String 

func (x *UpdateDestinationRequest) String() string

type UpdateDestinationResponse 

type UpdateDestinationResponse struct {
	Id               int64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name             string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Url              string      `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Secret           string      `protobuf:"bytes,4,opt,name=secret,proto3" json:"secret,omitempty"`
	Services         string      `protobuf:"bytes,5,opt,name=services,proto3" json:"services,omitempty"`
	IntegrationTypes string      `protobuf:"bytes,6,opt,name=integration_types,json=integrationTypes,proto3" json:"integration_types,omitempty"`
	Enable           bool        `protobuf:"varint,7,opt,name=enable,proto3" json:"enable,omitempty"`
	MetaData         []*query.Kv `protobuf:"bytes,8,rep,name=meta_data,json=metaData,proto3" json:"meta_data,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDestinationResponse) Descriptor deprecated 

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

Deprecated: Use UpdateDestinationResponse.ProtoReflect.Descriptor instead.

func (*UpdateDestinationResponse) GetEnable 

func (x *UpdateDestinationResponse) GetEnable() bool

func (*UpdateDestinationResponse) GetId 

func (x *UpdateDestinationResponse) GetId() int64

func (*UpdateDestinationResponse) GetIntegrationTypes 

func (x *UpdateDestinationResponse) GetIntegrationTypes() string

func (*UpdateDestinationResponse) GetMetaData 

func (x *UpdateDestinationResponse) GetMetaData() []*query.Kv

func (*UpdateDestinationResponse) GetName 

func (x *UpdateDestinationResponse) GetName() string

func (*UpdateDestinationResponse) GetSecret 

func (x *UpdateDestinationResponse) GetSecret() string

func (*UpdateDestinationResponse) GetServices 

func (x *UpdateDestinationResponse) GetServices() string

func (*UpdateDestinationResponse) GetUrl 

func (x *UpdateDestinationResponse) GetUrl() string

func (*UpdateDestinationResponse) ProtoMessage 

func (*UpdateDestinationResponse) ProtoMessage()

func (*UpdateDestinationResponse) ProtoReflect 

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

func (*UpdateDestinationResponse) Reset 

func (x *UpdateDestinationResponse) Reset()

func (*UpdateDestinationResponse) String 

func (x *UpdateDestinationResponse) String() string

type UsernamePassword 

type UsernamePassword struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*UsernamePassword) Descriptor deprecated 

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

Deprecated: Use UsernamePassword.ProtoReflect.Descriptor instead.

func (*UsernamePassword) GetPassword 

func (x *UsernamePassword) GetPassword() string

func (*UsernamePassword) GetUsername 

func (x *UsernamePassword) GetUsername() string

func (*UsernamePassword) ProtoMessage 

func (*UsernamePassword) ProtoMessage()

func (*UsernamePassword) ProtoReflect 

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

func (*UsernamePassword) Reset 

func (x *UsernamePassword) Reset()

func (*UsernamePassword) String 

func (x *UsernamePassword) String() string

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.