compass

Documentation

Index

• type Schema
  • func GetTopicSchema(ctx context.Context, cl compassv1beta1grpc.CompassServiceClient, ...) (Schema, error)

Types

type Schema

type Schema struct {
	Name        string `json:"name"`
	NamespaceID string `json:"namespaceId"`
	SchemaID    string `json:"schemaId"`
	VersionID   int    `json:"versionId"`
}

func GetTopicSchema

func GetTopicSchema(ctx context.Context, cl compassv1beta1grpc.CompassServiceClient,
	userID, projectSlug, stream, topic string, protoNames []string,
) (Schema, error)