nifi

package
v0.0.0-...-5fc95be Latest Latest
Warning

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

Go to latest
Published: Mar 9, 2017 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Call

func Call(fn Handler, req Request) *resty.Response

Call is used to invoke functions of type Handler.

func DoBackup

func DoBackup(ac *conf.AppConfig)

DoBackup contains the business logic for performing Nifi backups.

func ProcessGetProcessGroupFlow

func ProcessGetProcessGroupFlow(respBody []byte) []byte

ProcessGetProcessGroupFlow takes the response body from flow/ProcessGroup and returns a JSON payload to create a snippet

func ProcessSnippetResponse

func ProcessSnippetResponse(respBody []byte) string

ProcessSnippetResponse takes the response body from snippets post and returns snippetId.

func ProcessTemplateRequest

func ProcessTemplateRequest(tmplBody map[string]interface{}) []byte

ProcessTemplateRequest builds a request body for a templates post

func ProcessTemplateResponse

func ProcessTemplateResponse(respBody []byte) string

ProcessTemplateResponse takes the response body from template create post and returns templateId.

Types

type CredentialsInfo

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

CredentialsInfo holds the authentication credentials for Nifi.

type Handler

type Handler interface {
	RestCall(Request) *resty.Response
}

Handler interface provides an error-handling wrapper for REST calls.

type Request

type Request struct {
	Id   string
	Body interface{}
}

Request holds Id and Body for REST requests.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL