Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dataconnectors

package

Go to main page

Versions in this module

v0

v0.20250110.1074108

Jan 10, 2025

v0.20241212.1154051

Dec 12, 2024

v0.20241209.1115630

Dec 9, 2024

v0.20241206.1180327

Dec 6, 2024

v0.20241205.1102105

Dec 5, 2024

v0.20241203.1090052

Dec 3, 2024

v0.20241128.1112539

Nov 28, 2024

v0.20241128.1084944

Nov 28, 2024

v0.20241126.1110949

Nov 26, 2024

Changes in this version

+ func PossibleValuesForCcpAuthType() []string

+ func PossibleValuesForDataConnectorKind() []string

+ func PossibleValuesForDataTypeState() []string

+ func PossibleValuesForHTTPMethodVerb() []string

+ func PossibleValuesForRestApiPollerRequestPagingKind() []string

+ func ValidateDataConnectorID(input interface{}, key string) (warnings []string, errors []error)

+ func ValidateWorkspaceID(input interface{}, key string) (warnings []string, errors []error)

+ type AADDataConnector struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ Properties *AADDataConnectorProperties

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s AADDataConnector) DataConnector() BaseDataConnectorImpl

+ func (s AADDataConnector) MarshalJSON() ([]byte, error)

+ type AADDataConnectorProperties struct

+ DataTypes *AlertsDataTypeOfDataConnector

+ TenantId *string

+ type AATPDataConnector struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ Properties *AATPDataConnectorProperties

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s AATPDataConnector) DataConnector() BaseDataConnectorImpl

+ func (s AATPDataConnector) MarshalJSON() ([]byte, error)

+ type AATPDataConnectorProperties struct

+ DataTypes *AlertsDataTypeOfDataConnector

+ TenantId *string

+ type ASCDataConnector struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ Properties *ASCDataConnectorProperties

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s ASCDataConnector) DataConnector() BaseDataConnectorImpl

+ func (s ASCDataConnector) MarshalJSON() ([]byte, error)

+ type ASCDataConnectorProperties struct

+ DataTypes *AlertsDataTypeOfDataConnector

+ SubscriptionId *string

+ type AWSAuthModel struct

+ ExternalId *string

+ RoleArn string

+ Type CcpAuthType

+ func (s AWSAuthModel) CcpAuthConfig() BaseCcpAuthConfigImpl

+ func (s AWSAuthModel) MarshalJSON() ([]byte, error)

+ type AlertsDataTypeOfDataConnector struct

+ Alerts *DataConnectorDataTypeCommon

+ type ApiKeyAuthModel struct

+ ApiKey string

+ ApiKeyIdentifier *string

+ ApiKeyName string

+ IsApiKeyInPostPayload *bool

+ Type CcpAuthType

+ func (s ApiKeyAuthModel) CcpAuthConfig() BaseCcpAuthConfigImpl

+ func (s ApiKeyAuthModel) MarshalJSON() ([]byte, error)

+ type AwsCloudTrailDataConnector struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ Properties *AwsCloudTrailDataConnectorProperties

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s AwsCloudTrailDataConnector) DataConnector() BaseDataConnectorImpl

+ func (s AwsCloudTrailDataConnector) MarshalJSON() ([]byte, error)

+ type AwsCloudTrailDataConnectorDataTypes struct

+ Logs *DataConnectorDataTypeCommon

+ type AwsCloudTrailDataConnectorProperties struct

+ AwsRoleArn *string

+ DataTypes *AwsCloudTrailDataConnectorDataTypes

+ type BaseCcpAuthConfigImpl struct

+ Type CcpAuthType

+ func (s BaseCcpAuthConfigImpl) CcpAuthConfig() BaseCcpAuthConfigImpl

+ type BaseDataConnectorImpl struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s BaseDataConnectorImpl) DataConnector() BaseDataConnectorImpl

+ type BasicAuthModel struct

+ Password string

+ Type CcpAuthType

+ UserName string

+ func (s BasicAuthModel) CcpAuthConfig() BaseCcpAuthConfigImpl

+ func (s BasicAuthModel) MarshalJSON() ([]byte, error)

+ type CcpAuthConfig interface

+ CcpAuthConfig func() BaseCcpAuthConfigImpl

+ func UnmarshalCcpAuthConfigImplementation(input []byte) (CcpAuthConfig, error)

+ type CcpAuthType string

+ const CcpAuthTypeAPIKey

+ const CcpAuthTypeAWS

+ const CcpAuthTypeBasic

+ const CcpAuthTypeGCP

+ const CcpAuthTypeGitHub

+ const CcpAuthTypeJwtToken

+ const CcpAuthTypeNone

+ const CcpAuthTypeOAuthTwo

+ const CcpAuthTypeOracle

+ const CcpAuthTypeServiceBus

+ const CcpAuthTypeSession

+ func (s *CcpAuthType) UnmarshalJSON(bytes []byte) error

+ type CcpResponseConfig struct

+ CompressionAlgo *string

+ ConvertChildPropertiesToArray *bool

+ CsvDelimiter *string

+ CsvEscape *string

+ EventsJsonPaths []string

+ Format *string

+ HasCsvBoundary *bool

+ HasCsvHeader *bool

+ IsGzipCompressed *bool

+ SuccessStatusJsonPath *string

+ SuccessStatusValue *string

+ type CreateOrUpdateOperationResponse struct

+ HttpResponse *http.Response

+ Model DataConnector

+ OData *odata.OData

+ type DCRConfiguration struct

+ DataCollectionEndpoint string

+ DataCollectionRuleImmutableId string

+ StreamName string

+ type DataConnector interface

+ DataConnector func() BaseDataConnectorImpl

+ func UnmarshalDataConnectorImplementation(input []byte) (DataConnector, error)

+ type DataConnectorDataTypeCommon struct

+ State *DataTypeState

+ type DataConnectorId struct

+ DataConnectorId string

+ ResourceGroupName string

+ SubscriptionId string

+ WorkspaceName string

+ func NewDataConnectorID(subscriptionId string, resourceGroupName string, workspaceName string, ...) DataConnectorId

+ func ParseDataConnectorID(input string) (*DataConnectorId, error)

+ func ParseDataConnectorIDInsensitively(input string) (*DataConnectorId, error)

+ func (id *DataConnectorId) FromParseResult(input resourceids.ParseResult) error

+ func (id DataConnectorId) ID() string

+ func (id DataConnectorId) Segments() []resourceids.Segment

+ func (id DataConnectorId) String() string

+ type DataConnectorKind string

+ const DataConnectorKindAmazonWebServicesCloudTrail

+ const DataConnectorKindAzureActiveDirectory

+ const DataConnectorKindAzureAdvancedThreatProtection

+ const DataConnectorKindAzureSecurityCenter

+ const DataConnectorKindMicrosoftCloudAppSecurity

+ const DataConnectorKindMicrosoftDefenderAdvancedThreatProtection

+ const DataConnectorKindMicrosoftThreatIntelligence

+ const DataConnectorKindOfficeThreeSixFive

+ const DataConnectorKindPremiumMicrosoftDefenderForThreatIntelligence

+ const DataConnectorKindRestApiPoller

+ const DataConnectorKindThreatIntelligence

+ func (s *DataConnectorKind) UnmarshalJSON(bytes []byte) error

+ type DataConnectorOperationPredicate struct

+ func (p DataConnectorOperationPredicate) Matches(input DataConnector) bool

+ type DataConnectorsClient struct

+ Client *resourcemanager.Client

+ func NewDataConnectorsClientWithBaseURI(sdkApi sdkEnv.Api) (*DataConnectorsClient, error)

+ func (c DataConnectorsClient) CreateOrUpdate(ctx context.Context, id DataConnectorId, input DataConnector) (result CreateOrUpdateOperationResponse, err error)

+ func (c DataConnectorsClient) Delete(ctx context.Context, id DataConnectorId) (result DeleteOperationResponse, err error)

+ func (c DataConnectorsClient) Get(ctx context.Context, id DataConnectorId) (result GetOperationResponse, err error)

+ func (c DataConnectorsClient) List(ctx context.Context, id WorkspaceId) (result ListOperationResponse, err error)

+ func (c DataConnectorsClient) ListComplete(ctx context.Context, id WorkspaceId) (ListCompleteResult, error)

+ func (c DataConnectorsClient) ListCompleteMatchingPredicate(ctx context.Context, id WorkspaceId, predicate DataConnectorOperationPredicate) (result ListCompleteResult, err error)

+ type DataTypeState string

+ const DataTypeStateDisabled

+ const DataTypeStateEnabled

+ func (s *DataTypeState) UnmarshalJSON(bytes []byte) error

+ type DeleteOperationResponse struct

+ HttpResponse *http.Response

+ OData *odata.OData

+ type GCPAuthModel struct

+ ProjectNumber string

+ ServiceAccountEmail string

+ Type CcpAuthType

+ WorkloadIdentityProviderId string

+ func (s GCPAuthModel) CcpAuthConfig() BaseCcpAuthConfigImpl

+ func (s GCPAuthModel) MarshalJSON() ([]byte, error)

+ type GenericBlobSbsAuthModel struct

+ CredentialsConfig *map[string]string

+ StorageAccountCredentialsConfig *map[string]string

+ Type CcpAuthType

+ func (s GenericBlobSbsAuthModel) CcpAuthConfig() BaseCcpAuthConfigImpl

+ func (s GenericBlobSbsAuthModel) MarshalJSON() ([]byte, error)

+ type GetOperationResponse struct

+ HttpResponse *http.Response

+ Model DataConnector

+ OData *odata.OData

+ type GitHubAuthModel struct

+ InstallationId *string

+ Type CcpAuthType

+ func (s GitHubAuthModel) CcpAuthConfig() BaseCcpAuthConfigImpl

+ func (s GitHubAuthModel) MarshalJSON() ([]byte, error)

+ type HTTPMethodVerb string

+ const HTTPMethodVerbDELETE

+ const HTTPMethodVerbGET

+ const HTTPMethodVerbPOST

+ const HTTPMethodVerbPUT

+ func (s *HTTPMethodVerb) UnmarshalJSON(bytes []byte) error

+ type JwtAuthModel struct

+ Headers *map[string]string

+ IsCredentialsInHeaders *bool

+ IsJsonRequest *bool

+ Password map[string]string

+ QueryParameters *map[string]string

+ RequestTimeoutInSeconds *int64

+ TokenEndpoint string

+ Type CcpAuthType

+ UserName map[string]string

+ func (s JwtAuthModel) CcpAuthConfig() BaseCcpAuthConfigImpl

+ func (s JwtAuthModel) MarshalJSON() ([]byte, error)

+ type ListCompleteResult struct

+ Items []DataConnector

+ LatestHttpResponse *http.Response

+ type ListCustomPager struct

+ NextLink *odata.Link

+ func (p *ListCustomPager) NextPageLink() *odata.Link

+ type ListOperationResponse struct

+ HttpResponse *http.Response

+ Model *[]DataConnector

+ OData *odata.OData

+ type MCASDataConnector struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ Properties *MCASDataConnectorProperties

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s MCASDataConnector) DataConnector() BaseDataConnectorImpl

+ func (s MCASDataConnector) MarshalJSON() ([]byte, error)

+ type MCASDataConnectorDataTypes struct

+ Alerts *DataConnectorDataTypeCommon

+ DiscoveryLogs *DataConnectorDataTypeCommon

+ type MCASDataConnectorProperties struct

+ DataTypes *MCASDataConnectorDataTypes

+ TenantId *string

+ type MDATPDataConnector struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ Properties *MDATPDataConnectorProperties

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s MDATPDataConnector) DataConnector() BaseDataConnectorImpl

+ func (s MDATPDataConnector) MarshalJSON() ([]byte, error)

+ type MDATPDataConnectorProperties struct

+ DataTypes *AlertsDataTypeOfDataConnector

+ TenantId *string

+ type MSTIDataConnector struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ Properties *MSTIDataConnectorProperties

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s MSTIDataConnector) DataConnector() BaseDataConnectorImpl

+ func (s MSTIDataConnector) MarshalJSON() ([]byte, error)

+ type MSTIDataConnectorDataTypes struct

+ MicrosoftEmergingThreatFeed MSTIDataConnectorDataTypesMicrosoftEmergingThreatFeed

+ type MSTIDataConnectorDataTypesMicrosoftEmergingThreatFeed struct

+ LookbackPeriod string

+ State *DataTypeState

+ func (o *MSTIDataConnectorDataTypesMicrosoftEmergingThreatFeed) GetLookbackPeriodAsTime() (*time.Time, error)

+ func (o *MSTIDataConnectorDataTypesMicrosoftEmergingThreatFeed) SetLookbackPeriodAsTime(input time.Time)

+ type MSTIDataConnectorProperties struct

+ DataTypes MSTIDataConnectorDataTypes

+ TenantId *string

+ type NoneAuthModel struct

+ Type CcpAuthType

+ func (s NoneAuthModel) CcpAuthConfig() BaseCcpAuthConfigImpl

+ func (s NoneAuthModel) MarshalJSON() ([]byte, error)

+ type OAuthModel struct

+ AccessTokenPrepend *string

+ AuthorizationCode *string

+ AuthorizationEndpoint *string

+ AuthorizationEndpointHeaders *map[string]string

+ AuthorizationEndpointQueryParameters *map[string]string

+ ClientId string

+ ClientSecret string

+ GrantType string

+ IsCredentialsInHeaders *bool

+ IsJwtBearerFlow *bool

+ RedirectUri *string

+ Scope *string

+ TokenEndpoint string

+ TokenEndpointHeaders *map[string]string

+ TokenEndpointQueryParameters *map[string]string

+ Type CcpAuthType

+ func (s OAuthModel) CcpAuthConfig() BaseCcpAuthConfigImpl

+ func (s OAuthModel) MarshalJSON() ([]byte, error)

+ type OfficeDataConnector struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ Properties *OfficeDataConnectorProperties

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s OfficeDataConnector) DataConnector() BaseDataConnectorImpl

+ func (s OfficeDataConnector) MarshalJSON() ([]byte, error)

+ type OfficeDataConnectorDataTypes struct

+ Exchange *DataConnectorDataTypeCommon

+ SharePoint *DataConnectorDataTypeCommon

+ Teams *DataConnectorDataTypeCommon

+ type OfficeDataConnectorProperties struct

+ DataTypes *OfficeDataConnectorDataTypes

+ TenantId *string

+ type OracleAuthModel struct

+ PemFile string

+ PublicFingerprint string

+ TenantId string

+ Type CcpAuthType

+ UserId string

+ func (s OracleAuthModel) CcpAuthConfig() BaseCcpAuthConfigImpl

+ func (s OracleAuthModel) MarshalJSON() ([]byte, error)

+ type PremiumMdtiDataConnectorDataTypes struct

+ Connector DataConnectorDataTypeCommon

+ type PremiumMdtiDataConnectorProperties struct

+ DataTypes PremiumMdtiDataConnectorDataTypes

+ LookbackPeriod string

+ RequiredSKUsPresent *bool

+ TenantId *string

+ func (o *PremiumMdtiDataConnectorProperties) GetLookbackPeriodAsTime() (*time.Time, error)

+ func (o *PremiumMdtiDataConnectorProperties) SetLookbackPeriodAsTime(input time.Time)

+ type PremiumMicrosoftDefenderForThreatIntelligence struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ Properties *PremiumMdtiDataConnectorProperties

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s PremiumMicrosoftDefenderForThreatIntelligence) DataConnector() BaseDataConnectorImpl

+ func (s PremiumMicrosoftDefenderForThreatIntelligence) MarshalJSON() ([]byte, error)

+ type RawCcpAuthConfigImpl struct

+ Type string

+ Values map[string]interface{}

+ func (s RawCcpAuthConfigImpl) CcpAuthConfig() BaseCcpAuthConfigImpl

+ type RawDataConnectorImpl struct

+ Type string

+ Values map[string]interface{}

+ func (s RawDataConnectorImpl) DataConnector() BaseDataConnectorImpl

+ type RestApiPollerDataConnector struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ Properties *RestApiPollerDataConnectorProperties

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s RestApiPollerDataConnector) DataConnector() BaseDataConnectorImpl

