zbc-go: github.com/zeebe-io/zbc-go/zbc Index | Files | Directories

package zbc

import "github.com/zeebe-io/zbc-go/zbc"

Index

Package Files

client.go

Constants

const LatestVersion = -1

func NewJob Uses

func NewJob(typeName string) *zbmsgpack.Job

NewJob is constructor for Job object. Function signature denotes mandatory fields.

func NewResource Uses

func NewResource(resourceName, resourceType string, resource []byte) *zbmsgpack.Resource

NewResource will create new message pack resource.

func NewWorkflowInstance Uses

func NewWorkflowInstance(bpmnProcessID string, version int, payload interface{}) *zbmsgpack.CreateWorkflowInstance

NewWorkflowInstance will create new workflow instance.

type Client Uses

type Client struct {
    zbsubscribe.ZeebeAPI
}

Client for Zeebe broker with support for clustered deployment.

func NewClient Uses

func NewClient(bootstrapAddr string) (*Client, error)

NewClient is constructor for Client structure. It will resolve IP address and dial the provided tcp address.

type ProtocolSerializer Uses

type ProtocolSerializer struct{}

func NewProtocolSerializer Uses

func NewProtocolSerializer() *ProtocolSerializer

func (*ProtocolSerializer) UnmarshalFromFile Uses

func (ps *ProtocolSerializer) UnmarshalFromFile(path string) (*zbdispatch.Message, error)

UnmarshalFromFile will read binary message from disk.

Directories

PathSynopsis
common
models/zbdispatch
models/zbmsgpack
models/zbprotocol
models/zbsbe
models/zbsubscriptions
services/zbexchange
services/zbsocket
services/zbsubscribe
services/zbtopology
services/zbtransport

Package zbc imports 7 packages (graph) and is imported by 3 packages. Updated 2018-07-18. Refresh now. Tools for package owners.