\SourcesAPI

All URIs are relative to https://api.segmentapis.com

Method	HTTP request	Description
AddLabelsToSource	Post /sources/{sourceId}/labels	Add Labels to Source
CreateSource	Post /sources	Create Source
CreateWriteKeyForSource	Post /sources/{sourceId}/writekey	Create Write Key for Source
DeleteSource	Delete /sources/{sourceId}	Delete Source
GetSource	Get /sources/{sourceId}	Get Source
ListConnectedDestinationsFromSource	Get /sources/{sourceId}/connected-destinations	List Connected Destinations from Source
ListConnectedWarehousesFromSource	Get /sources/{sourceId}/connected-warehouses	List Connected Warehouses from Source
ListSchemaSettingsInSource	Get /sources/{sourceId}/settings	List Schema Settings in Source
ListSources	Get /sources	List Sources
RemoveWriteKeyFromSource	Delete /sources/{sourceId}/writekey/{writeKey}	Remove Write Key from Source
ReplaceLabelsInSource	Put /sources/{sourceId}/labels	Replace Labels in Source
UpdateSchemaSettingsInSource	Patch /sources/{sourceId}/settings	Update Schema Settings in Source
UpdateSource	Patch /sources/{sourceId}	Update Source

Operation: AddLabelsToSource

AddLabelsToSource200Response AddLabelsToSource(ctx, sourceId).AddLabelsToSourceV1Input(addLabelsToSourceV1Input).Execute()

Add Labels to Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    sourceId := "rh5BDZp6QDHvXFCkibm1pR" // string | 
    addLabelsToSourceV1Input := *api.NewAddLabelsToSourceV1Input([]api.LabelV1{*api.NewLabelV1("Key_example", "Value_example")}) // AddLabelsToSourceV1Input | 

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.AddLabelsToSource(ctx, sourceId).AddLabelsToSourceV1Input(addLabelsToSourceV1Input).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.AddLabelsToSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `AddLabelsToSource`: AddLabelsToSource200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.AddLabelsToSource`: %v\n", resp.GetData())
}

Path Parameters

Name	Type	Description	Notes
ctx	context.Context	context for authentication, logging, cancellation, deadlines, tracing, etc.
sourceId	string

Other Parameters

Other parameters are passed through a pointer to a apiAddLabelsToSourceRequest struct via the builder pattern

Name	Type	Description	Notes

addLabelsToSourceV1Input | AddLabelsToSourceV1Input | |

Return type

AddLabelsToSource200Response

Authorization

token

HTTP request headers

Content-Type: application/json, application/vnd.segment.v1+json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json
Accept: application/vnd.segment.v1+json, application/json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: CreateSource

CreateSource201Response CreateSource(ctx).CreateSourceV1Input(createSourceV1Input).Execute()

Create Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    createSourceV1Input := *api.NewCreateSourceV1Input("Slug_example", false, "MetadataId_example") // CreateSourceV1Input | 

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.CreateSource(ctx).CreateSourceV1Input(createSourceV1Input).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.CreateSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `CreateSource`: CreateSource201Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.CreateSource`: %v\n", resp.GetData())
}

Path Parameters

Other Parameters

Other parameters are passed through a pointer to a apiCreateSourceRequest struct via the builder pattern

Name	Type	Description	Notes
createSourceV1Input	CreateSourceV1Input

Return type

CreateSource201Response

Authorization

token

HTTP request headers

Content-Type: application/json, application/vnd.segment.v1+json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json
Accept: application/vnd.segment.v1+json, application/json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: CreateWriteKeyForSource

CreateWriteKeyForSource200Response CreateWriteKeyForSource(ctx, sourceId).Execute()

Create Write Key for Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    sourceId := "idR4zzU9iGcGJgoAX891nf" // string | 

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.CreateWriteKeyForSource(ctx, sourceId).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.CreateWriteKeyForSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `CreateWriteKeyForSource`: CreateWriteKeyForSource200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.CreateWriteKeyForSource`: %v\n", resp.GetData())
}

Path Parameters

Name	Type	Description	Notes
ctx	context.Context	context for authentication, logging, cancellation, deadlines, tracing, etc.
sourceId	string

Other Parameters

Other parameters are passed through a pointer to a apiCreateWriteKeyForSourceRequest struct via the builder pattern

Name	Type	Description	Notes

Return type

CreateWriteKeyForSource200Response

Authorization

token

HTTP request headers

Content-Type: Not defined
Accept: application/vnd.segment.v1alpha+json, application/json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: DeleteSource

DeleteSource200Response DeleteSource(ctx, sourceId).Execute()

Delete Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    sourceId := "rYxTjyaPtAELCjnFE5EYfM" // string | 

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.DeleteSource(ctx, sourceId).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.DeleteSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `DeleteSource`: DeleteSource200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.DeleteSource`: %v\n", resp.GetData())
}

