grpshuffle_client

Documentation

Index

• Constants
• Variables
• func CloseConnect(conn *grpc.ClientConn)
• func Connect(host string, port int, noTls bool) (conn *grpc.ClientConn, err error)
• func HttpServe(port int)
• func Shuffle(cc *grpshuffle.ComputeClient, divide uint64, targets []string) ([]*grpshuffle.Combination, error)
• type HealthCheckResponse
  • func HealthCheck(hc *health.HealthClient) (*HealthCheckResponse, error)
• type HttpResponse
• type ResponseFormat

Constants

const (
	FormatJson       = "json"
	FormatJsonPretty = "json-pretty"
	FormatReadable   = "readable"
)

Variables

var (
	Host  string // Host is host of grpshuffle server
	Port  int    // Port is port of grpshuffle server
	NoTLS bool   // NoTLS disables TLS
)

Functions

func CloseConnect

func CloseConnect(conn *grpc.ClientConn)

CloseConnect is close grpc.ClientConn

func Connect

func Connect(host string, port int, noTls bool) (conn *grpc.ClientConn, err error)

Connect is create grpc.ClientConn

func HttpServe

func HttpServe(port int)

HttpServe is serve http server for grpshuffle-client

func Shuffle

func Shuffle(cc *grpshuffle.ComputeClient, divide uint64, targets []string) ([]*grpshuffle.Combination, error)

Shuffle is request to grpshuffle.ComputeClient

Types

type HealthCheckResponse

type HealthCheckResponse struct {
	Status string `json:"status"`
}

HealthCheckResponse is response HealthCheck

func HealthCheck

func HealthCheck(hc *health.HealthClient) (*HealthCheckResponse, error)

HealthCheck is request to grpc_health_v1.HealthClient

type HttpResponse

type HttpResponse struct {
	Status int         `json:"status"`
	Msg    string      `json:"msg"`
	Result interface{} `json:"result"`
}

HttpResponse is response http server for grpshuffle-client

type ResponseFormat

type ResponseFormat string