+ func (s RestApiPollerDataConnector) MarshalJSON() ([]byte, error)

+ type RestApiPollerDataConnectorProperties struct

+ AddOnAttributes *map[string]string

+ Auth CcpAuthConfig

+ ConnectorDefinitionName string

+ DataType *string

+ DcrConfig *DCRConfiguration

+ IsActive *bool

+ Paging *RestApiPollerRequestPagingConfig

+ Request RestApiPollerRequestConfig

+ Response *CcpResponseConfig

+ func (s *RestApiPollerDataConnectorProperties) UnmarshalJSON(bytes []byte) error

+ type RestApiPollerRequestConfig struct

+ ApiEndpoint string

+ EndTimeAttributeName *string

+ HTTPMethod *HTTPMethodVerb

+ Headers *map[string]string

+ IsPostPayloadJson *bool

+ QueryParameters *map[string]interface{}

+ QueryParametersTemplate *string

+ QueryTimeFormat *string

+ QueryTimeIntervalAttributeName *string

+ QueryTimeIntervalDelimiter *string

+ QueryTimeIntervalPrepend *string

+ QueryWindowInMin *int64

+ RateLimitQPS *int64

+ RetryCount *int64

+ StartTimeAttributeName *string

+ TimeoutInSeconds *int64

+ type RestApiPollerRequestPagingConfig struct

+ PageSize *int64

+ PageSizeParameterName *string

+ PagingType RestApiPollerRequestPagingKind

+ type RestApiPollerRequestPagingKind string

+ const RestApiPollerRequestPagingKindCountBasedPaging

+ const RestApiPollerRequestPagingKindLinkHeader

+ const RestApiPollerRequestPagingKindNextPageToken

+ const RestApiPollerRequestPagingKindNextPageURL

+ const RestApiPollerRequestPagingKindOffset

+ const RestApiPollerRequestPagingKindPersistentLinkHeader

+ const RestApiPollerRequestPagingKindPersistentToken

+ func (s *RestApiPollerRequestPagingKind) UnmarshalJSON(bytes []byte) error

+ type SessionAuthModel struct

+ Headers *map[string]string

+ IsPostPayloadJson *bool

+ Password map[string]string

+ QueryParameters *map[string]interface{}

+ SessionIdName *string

+ SessionLoginRequestUri *string

+ SessionTimeoutInMinutes *int64

+ Type CcpAuthType

+ UserName map[string]string

+ func (s SessionAuthModel) CcpAuthConfig() BaseCcpAuthConfigImpl

+ func (s SessionAuthModel) MarshalJSON() ([]byte, error)

+ type TIDataConnector struct

+ Etag *string

+ Id *string

+ Kind DataConnectorKind

+ Name *string

+ Properties *TIDataConnectorProperties

+ SystemData *systemdata.SystemData

+ Type *string

+ func (s TIDataConnector) DataConnector() BaseDataConnectorImpl

+ func (s TIDataConnector) MarshalJSON() ([]byte, error)

+ type TIDataConnectorDataTypes struct

+ Indicators *DataConnectorDataTypeCommon

+ type TIDataConnectorProperties struct

+ DataTypes *TIDataConnectorDataTypes

+ TenantId *string

+ TipLookbackPeriod *string

+ func (o *TIDataConnectorProperties) GetTipLookbackPeriodAsTime() (*time.Time, error)

+ func (o *TIDataConnectorProperties) SetTipLookbackPeriodAsTime(input time.Time)

+ type WorkspaceId struct

+ ResourceGroupName string

+ SubscriptionId string

+ WorkspaceName string

+ func NewWorkspaceID(subscriptionId string, resourceGroupName string, workspaceName string) WorkspaceId

+ func ParseWorkspaceID(input string) (*WorkspaceId, error)

+ func ParseWorkspaceIDInsensitively(input string) (*WorkspaceId, error)

+ func (id *WorkspaceId) FromParseResult(input resourceids.ParseResult) error

+ func (id WorkspaceId) ID() string

+ func (id WorkspaceId) Segments() []resourceids.Segment

+ func (id WorkspaceId) String() string