Path Parameters

Name	Type	Description	Notes
ctx	context.Context	context for authentication, logging, cancellation, deadlines, tracing, etc.
sourceId	string

Other Parameters

Other parameters are passed through a pointer to a apiDeleteSourceRequest struct via the builder pattern

Name	Type	Description	Notes

Return type

DeleteSource200Response

Authorization

token

HTTP request headers

Content-Type: Not defined
Accept: application/vnd.segment.v1+json, application/json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: GetSource

GetSource200Response GetSource(ctx, sourceId).Execute()

Get Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    sourceId := "qQEHquLrjRDN9j1ByrChyn" // string | 

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.GetSource(ctx, sourceId).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.GetSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `GetSource`: GetSource200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.GetSource`: %v\n", resp.GetData())
}

Path Parameters

Name	Type	Description	Notes
ctx	context.Context	context for authentication, logging, cancellation, deadlines, tracing, etc.
sourceId	string

Other Parameters

Other parameters are passed through a pointer to a apiGetSourceRequest struct via the builder pattern

Name	Type	Description	Notes

Return type

GetSource200Response

Authorization

token

HTTP request headers

Content-Type: Not defined
Accept: application/vnd.segment.v1+json, application/json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: ListConnectedDestinationsFromSource

ListConnectedDestinationsFromSource200Response ListConnectedDestinationsFromSource(ctx, sourceId).Pagination(pagination).Execute()

List Connected Destinations from Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    sourceId := "qQEHquLrjRDN9j1ByrChyn" // string | 
    pagination := *api.NewPaginationInput(10) // PaginationInput | Required pagination params for the request.  This parameter exists in alpha. (optional)

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.ListConnectedDestinationsFromSource(ctx, sourceId).Pagination(pagination).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.ListConnectedDestinationsFromSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `ListConnectedDestinationsFromSource`: ListConnectedDestinationsFromSource200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.ListConnectedDestinationsFromSource`: %v\n", resp.GetData())
}

Path Parameters

Name	Type	Description	Notes
ctx	context.Context	context for authentication, logging, cancellation, deadlines, tracing, etc.
sourceId	string

Other Parameters

Other parameters are passed through a pointer to a apiListConnectedDestinationsFromSourceRequest struct via the builder pattern

Name	Type	Description	Notes

pagination | PaginationInput | Required pagination params for the request. This parameter exists in alpha. |

Return type

ListConnectedDestinationsFromSource200Response

Authorization

token

HTTP request headers

Content-Type: Not defined
Accept: application/vnd.segment.v1+json, application/json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: ListConnectedWarehousesFromSource

ListConnectedWarehousesFromSource200Response ListConnectedWarehousesFromSource(ctx, sourceId).Pagination(pagination).Execute()

List Connected Warehouses from Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    sourceId := "qQEHquLrjRDN9j1ByrChyn" // string | 
    pagination := *api.NewPaginationInput(10) // PaginationInput | Required pagination params for the request.  This parameter exists in alpha. (optional)

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.ListConnectedWarehousesFromSource(ctx, sourceId).Pagination(pagination).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.ListConnectedWarehousesFromSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `ListConnectedWarehousesFromSource`: ListConnectedWarehousesFromSource200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.ListConnectedWarehousesFromSource`: %v\n", resp.GetData())
}

Path Parameters

Name	Type	Description	Notes
ctx	context.Context	context for authentication, logging, cancellation, deadlines, tracing, etc.
sourceId	string

Other Parameters

Other parameters are passed through a pointer to a apiListConnectedWarehousesFromSourceRequest struct via the builder pattern

Name	Type	Description	Notes

pagination | PaginationInput | Required pagination params for the request. This parameter exists in alpha. |

Return type

ListConnectedWarehousesFromSource200Response

Authorization

token

HTTP request headers

Content-Type: Not defined
Accept: application/vnd.segment.v1+json, application/json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: ListSchemaSettingsInSource

ListSchemaSettingsInSource200Response ListSchemaSettingsInSource(ctx, sourceId).Execute()

List Schema Settings in Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    sourceId := "qQEHquLrjRDN9j1ByrChyn" // string | 

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.ListSchemaSettingsInSource(ctx, sourceId).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.ListSchemaSettingsInSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `ListSchemaSettingsInSource`: ListSchemaSettingsInSource200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.ListSchemaSettingsInSource`: %v\n", resp.GetData())
}

Path Parameters

Name	Type	Description	Notes
ctx	context.Context	context for authentication, logging, cancellation, deadlines, tracing, etc.
sourceId	string

Other Parameters

Other parameters are passed through a pointer to a apiListSchemaSettingsInSourceRequest struct via the builder pattern

Name	Type	Description	Notes

Return type

ListSchemaSettingsInSource200Response

Authorization

token

HTTP request headers

Content-Type: Not defined
Accept: application/vnd.segment.v1+json, application/json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: ListSources

ListSources200Response ListSources(ctx).Pagination(pagination).Execute()

List Sources

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    pagination := *api.NewPaginationInput(10) // PaginationInput | Defines the pagination parameters.  This parameter exists in alpha. (optional)

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.ListSources(ctx).Pagination(pagination).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.ListSources``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `ListSources`: ListSources200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.ListSources`: %v\n", resp.GetData())
}

Path Parameters

Other Parameters

Other parameters are passed through a pointer to a apiListSourcesRequest struct via the builder pattern

Name	Type	Description	Notes
pagination	PaginationInput	Defines the pagination parameters. This parameter exists in alpha.

Return type

ListSources200Response

Authorization

token

HTTP request headers

Content-Type: Not defined
Accept: application/vnd.segment.v1+json, application/json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: RemoveWriteKeyFromSource

RemoveWriteKeyFromSource200Response RemoveWriteKeyFromSource(ctx, sourceId, writeKey).Execute()

Remove Write Key from Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    sourceId := "idR4zzU9iGcGJgoAX891nf" // string | 
    writeKey := "wk123" // string | 

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.RemoveWriteKeyFromSource(ctx, sourceId, writeKey).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.RemoveWriteKeyFromSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `RemoveWriteKeyFromSource`: RemoveWriteKeyFromSource200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.RemoveWriteKeyFromSource`: %v\n", resp.GetData())
}

Path Parameters

Name	Type	Description
ctx	context.Context	context for authentication, logging, cancellation, deadlines, tracing, etc.
sourceId	string
writeKey	string

Other Parameters

Other parameters are passed through a pointer to a apiRemoveWriteKeyFromSourceRequest struct via the builder pattern

Name	Type	Description	Notes

Return type

RemoveWriteKeyFromSource200Response

Authorization

token

HTTP request headers

Content-Type: Not defined
Accept: application/vnd.segment.v1alpha+json, application/json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: ReplaceLabelsInSource

ReplaceLabelsInSource200Response ReplaceLabelsInSource(ctx, sourceId).ReplaceLabelsInSourceV1Input(replaceLabelsInSourceV1Input).Execute()

Replace Labels in Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    sourceId := "rh5BDZp6QDHvXFCkibm1pR" // string | 
    replaceLabelsInSourceV1Input := *api.NewReplaceLabelsInSourceV1Input([]api.LabelV1{*api.NewLabelV1("Key_example", "Value_example")}) // ReplaceLabelsInSourceV1Input | 

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.ReplaceLabelsInSource(ctx, sourceId).ReplaceLabelsInSourceV1Input(replaceLabelsInSourceV1Input).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.ReplaceLabelsInSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `ReplaceLabelsInSource`: ReplaceLabelsInSource200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.ReplaceLabelsInSource`: %v\n", resp.GetData())
}

Path Parameters

Name	Type	Description	Notes
ctx	context.Context	context for authentication, logging, cancellation, deadlines, tracing, etc.
sourceId	string

Other Parameters

Other parameters are passed through a pointer to a apiReplaceLabelsInSourceRequest struct via the builder pattern

Name	Type	Description	Notes

replaceLabelsInSourceV1Input | ReplaceLabelsInSourceV1Input | |

Return type

ReplaceLabelsInSource200Response

Authorization

token

HTTP request headers

Content-Type: application/json, application/vnd.segment.v1+json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json
Accept: application/vnd.segment.v1+json, application/json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: UpdateSchemaSettingsInSource

UpdateSchemaSettingsInSource200Response UpdateSchemaSettingsInSource(ctx, sourceId).UpdateSchemaSettingsInSourceV1Input(updateSchemaSettingsInSourceV1Input).Execute()

Update Schema Settings in Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    sourceId := "qQEHquLrjRDN9j1ByrChyn" // string | 
    updateSchemaSettingsInSourceV1Input := *api.NewUpdateSchemaSettingsInSourceV1Input() // UpdateSchemaSettingsInSourceV1Input | 

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.UpdateSchemaSettingsInSource(ctx, sourceId).UpdateSchemaSettingsInSourceV1Input(updateSchemaSettingsInSourceV1Input).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.UpdateSchemaSettingsInSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `UpdateSchemaSettingsInSource`: UpdateSchemaSettingsInSource200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.UpdateSchemaSettingsInSource`: %v\n", resp.GetData())
}

