client

Documentation

Index

• func BootstrapInit(mashupPath string, mashupApiHandler mashupsdk.MashupApiHandler, ...) *mashupsdk.MashupContext
• func BootstrapInitWithMessageExt(mashupPath string, mashupApiHandler mashupsdk.MashupApiHandler, ...) *mashupsdk.MashupContext
• func GetServerAuthToken() string
• func InitDialOptions(dialOption grpc.DialOption)
• type MashupClient
  • func (c *MashupClient) CollaborateInit(ctx context.Context, in *mashupsdk.MashupConnectionConfigs) (*mashupsdk.MashupConnectionConfigs, error)
  • func (c *MashupClient) GetElements(ctx context.Context, in *mashupsdk.MashupEmpty) (*mashupsdk.MashupDetailedElementBundle, error)
  • func (c *MashupClient) OnDisplayChange(ctx context.Context, in *mashupsdk.MashupDisplayBundle) (*mashupsdk.MashupDisplayHint, error)
  • func (s *MashupClient) Shutdown(ctx context.Context, in *mashupsdk.MashupEmpty) (*mashupsdk.MashupEmpty, error)
  • func (c *MashupClient) TweakStates(ctx context.Context, in *mashupsdk.MashupElementStateBundle) (*mashupsdk.MashupElementStateBundle, error)
  • func (c *MashupClient) UpsertElements(ctx context.Context, in *mashupsdk.MashupDetailedElementBundle) (*mashupsdk.MashupDetailedElementBundle, error)

Functions

func BootstrapInit

func BootstrapInit(mashupPath string,
	mashupApiHandler mashupsdk.MashupApiHandler,
	envParams []string,
	params []string,
	insecure *bool) *mashupsdk.MashupContext

For a remote server/client initialization, ensure envParams is of the form: [remote server name, remote server port, client server name, client server port] Also for a remote server/client initialization, ensure params is of the format: ["remote", Remote Server Auth Token] For client initialization where the server does not know the client's address, ensure params if of the form: ["flume", Server Auth Token]

func BootstrapInitWithMessageExt

func BootstrapInitWithMessageExt(mashupPath string,
	mashupApiHandler mashupsdk.MashupApiHandler,
	envParams []string,
	params []string,
	insecure *bool, maxMessageLength int) *mashupsdk.MashupContext

BootstrapInitWithMessageExt - main entry point for bootstrapping the sdk. This will fork a mashup, connect with it, and handshake with it to establish shared set of credentials to be used in future transactions.

func GetServerAuthToken

func GetServerAuthToken() string

func InitDialOptions

func InitDialOptions(dialOption grpc.DialOption)

Types

type MashupClient

type MashupClient struct {
	mashupsdk.UnimplementedMashupServerServer
	// contains filtered or unexported fields
}

func (*MashupClient) CollaborateInit

func (c *MashupClient) CollaborateInit(ctx context.Context, in *mashupsdk.MashupConnectionConfigs) (*mashupsdk.MashupConnectionConfigs, error)

CollaborateInit - Implementation of the handshake. During the callback from the mashup, construct new more permanent set of credentials to be shared.

func (*MashupClient) GetElements

func (c *MashupClient) GetElements(ctx context.Context, in *mashupsdk.MashupEmpty) (*mashupsdk.MashupDetailedElementBundle, error)

Shutdown -- handles request to shut down the mashup.

func (*MashupClient) OnDisplayChange

func (c *MashupClient) OnDisplayChange(ctx context.Context, in *mashupsdk.MashupDisplayBundle) (*mashupsdk.MashupDisplayHint, error)

func (*MashupClient) Shutdown

func (s *MashupClient) Shutdown(ctx context.Context, in *mashupsdk.MashupEmpty) (*mashupsdk.MashupEmpty, error)

Shutdown -- handles request to shut down the mashup.

func (*MashupClient) TweakStates

func (c *MashupClient) TweakStates(ctx context.Context, in *mashupsdk.MashupElementStateBundle) (*mashupsdk.MashupElementStateBundle, error)

func (*MashupClient) UpsertElements

func (c *MashupClient) UpsertElements(ctx context.Context, in *mashupsdk.MashupDetailedElementBundle) (*mashupsdk.MashupDetailedElementBundle, error)