Использование сообщений Protobuf в Pcollection в Apache Beam с использованием Go вызывает ошибку

func processPubSubMsgFn(ctx context.Context, in *pubsub.PubsubMessage) v1.someProto {
    someProto := &v1.someProto{}
    if err := proto.Unmarshal((in.Data), someProto); err != nil {
        log.Fatalln("Failed to parse address book:", err)
    }
    return *someProto
}

Причины: неверный тип возвращаемого значения вызванный: структура кодирования v1.someProto тип имеет неэкспортированное поле: состояние

При попытке запустить конвейер в java я устанавливал кодировщик для типа сообщения, но не знаю, как это сделать в версии Go Apache Beam