Path Parameters

Name	Type	Description	Notes
ctx	context.Context	context for authentication, logging, cancellation, deadlines, tracing, etc.
sourceId	string

Other Parameters

Other parameters are passed through a pointer to a apiUpdateSchemaSettingsInSourceRequest struct via the builder pattern

Name	Type	Description	Notes

updateSchemaSettingsInSourceV1Input | UpdateSchemaSettingsInSourceV1Input | |

Return type

UpdateSchemaSettingsInSource200Response

Authorization

token

HTTP request headers

Content-Type: application/json, application/vnd.segment.v1+json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json
Accept: application/vnd.segment.v1+json, application/json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Operation: UpdateSource

UpdateSource200Response UpdateSource(ctx, sourceId).UpdateSourceV1Input(updateSourceV1Input).Execute()

Update Source

Example

package main

import (
    "context"
    "fmt"
    "os"
    api "github.com/segmentio/public-api-sdk-go"
)

func main() {
    sourceId := "44LMHs8Wf5vidxba4kN52J" // string | 
    updateSourceV1Input := *api.NewUpdateSourceV1Input() // UpdateSourceV1Input | 

    configuration := api.NewConfiguration()
    apiClient := api.NewAPIClient(configuration)
    token := "<BEARER_TOKEN>"
    ctx := context.WithValue(context.Background(), api.ContextAccessToken, token)
    resp, r, err := apiClient.SourcesAPI.UpdateSource(ctx, sourceId).UpdateSourceV1Input(updateSourceV1Input).Execute()
    if err != nil {
        fmt.Fprintf(os.Stderr, "Error when calling `SourcesAPI.UpdateSource``: %v\n", err)
        fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
        responseErrors := api.UnwrapFullErrors(err)
        if responseErrors != nil {
            for _, responseError := range responseErrors.Errors {
                fmt.Fprintf(os.Stderr, "Full error message: %v\n", *responseError.Message)
            }
        }
    }
    // response from `UpdateSource`: UpdateSource200Response
    fmt.Fprintf(os.Stdout, "Response from `SourcesAPI.UpdateSource`: %v\n", resp.GetData())
}

Path Parameters

Name	Type	Description	Notes
ctx	context.Context	context for authentication, logging, cancellation, deadlines, tracing, etc.
sourceId	string

Other Parameters

Other parameters are passed through a pointer to a apiUpdateSourceRequest struct via the builder pattern

Name	Type	Description	Notes

updateSourceV1Input | UpdateSourceV1Input | |

Return type

UpdateSource200Response

Authorization

token

HTTP request headers

Content-Type: application/json, application/vnd.segment.v1+json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json
Accept: application/vnd.segment.v1+json, application/json, application/vnd.segment.v1beta+json, application/vnd.segment.v1alpha+json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

Files

SourcesAPI.md

Latest commit

History

SourcesAPI.md

File metadata and controls

\SourcesAPI

Operation: AddLabelsToSource

Example

Path Parameters

Other Parameters

Return type

Authorization

HTTP request headers

Operation: CreateSource

Example

Path Parameters

Other Parameters

Return type

Authorization

HTTP request headers

Operation: CreateWriteKeyForSource

Example

Path Parameters

Other Parameters

Return type

Authorization

HTTP request headers

Operation: DeleteSource

Example

Path Parameters

Other Parameters

Return type

Authorization

HTTP request headers

Operation: GetSource

Example

Path Parameters

Other Parameters

Return type

Authorization

HTTP request headers

Operation: ListConnectedDestinationsFromSource

Example

Path Parameters

Other Parameters

Return type

Authorization

HTTP request headers

Operation: ListConnectedWarehousesFromSource

Example

Path Parameters

Other Parameters

Return type

Authorization

HTTP request headers

Operation: ListSchemaSettingsInSource

Example

Path Parameters

Other Parameters

Return type

Authorization

HTTP request headers

Operation: ListSources

Example

Path Parameters

Other Parameters

Return type

Authorization

HTTP request headers

Operation: RemoveWriteKeyFromSource

Example

Path Parameters

Other Parameters

Return type

Authorization

HTTP request headers

Operation: ReplaceLabelsInSource

Example

Path Parameters